RabbitMQ 群发消息实现代码示例 - Python

MQ（消息队列）是一种用于在应用程序之间传递消息的通信模式。群发是指向多个接收者发送相同消息的操作。下面是一个使用 RabbitMQ 实现 MQ 群发的示例代码：\n\npython\nimport pika\n\n# 连接 RabbitMQ 服务器\nconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))\nchannel = connection.channel()\n\n# 声明一个 exchange\nchannel.exchange_declare(exchange='message_exchange', exchange_type='fanout')\n\n# 定义消息内容\nmessage = 'Hello, World!'\n\n# 发布消息到 exchange\nchannel.basic_publish(exchange='message_exchange', routing_key='', body=message)\n\nprint(" [x] Sent %r" % message)\n\n# 关闭连接\nconnection.close()\n\n\n上述代码中，首先创建一个 RabbitMQ 的连接，然后声明一个 exchange（交换机），并将消息发布到该交换机上。在这个例子中，我们使用了 fanout 类型的 exchange，它会向所有绑定到该交换机的队列发送消息。\n\n注意：在实际使用中，你可能需要根据自己的业务需求修改代码，比如修改连接参数、exchange 名称等。同时，你还需要确保 RabbitMQ 服务器已经正确安装和配置。