这篇文章给大家分享的是有关python中rabbitmq指的是什么的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。
1、当信息在一个队列中变成死信时,可以重新发送到DLX,绑定DLX的队列称为rabbitmq。
也叫死信队列。
2、常用于订单超时自动取消,会议预订提前提醒等等。
实例
import pika import json import 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指的是什么”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。