RabbitMQ 核心概念死信延時佇列

rabbitmq訊息傳遞模型的核心思想是生產者從不將任何訊息直接傳送到佇列。實際上，生產者經常甚至根本不知道是否將訊息傳遞到任何佇列。

send.py

import pika
connection = pika.blockingconnection(
pika.connectionparameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello', body='hello world!')
print(" [x] sent 'hello world!'")
connection.close()

recive.py

import pika, sys, os
def main():
connection = pika.blockingconnection(pika.connectionparameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
print(" [x] received %r" % body)
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=true)
print(' [*] waiting for messages. to exit press ctrl+c')
channel.start_consuming()
if __name__ == '__main__':
try:
main()
except keyboardinterrupt:
print('interrupted')
try:
sys.exit(0)
except systemexit:
os._exit(0)

producer exchange、routing_key queue consumer

producer 將訊息發往exchange

預設使用的是direct型別，exchange為空，根據routing_key找到queue或者建立queue

channel.basic_publish(exchange='', routing_key='hello', body='hello world!')

生產者只能將訊息傳送到exchange,交流是一件非常簡單的事情。一方面，它接收來自生產者的訊息，另一方面，將它們推入佇列。交易所必須確切知道如何處理收到的訊息。是否應將其附加到特定佇列？是否應該將其附加到許多佇列中？還是應該丟棄它。規則由交換型別定義。

有幾種交換型別可用：direct，topic，headers 和fanout。我們將集中討論最後乙個-fanout。讓我們建立該型別的交換，並將其稱為log：

channel.exchange_declare（exchange = 'logs'，
exchange_type = 'fanout'）

發布或者訂閱時指定routing_key

exchange 在direct型別時：routing_key 和exchange 訊息所屬佇列；

exchange 在topic 模式下時：

"#"：匹配所有的路由鍵

"work.#"：無匹配

exchangezai fanout型別時：

到達該exchange的所有訊息將會傳送到繫結到該exchange的所有佇列

訊息被否定確認，使用channel.basic_nack或channel.basic_reject，並且此時requeue屬性被設定為false。

訊息在佇列的存活時間超過設定的ttl時間。

訊息佇列的訊息數量已經超過最大佇列長度。

那麼該訊息將成為「死信」。

「死信」訊息會被rabbitmq進行特殊處理，如果配置了死信佇列資訊，那麼該訊息將會被丟進死信佇列中，如果沒有配置，則該訊息將會被丟棄。

死信訊息的生命週期：

業務訊息被投入業務佇列

消費者消費業務佇列的訊息，由於處理過程中發生異常，於是進行了nck或者reject操作

被nck或reject的訊息由rabbitmq投遞到死信交換機中

死信交換機將訊息投入相應的死信佇列

死信佇列的消費者消費死信訊息

延時佇列，首先，它是一種佇列，佇列意味著內部的元素是有序的，元素出隊和入隊是有方向性的，元素從一端進入，從另一端取出。

其次，延時佇列，最重要的特性就體現在它的延時屬性上，跟普通的佇列不一樣的是，普通佇列中的元素總是等著希望被早點取出處理，而延時佇列中的元素則是希望被在指定時間得到取出和處理，所以延時佇列中的元素是都是帶時間屬性的，通常來說是需要被處理的訊息或者任務。

簡單來說，延時佇列就是用來存放需要在指定時間被處理的元素的佇列。

官網基礎

可靠訊息|死信佇列|延時佇列

RabbitMQ 核心概念死信延時佇列

RabbitMq死信佇列

rabbitmq死信佇列

rabbitmq死信佇列

RabbitMQ 核心概念 死信 延時佇列

RabbitMq死信佇列

rabbitmq死信佇列

rabbitmq死信佇列

相關推薦

RabbitMQ 核心概念死信延時佇列