统一消息系统

小明：最近我们项目中消息通知部分有点混乱，各种渠道的推送方式不一致，怎么处理？

小李：我觉得可以引入“统一消息服务”来整合所有消息类型，比如邮件、短信、站内信等。

小明：那这个服务要怎么设计呢？有没有具体的实现方案？

小李：我们可以使用消息队列如RabbitMQ或Kafka作为中间件，后端系统将消息发送到队列，由统一消息服务消费并分发。

小明：听起来不错，能给我看个代码示例吗？

小李：当然，下面是一个简单的Python示例，使用RabbitMQ进行消息发布：

import pika

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

channel.queue_declare(queue='message_queue')

message = '{"type": "email", "content": "欢迎注册！", "to": "user@example.com"}'
channel.basic_publish(exchange='', routing_key='message_queue', body=message)
print(" [x] Sent message")
connection.close()
    

小明：那接收方怎么处理呢？

小李：统一消息服务可以订阅该队列，并根据消息类型调用不同的发送接口，例如：

def send_email(message):
    print(f"Sending email to {message['to']}: {message['content']}")

def process_message(ch, method, properties, body):
    message = eval(body)
    if message['type'] == 'email':
        send_email(message)

channel.basic_consume(queue='message_queue', on_message_callback=process_message, auto_ack=True)
channel.start_consuming()
    

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

小李：没错，这不仅提升了系统的可维护性，也方便后续扩展。