這篇“python rabbitmq指的是什么”文章的知識(shí)點(diǎn)大部分人都不太理解,所以小編給大家總結(jié)了以下內(nèi)容,內(nèi)容詳細(xì),步驟清晰,具有一定的借鑒價(jià)值,希望大家閱讀完這篇文章能有所收獲,下面我們一起來看看這篇“python rabbitmq指的是什么”文章吧。
成都創(chuàng)新互聯(lián)成立與2013年,是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司,擁有項(xiàng)目成都做網(wǎng)站、成都網(wǎng)站制作網(wǎng)站策劃,項(xiàng)目實(shí)施與項(xiàng)目整合能力。我們以讓每一個(gè)夢想脫穎而出為使命,1280元密云做網(wǎng)站,已為上家服務(wù),為密云各地企業(yè)和個(gè)人服務(wù),聯(lián)系電話:18982081108
1、當(dāng)信息在一個(gè)隊(duì)列中變成死信時(shí),可以重新發(fā)送到DLX,綁定DLX的隊(duì)列稱為rabbitmq。
也叫死信隊(duì)列。
2、常用于訂單超時(shí)自動(dòng)取消,會(huì)議預(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ì)列,消息將在這個(gè)隊(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)容,相信大家都有了一定的了解,希望小編分享的內(nèi)容對大家有幫助,若想了解更多相關(guān)的知識(shí)內(nèi)容,請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
標(biāo)題名稱:pythonrabbitmq指的是什么
新聞來源:http://jinyejixie.com/article48/pshcep.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站設(shè)計(jì)公司、定制網(wǎng)站、虛擬主機(jī)、企業(yè)建站、定制開發(fā)、微信小程序
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)