统一消息系统

小明：最近我们在设计一个登录系统，发现用户登录时需要处理很多异步任务，比如发送验证码、记录日志等。你有什么建议吗？

小李：我觉得可以引入“统一消息”机制。比如使用消息队列，把登录事件发布出去，由不同的服务订阅并处理。

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

小李：当然可以。这里是一个简单的 Python 示例，使用 RabbitMQ 实现消息发布：

import pika

def send_login_message(user_id):
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='login_events')
    channel.basic_publish(exchange='', routing_key='login_events', body=str(user_id))
    print(f"Sent login event for user {user_id}")
    connection.close()

    

小明：那接收端怎么处理这些消息呢？

小李：下面是一个消费者示例，用来处理登录事件并发送验证码：

import pika

def callback(ch, method, properties, body):
    user_id = body.decode()
    print(f"Processing login for user {user_id}")
    # 这里可以调用发送验证码的逻辑
    ch.basic_ack(delivery_tag=method.delivery_tag)

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='login_events')
channel.basic_consume(queue='login_events', on_message_callback=callback)
print('Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

    

小明：这样确实能解耦登录逻辑，提升系统的可扩展性。你觉得这个“平台”应该怎么设计呢？

小李：我们可以构建一个统一的消息平台，让所有服务都基于这个平台进行通信，减少重复代码和耦合度。

小明：明白了，感谢你的分享！