RabbitMQ消息中間件技術精講17 高級篇十 死信隊列

死信隊列介紹

本文是《RabbitMQ精講系列》中第十七：RabbitMQ消息中間件技術精講17 高級篇十 死信隊列

死信隊列：DLX(dead-letter-exchange)

當一個消息沒有了消費者之後，這個隊列就成了死信隊列。

在RabbitMQ中，死信隊列是相對於exchange的。RabbitMQ的死信隊列：

利用DLX，當消息在一個隊列中變為死信(dead message)之後，它能被重新publish到另一個exchange，這個exchange就是DLX死信隊列了。

在RabbitMQ中，消息如何變成死信的？有以下幾種情況：

1：消息被拒絕

消息被拒絕又分為：basic.reject和basic.nack兩種

當是這兩種情況下且設置了requeeu=false。也就是設置重回隊列為false的情況

2：消息TTL過期

在上一篇文章中，我們講的TTL消息的時效性。當消息超過了設置的超時時間情況

3：隊列達到最大長度

同樣，在上一篇中，我們講到了在發送消息的時候，設置消息的最大上的。當發送消息的數據長度超過了設置的值之後，這種情況也成了死信隊列。

在來看看rabbitmq死信隊列：

DLX也是一個正常的exchange,和一般的exchange沒有區別，它能在任何的隊列上被指定，實際上也就是設置某個隊列的屬性而已；

當這個隊列中有死信時候，rabbitmq就會自動的將這個消息重新發布到設置的exchange上去，進而被路由到另一個隊列。

可以監聽這個隊列中消息做相應的處理，這個特性可以彌補rabbitmq3.0以前支持immediate參數的功能。

死信隊列設置：

1 ：設置死信隊列的exchange和queue,然後進行綁定(這是廢話，任何一個隊列都是這樣的)：

Exchange：dlx.exchange

Queue：dlx.queue

Routingkey：#

2 ：然後我們進行正常的聲明交換機、隊列、綁定，只不過我們需要在隊列加上一個參數即可。這個參數就是：arguments.put(「x-dead-letter-exchange」,」dlx.exchange」).

說明：arguments.put(「x-dad-letter-exchange」,」這裡是自己定義的接收死信隊列的exchange」)

這樣消息在過期、requeue、隊列在達到最大長度時，消息就可以直接路由到死信隊列了！

代碼這裡就不截圖了，已發布在git上。

本章節總結：

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！