统一消息系统

小明：嘿，小李，我最近在做系统设计，感觉各个模块之间的通信有点混乱，你有什么建议吗？

小李：你可以考虑使用统一消息机制。比如用消息队列来解耦模块之间的依赖。

小明：那具体怎么实现呢？能给我举个例子吗？

小李：当然可以。我们可以用Python的`pika`库来实现一个简单的消息队列。比如，用户注册模块发送消息到队列，订单处理模块再从队列中消费消息。

小明：听起来不错，那你能写个代码示例吗？

小李：

    # 生产者（用户注册模块）
    import pika

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

    channel.queue_declare(queue='user_registered')

    channel.basic_publish(exchange='',
                          routing_key='user_registered',
                          body='User registered: John Doe')
    print(" [x] Sent 'User registered: John Doe'")
    connection.close()
    

小明：这是生产者代码，那消费者呢？

小李：

    # 消费者（订单处理模块）
    import pika

    def callback(ch, method, properties, body):
        print(f" [x] Received {body.decode()}")

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

    channel.queue_declare(queue='user_registered')

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

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

小明：明白了！这样每个模块只需要关注自己的逻辑，不需要直接调用其他模块。

小李：没错，这就是架构设计的优势。统一消息让系统更灵活、可扩展。

小明：看来我需要重新设计一下我的模块结构了！

小李：对，合理的设计能让系统更稳定、更容易维护。