rabbitmq更细致的过滤-创新互联

发送端：

在瓦房店等地区，都构建了全面的区域性战略布局，加强发展的系统性、市场前瞻性、产品创新能力，以专注、极致的服务理念，为客户提供做网站、成都做网站 网站设计制作按需制作网站,公司网站建设,企业网站建设,品牌网站制作,成都全网营销,外贸网站建设,瓦房店网站建设费用合理。import pika import sys connection = pika.BlockingConnection(pika.ConnectionParameters(     host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='topic_logs',                          exchange_type='topic') routing_key = sys.argv[1] if len(sys.argv) > 1 else 'anonymous.info' message = ' '.join(sys.argv[2:]) or 'Hello World!' channel.basic_publish(exchange='topic_logs',                       routing_key=routing_key,                       body=message) print(" [x] Sent %r:%r" % (routing_key, message)) connection.close()

接收端：

import pika import sys connection = pika.BlockingConnection(pika.ConnectionParameters(     host='localhost')) channel = connection.channel() channel.exchange_declare(exchange='topic_logs',                          exchange_type='topic') result = channel.queue_declare(exclusive=True) queue_name = result.method.queue binding_keys = sys.argv[1:] if not binding_keys:     sys.stderr.write("Usage: %s [binding_key]...\n" % sys.argv[0])     sys.exit(1) for binding_key in binding_keys:     channel.queue_bind(exchange='topic_logs',                        queue=queue_name,                        routing_key=binding_key) 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://6mz.cn/article/dhdhhp.html