pythonrabbitmq消息发布订阅-创新互联

发送端：

创新互联建站专注于来宾网站建设服务及定制，我们拥有丰富的企业做网站经验。 热诚为您提供来宾营销型网站建设，来宾网站制作、来宾网页设计、来宾网站官网定制、重庆小程序开发服务，打造来宾网络公司原创品牌,更为您提供来宾网站排名全网营销落地服务。import pika import sys connection = pika.BlockingConnection(pika.ConnectionParameters(     host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='logs',exchange_type='fanout') message = ' '.join(sys.argv[1:]) or "info: Hello World!" channel.basic_publish(exchange='logs',                       routing_key='',                       body=message) print(" [x] Sent %r" % message) connection.close()

接收端：

import pika connection = pika.BlockingConnection(pika.ConnectionParameters(     host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='logs',                          exchange_type='fanout') result = channel.queue_declare(exclusive=True)  # 不指定queue名字,rabbit会随机分配一个名字,exclusive=True会在使用此queue的消费者断开后,自动将queue删除 queue_name = result.method.queue print(queue_name) channel.queue_bind(exchange='logs',                    queue=queue_name) print(' [*] Waiting for logs. To exit press CTRL+C') def callback(ch, method, properties, body):     print(" [x] %r" % body) channel.basic_consume(callback,                       queue=queue_name,                       no_ack=True) channel.start_consuming()

exchange不会保存数据，如果没客户端接受，就丢弃，也就是说，客户端会丢失启动前发送端发送的数据。

另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

网站栏目：pythonrabbitmq消息发布订阅-创新互联
文章位置：http://dzwzjz.com/article/dscdio.html