python中rabbitmq指的是什么
发表于:2024-12-12 作者:千家信息网编辑
千家信息网最后更新 2024年12月12日,这篇文章给大家分享的是有关python中rabbitmq指的是什么的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。1、当信息在一个队列中变成死信时,可以重新发送到DLX,绑定
千家信息网最后更新 2024年12月12日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安全错误
数据库的锁怎样保障安全
上海康盛网络技术有限公司
辽宁时代网络技术产品介绍
扶沟百事通网络技术
有关网络安全方面的知识
完美服务器异常什么情况
小米app连接服务器
电力监测网络安全系统
异构服务器支持分散的业务吗
网络安全立体美术字怎么写
私人云盘与服务器的区别
裸金属服务器常见行业场景
网易mc服务器指令调节延迟
浙江软件开发推广
零基础学计算机网络技术的书
思科网络技术学院第十章总结
怎么建立数据库供别人查询
添加数据库数据库文件位置
教授讲解网络安全
山东省规模大的浪潮服务器代理商
数据库的结构与类型
均衡型服务器是什么意思
免费ssr服务器
网络安全靠大家演讲稿
vpn网关 vpn服务器
飞轮数据库融资
数据库及数据操作实验
软件开发不予验收
武昌放心的软件开发电话
读取plc数据传给数据库
农商银行软件开发面试