消息推送系统

sudo apt-get update

sudo apt-get install rabbitmq-server

# 启动服务

sudo systemctl start rabbitmq-server

sudo systemctl enable rabbitmq-server

rabbitmqadmin declare queue name=my_queue

# 发送消息

rabbitmqadmin publish exchange="amq.direct" routing_key="my_queue" payload="Hello World"

def callback(ch, method, properties, body):

print("Received %r" % body)

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

channel = connection.channel()

channel.queue_declare(queue='my_queue')

channel.basic_consume(queue='my_queue', on_message_callback=callback, auto_ack=True)

channel.start_consuming()