RabbitMQ是什么,rabbitmq是干什么的
1、当信息在一个队列中变成死信时,可以重新发送到DLX,绑定DLX的队列称为rabbitmq。
也叫死信队列。
2、常用于订单超时自动取消,会议预订提前提醒等等。
实例
进口皮卡
importjson
进口时间
凭据=鼠兔。纯凭据( admin , admin)#mq用户名和密码
#虚拟队列需要指定参数虚拟主机,如果是默认的可以不填。
连接=鼠兔BlockingConnection(pika .连接参数(主机=127.0.0.1 ,端口=5672,凭据=凭据))
channel=connection.channel()
#声明消息队列,消息将在这个队列传递,如不存在,则创建
queue_name=delay_queue_a
exchange=delay_exchange_a
routing _ key= delay _ routing _ key _ a
dead _ letter _ exchange= dead _ exchange _ a # amq。直接 # dead _ exchange _ a
dead _ letter _ routing _ key= dead _ letter _ routing _ key _ a # dead _ queue _ a # dead _ letter _ routing _ key _ a
参数={
x消息-ttl:5000,
x-死信交换 :死信交换,
x-dead-letter-routing-key : dead _ letter _ routing _ key
}
渠道。确认_交付()
渠道。exchange _ declare(exchange=exchange,durable=True,exchange_type=direct )
结果=渠道。queue _ declare(queue=queue _ name,durable=False,arguments=arguments)
渠道。queue _ bind(exchange=exchange,queue=队列名称路由关键字=路由关键字)
(10):
message=JSON。转储({ OrderId : I })
#向队列插入数值路由_密钥是队列名
渠道。basic _ publish(交换=交换,路由密钥=路由密钥,正文=消息
属性=鼠兔。基本属性(delivery_mode=2))
打印(消息)
时间。睡眠(1.5)
connection.close()以上就是python rabbitmq的介绍,希望对大家有所帮助。更多计算机编程语言学习指路:python基础教程
本文教程操作环境:windows7系统、Python 3.9.1、戴尔自交第三代电脑。
郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。