rabbitmq(python rabbitmq指的是什么)

1、當信息在一個隊列中變成死信時,可以重新發送到DLX,綁定DLX的隊列稱為rabbitmq。

也叫死信隊列。

2、常用于訂單超時自動取消,會議預訂提前提醒等等。

實例

importpikaimportjsonimporttimecredentials=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)foriinrange(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指的是什么”這篇文章的內容,相信大家都有了一定的了解,希望小編分享的內容對大家有幫助,若想了解更多相關的知識內容,請關注本站行業資訊頻道。