统一消息系统

# 生产者代码

import pika

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

channel = connection.channel()

channel.queue_declare(queue='unified_message_queue')

message = 'Hello World!'

channel.basic_publish(exchange='',

routing_key='unified_message_queue',

body=message)

print(" [x] Sent %r" % message)

师生服务大厅

connection.close()

# 消费者代码

import pika

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

channel = connection.channel()

channel.queue_declare(queue='unified_message_queue')

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

print(" [x] Received %r" % body)

channel.basic_consume(queue='unified_message_queue',

on_message_callback=callback,

auto_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')

channel.start_consuming()

]]>