rabbitmq有选择的接收消息-创新互联

发送端：

网站建设哪家好，找成都创新互联公司！专注于网页设计、网站建设、微信开发、成都微信小程序、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了兴业免费建站欢迎大家使用！import pika import sys connection = pika.BlockingConnection(pika.ConnectionParameters(     host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='direct_logs',                          exchange_type='direct') severity = sys.argv[1] if len(sys.argv) > 1 else 'info' message = ' '.join(sys.argv[2:]) or 'Hello World!' channel.basic_publish(exchange='direct_logs',                       routing_key=severity,                       body=message) print(" [x] Sent %r:%r" % (severity, message)) connection.close()

接收端：

import pika import sys connection = pika.BlockingConnection(pika.ConnectionParameters(     host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='direct_logs',                          exchange_type='direct') result = channel.queue_declare(exclusive=True) queue_name = result.method.queue severities = sys.argv[1:] if not severities:     sys.stderr.write("Usage: %s [info] [warning] [error]\n" % sys.argv[0])     sys.exit(1) for severity in severities:     channel.queue_bind(exchange='direct_logs',                        queue=queue_name,                        routing_key=severity) print(' [*] Waiting for logs. To exit press CTRL+C') def callback(ch, method, properties, body):     print(" [x] %r:%r" % (method.routing_key, body)) channel.basic_consume(callback,                       queue=queue_name,                       no_ack=True) channel.start_consuming()

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

分享题目：rabbitmq有选择的接收消息-创新互联
本文网址：http://cxhlcq.com/article/dephsc.html