时间:2020-11-29来源:www.pcxitongcheng.com作者:电脑系统城
介绍
rabbitmq默认有7个交换机,其中amq.rabbitmq.log为系统日志的交换机,这个日志为topic类型,会有三个等级的(routing_key)的日志发送到这个交换机上。
代码如下
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 |
#!/usr/bin/env python # -*- coding: utf-8 -*- import pika # ########################### 订阅者 ########################### credentials = pika.PlainCredentials( "用户名" , "密码" ) connection = pika.BlockingConnection(pika.ConnectionParameters( 'ip' , 5672 , '/' , credentials = credentials)) channel = connection.channel() # 声明队列 channel.queue_declare(queue = 'info_queue' ,durable = True ) channel.queue_declare(queue = 'error_queue' ,durable = True ) channel.queue_declare(queue = 'warning_queue' ,durable = True ) # 绑定 channel.queue_bind(exchange = 'amq.rabbitmq.log' ,queue = "info_queue" ,routing_key = "info" ) channel.queue_bind(exchange = 'amq.rabbitmq.log' ,queue = "error_queue" ,routing_key = "error" ) channel.queue_bind(exchange = 'amq.rabbitmq.log' ,queue = "warning_queue" ,routing_key = "warning" ) print ( ' [*] Waiting for logs. To exit press CTRL+C' ) def callback(ch, method, properties, body): print ( " [x] %r" % body) print ( " [x] Done" ) ch.basic_ack(delivery_tag = method.delivery_tag) channel.basic_consume( "info_queue" ,callback,auto_ack = False ) channel.basic_consume( "error_queue" ,callback,auto_ack = False ) channel.basic_consume( "warning_queue" ,callback,auto_ack = False ) channel.start_consuming() ''' 然后发布者只需要给exchange发送消息,然后exchange绑定的多个队列都有这个消息了。订阅者就收到这个消息了。 ''' |
以上就是本文的全部内容,希望对大家的学习有所帮助
2020-11-29
Python基于Webhook实现github自动化部署2020-11-29
快速创建python 虚拟环境2020-11-29
详解pandas赋值失败问题解决TQDW也算是独树一帜了,原因主要是因为自身所存在的功能效果,比如我们如果在写项目,往往会忘记我们要完成多少量,而这个库主要就是帮我们实时掌握进度,现在这样跟大家讲解,是不是都来了兴趣呢?因此,那就开启本章正题,给大家详解...
2020-11-18
一般我们在解决问题时候,经常能碰到好几种解决方式,总归是有最优,还有最不推荐的选择的,针对搜索算法也一样,因为能实现的方式也有很多个,因此,不知道大家在什么场景里使用这些算法,反正小编都把这些算法整理出来了,供大家选择...
2020-11-18