rabbitmq延遲訊息

使用rabbitmq來實現延遲訊息必須先了解rabbitmq的兩個概念：訊息的ttl和死信exchange，通過這兩者的組合來實現上述需求。

訊息的ttl就是訊息的存活時間。rabbitmq可以對佇列和訊息分別設定ttl。對佇列設定就是佇列沒有消費者連著的保留時間，也可以對每乙個單獨的訊息做單獨的設定。超過了這個時間，我們認為這個訊息就死了，稱之為死信。

我們建立乙個佇列queue.temp，在arguments 中新增x-message-ttl 為5000 （單位是毫秒），那每乙個進入這個佇列的訊息在5秒後會消失。

乙個訊息在滿足如下條件下，會進死信交換機，記住這裡是交換機而不是佇列，乙個交換機可以對應很多佇列。

（1）乙個訊息被consumer拒收了，並且reject方法的引數裡requeue是false。也就是說不會被再次放在佇列裡，被其他消費者使用。

（2）上面的訊息的ttl到了，訊息過期了。

（3）佇列的長度限制滿了。排在前面的訊息會被丟棄或者扔到死信交換機上。

dead letter exchange其實就是一種普通的exchange，和建立其他exchange沒有兩樣。只是在某乙個設定dead letter exchange的佇列中有訊息過期了，會自動觸發訊息的**，傳送到dead letterexchange中去。

我們現在可以測試一下延遲佇列。

（1）建立死信交換器 exchange.ordertimeout （fanout）

（2）建立佇列queue.ordertimeout

（3）建立死信交換器 exchange.ordertimeout 與佇列queue.ordertimeout 之間的繫結

（4）建立佇列queue.ordercreate，arguments新增

x-message-ttl=10000

x-dead-letter-exchange： exchange.ordertimeout

（5）測試：向queue.ordercreate佇列新增訊息，等待10秒後訊息從queue.ordercreate佇列消失，

步驟：（1）建立死信交換器 exchange.ordertimeout （fanout）

（2）建立佇列queue.ordertimeout

（3）建立死信交換器 exchange.ordertimeout 與佇列queue.ordertimeout 之間的繫結

（4）建立佇列queue.ordercreate，arguments新增

（5）測試：向queue.ordercreate佇列新增訊息，等待10秒後訊息從queue.ordercreate佇列消失，

（5）專案中

org.springframework.amqp

spring-rabbit

serviceimpl:

@autowired
private
rabbittemplate rabbittemplate;
//傳送延遲訊息
rabbittemplate.convertandsend("","queue.ordercreate",orderid);