消息推送系统

小明：嘿，小李，最近我在设计一个微服务系统，遇到了消息处理的问题。你有什么建议吗？

小李：你可以考虑使用统一消息机制，这样可以避免各个服务之间直接耦合。

小明：统一消息？具体怎么实现呢？

小李：比如你可以用消息队列，像RabbitMQ或者Kafka。然后定义一个统一的消息格式，比如JSON。

小明：那是不是还需要一个统一的架构来支撑这个消息系统？

小李：没错，架构上应该有一个消息中心，负责接收、分发和管理所有消息。比如你可以用一个消息代理服务，其他服务都通过它进行通信。

小明：听起来不错，那你能给我一个简单的代码示例吗？

小李：当然可以。下面是一个使用Python和RabbitMQ的简单生产者和消费者示例：

    # 生产者
    import pika

    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='task_queue', durable=True)

    message = 'Hello World!'
    channel.basic_publish(
        exchange='',
        routing_key='task_queue',
        body=message,
        properties=pika.BasicProperties(delivery_mode=2)  # 持久化
    )
    print(" [x] Sent %r" % message)
    connection.close()
    

    # 消费者
    import pika

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

    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='task_queue', durable=True)

    channel.basic_consume(callback, queue='task_queue')

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

小明：明白了，这样就能实现统一的消息处理了。

排课系统

小李：对，而且这种架构也便于扩展和维护。你可以根据需要增加更多的服务，而不需要修改现有的消息逻辑。