日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間:8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
創(chuàng)新互聯(lián)Python教程:pythonrabbitmq是什么

1、當(dāng)信息在一個(gè)隊(duì)列中變成死信時(shí),可以重新發(fā)送到DLX,綁定DLX的隊(duì)列稱(chēng)為RabbitMQ。

創(chuàng)新互聯(lián)專(zhuān)業(yè)為企業(yè)提供柯城網(wǎng)站建設(shè)、柯城做網(wǎng)站、柯城網(wǎng)站設(shè)計(jì)、柯城網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)與制作、柯城企業(yè)網(wǎng)站模板建站服務(wù),10余年柯城做網(wǎng)站經(jīng)驗(yàn),不只是建網(wǎng)站,更提供有價(jià)值的思路和整體網(wǎng)絡(luò)服務(wù)。

也叫死信隊(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()

以上就是python rabbitmq的介紹,希望對(duì)大家有所幫助。更多Python學(xué)習(xí)指路:創(chuàng)新互聯(lián)python教程

本文教程操作環(huán)境:windows7系統(tǒng)、Python 3.9.1,DELL G3電腦。


文章標(biāo)題:創(chuàng)新互聯(lián)Python教程:pythonrabbitmq是什么
瀏覽路徑:http://m.5511xx.com/article/coeoisi.html