建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯網營銷解決方案
創(chuàng)新互聯Python教程：pythonrabbitmq是什么
1、當信息在一個隊列中變成死信時，可以重新發(fā)送到DLX，綁定DLX的隊列稱為RabbitMQ。
創(chuàng)新互聯專業(yè)為企業(yè)提供柯城網站建設、柯城做網站、柯城網站設計、柯城網站制作等企業(yè)網站建設、網頁設計與制作、柯城企業(yè)網站模板建站服務，10余年柯城做網站經驗，不只是建網站，更提供有價值的思路和整體網絡服務。
也叫死信隊列。
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()
# 聲明消息隊列，消息將在這個隊列傳遞，如不存在，則創(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})
# 向隊列插入數值 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的介紹，希望對大家有所幫助。更多Python學習指路：創(chuàng)新互聯python教程
本文教程操作環(huán)境：windows7系統(tǒng)、Python 3.9.1，DELL G3電腦。
名稱欄目：創(chuàng)新互聯Python教程：pythonrabbitmq是什么
文章起源：http://www.5511xx.com/article/coeoisi.html
