您好,登錄后才能下訂單哦!
死信隊列介紹
本文是《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上。
本章節總結:
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。