统一消息系统

小明：最近我们在做一个电商平台，感觉消息处理有点混乱，你有什么建议吗？

小李：你可以考虑引入一个统一消息系统，比如用RabbitMQ或者Kafka来管理消息流。

小明：那怎么实现呢？能给我看看代码吗？

小李：当然可以。下面是一个使用Python和RabbitMQ发送消息的例子：

import pika

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

channel.queue_declare(queue='order_notifications')

channel.basic_publish(exchange='',
                      routing_key='order_notifications',
                      body='订单已创建')
print(" [x] Sent '订单已创建'")
connection.close()
    

小明：这个是发送端的代码，那接收端呢？

小李：接收端的代码如下：

import pika

def callback(ch, method, properties, body):
    print(" [x] 收到消息: %r" % body)

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

channel.queue_declare(queue='order_notifications')

channel.basic_consume(callback,
                      queue='order_notifications',
                      no_ack=True)

print(' [*] 等待消息。按 CTRL+C 退出')
channel.start_consuming()
    

小明：明白了，这样就能统一处理各种消息了。

小李：没错，统一消息系统能提升系统的可扩展性和稳定性，特别是在后端架构中非常关键。

小明：谢谢你，我回去就试试看。

小李：没问题，有需要随时问我。