python中rabbitmq指的是什么
发表于:2025-01-19 作者:千家信息网编辑
千家信息网最后更新 2025年01月19日,这篇文章给大家分享的是有关python中rabbitmq指的是什么的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。1、当信息在一个队列中变成死信时,可以重新发送到DLX,绑定
千家信息网最后更新 2025年01月19日python中rabbitmq指的是什么
这篇文章给大家分享的是有关python中rabbitmq指的是什么的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。
1、当信息在一个队列中变成死信时,可以重新发送到DLX,绑定DLX的队列称为rabbitmq。
也叫死信队列。
2、常用于订单超时自动取消,会议预订提前提醒等等。
实例
import pikaimport jsonimport time credentials = pika.PlainCredentials('admin', 'admin') # mq用户名和密码# 虚拟队列需要指定参数 virtual_host,如果是默认的可以不填。connection = pika.BlockingConnection(pika.ConnectionParameters(host='127.0.0.1', port=5672, credentials=credentials))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.direct'#'dead_exchange_a'dead_letter_routing_key = 'dead_letter_routing_key_a' # 'dead_queue_a'#'dead_letter_routing_key_a'arguments = { "x-message-ttl": 5000, 'x-dead-letter-exchange': dead_letter_exchange, 'x-dead-letter-routing-key': dead_letter_routing_key} channel.confirm_delivery() channel.exchange_declare(exchange=exchange, durable=True, exchange_type='direct')result = channel.queue_declare(queue=queue_name, durable=False, arguments=arguments)channel.queue_bind(exchange=exchange, queue=queue_name, routing_key=routing_key)for i in range(10): message = json.dumps({'OrderId': i}) # 向队列插入数值 routing_key是队列名 channel.basic_publish(exchange=exchange, routing_key=routing_key, body=message, properties=pika.BasicProperties(delivery_mode=2)) print(message) time.sleep(1.5) connection.close()
感谢各位的阅读!关于"python中rabbitmq指的是什么"这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!
队列
内容
更多
死信
消息
篇文章
不错
实用
会议
会议预订
信息
参数
实例
密码
数值
文章
用户
用户名
看吧
知识
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
当前软件开发的社会环境
无线传感器网络安全隐患
互联网在科技领域的利
查看服务器信息内核
软件开发获奖发言
什么电脑可以用阿里云服务器
我的世界服务器火影忍者电脑版
医学数据库网站投稿
广州科信网络技术
圆通快递本地数据库默认名称
计算机网络技术 大专
计算机软件开发效率如何提高
java连接数据库sql
土地利用现状数据库 涉密
山东256互联网科技公司
预防发生危害网络安全的事件
支持mdx数据库开源
国内安全服务器
服务器拒绝连接网络
软件开发的法律责任
圆通快递本地数据库默认名称
广东定制软件开发排行榜
2k19服务器关闭怎么联网
信息系统数据库怎么弄
杭州橡胶零件加工管理软件开发
贵州众易帮互联网科技
怎样开启服务器8080
和元软件开发消息
大学生网络安全竞赛
软件开发月入多少