统一消息系统

小明：嘿，小李，最近我在研究一个统一消息平台，想用Python来实现。你有什么建议吗？

小李：当然可以！你可以考虑使用像RabbitMQ或者Redis这样的消息队列系统，它们非常适合做消息的发布和订阅。

小明：那怎么用Python来连接这些服务呢？有没有具体的例子？

小李：当然有。比如用pika库连接RabbitMQ。我给你写个简单的生产者和消费者代码吧。

小明：太好了，快给我看看！

小李：这是生产者的代码：

    import pika

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

    channel.queue_declare(queue='hello')

    channel.basic_publish(exchange='',
                          routing_key='hello',
                          body='Hello World!')
    print(" [x] Sent 'Hello World!'")
    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='hello')

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

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

小明：明白了，这样就能在Python中实现消息的发送和接收了。

小李：没错。如果你想构建一个统一的消息平台，还可以结合REST API，让不同系统都能通过HTTP接口发送或接收消息。

小明：听起来很有用，我得试试看！

小李：没问题，随时交流。