小明：最近我们在做一个综合信息门户的项目，感觉系统之间沟通起来有点麻烦。

小李：是啊，很多模块都是独立开发的，数据和消息传递不一致。有没有考虑用统一消息来整合？

小明：统一消息？具体是什么意思？

小李：就是使用一个统一的消息队列或消息中间件，比如RabbitMQ或者Kafka，让各个模块通过这个平台进行通信，这样就能避免直接调用接口带来的耦合问题。

小明：听起来不错。那在架构上怎么设计呢？

小李：我们可以把整个门户拆分成多个微服务，每个服务负责自己的业务逻辑，然后通过统一消息进行交互。比如用户登录后，发送一条消息到消息队列，其他模块就可以订阅这条消息并做出响应。

小明：那代码方面怎么实现呢？

小李：举个例子，我们用Python写一个简单的消息生产者：

    import pika

    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='user_login')

    channel.basic_publish(exchange='',
                          routing_key='user_login',
                          body='User logged in')
    print(" [x] Sent 'User logged in'")
    connection.close()
    

小明：那消费者端呢？

小李：这是消费者代码：

    import pika

    def callback(ch, method, properties, body):
        print(" [x] Received %r" % body)

    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='user_login')

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

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

小明：明白了！这样就实现了统一消息的机制，系统之间的通信也更清晰了。

小李：没错，这就是现代系统架构中常用的设计方式。