python中rabbitmq指的是什么

這篇文章給大家分享的是有關(guān)python中rabbitmq指的是什么的內(nèi)容。小編覺得挺實(shí)用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

1、當(dāng)信息在一個隊(duì)列中變成死信時，可以重新發(fā)送到DLX，綁定DLX的隊(duì)列稱為rabbitmq。

也叫死信隊(duì)列。

2、常用于訂單超時自動取消，會議預(yù)訂提前提醒等等。

實(shí)例

import pika
import json
import time
 
credentials = pika.PlainCredentials('admin', 'admin')  # mq用戶名和密碼
# 虛擬隊(duì)列需要指定參數(shù) virtual_host，如果是默認(rèn)的可以不填。
connection = pika.BlockingConnection(pika.ConnectionParameters(host='127.0.0.1', port=5672, credentials=credentials))
channel = connection.channel()
# 聲明消息隊(duì)列，消息將在這個隊(duì)列傳遞，如不存在，則創(chuàng)建
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})
    # 向隊(duì)列插入數(shù)值 routing_key是隊(duì)列名
    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()

感謝各位的閱讀！關(guān)于“python中rabbitmq指的是什么”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學(xué)到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！