摘要：官方插件僅支持版本中支持。使用過程聲明消息交換機實現(xiàn)實現(xiàn)消息發(fā)送實現(xiàn)實現(xiàn)
官方插件僅支持>=3.6.x 版本中支持。
本文描述的消息延遲機制采用官方推薦的插件rabbitmq-delayed-message-exchange，如精通rabbitmq和編程，請自行查看官方文檔，描述更加詳盡：
github
Rabbitmq插件列表
安裝
需要在集群每臺機器中安裝由于rabbitmq并未內(nèi)置該插件，需要手動下載安裝。關(guān)于已安裝的插件通過rabbitmq-plugins list可查看.
3.6.x下載地址
3.7.x下載地址
加載后解壓，并將其拷貝至(使用Linux Debian/RPM部署)rabbitmq服務(wù)器目錄：/usr/lib/rabbitmq/plugins中(windows和其他系統(tǒng)<安裝目錄>
abbitmq_server-versionplugins).
啟用插件
需要在集群每臺機器中執(zhí)行
通過rabbitmq-plugins list查看已安裝列表,如下：
...
[ ] rabbitmq_delayed_message_exchange 20171215-3.6.x
...
使用命令rabbitmq-plugins enable rabbitmq_delayed_message_exchang啟用插件，輸出如下：
The following plugins have been enabled:
rabbitmq_delayed_message_exchange
通過rabbitmq-plugins list查看已安裝列表，如下：
...
[E*] rabbitmq_delayed_message_exchange 20171215-3.6.x
...
機制
安裝插件后會生成新的Exchange類型x-delayed-message，該類型消息支持延遲投遞機制,接收到消息后并未立即將消息投遞至目標(biāo)隊列中，而是存儲在mnesia(一個分布式數(shù)據(jù)系統(tǒng))表中，檢測消息延遲時間，如達(dá)到可投遞時間時并將其通過x-delayed-type類型標(biāo)記的交換機類型投遞至目標(biāo)隊列。
Java使用過程
聲明x-delayed-message消息交換機
rabbitmq java client實現(xiàn)
// ... elided code ...
Map args = new HashMap();
args.put("x-delayed-type", "direct");
channel.exchangeDeclare("my-exchange", "x-delayed-message", true, false, args);
// ... more code ...
spring rabbitmq template實現(xiàn)
// ... elided code ...
Map args = new HashMap<>();
args.put("x-delayed-type", "direct");
Exchange exchange = new CustomExchange("test.exchange", "x-delayed-message", true, false, args);
//admin = RabbitmqAdmin
admin.declareExchange(exchange);
//more code...
消息發(fā)送
rabbitmq java client實現(xiàn)
// ... elided code ...
byte[] messageBodyBytes = "delayed payload".getBytes("UTF-8");
Map headers = new HashMap();
headers.put("x-delay", 5000);
AMQP.BasicProperties.Builder props = new AMQP.BasicProperties.Builder().headers(headers);
channel.basicPublish("test.exchange", "test", props.build(), messageBodyBytes);
// ... more code ...
spring rabbitmq template實現(xiàn)
MessageProperties properties = new MessageProperties();
properties.setHeader("x-delay", 1000);
//template : RabbitmqTemplate
template.convertAndSend("test.exchange", "test", new Message(body, properties));
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://specialneedsforspecialkids.com/yun/68500.html
