RabbitMQ實(shí)現(xiàn)延遲隊(duì)列一：在隊(duì)列上設(shè)置TTL

Publish --> delaysync.exchange --> delay.5m.queue(延遲隊(duì)列) --> delay.exchange --> test.queue(正常隊(duì)列) --> Consumer

//延遲隊(duì)列start Map<String,Object> map = new HashMap<String,Object>(); map.put("x-message-ttl", 10000);//消息過期時(shí)間 map.put("x-max-length", 500000);//最大積壓的消息個(gè)數(shù) map.put("x-dead-letter-exchange", "delay.exchange");//消息過期后會(huì)投遞到delay.exchange channel.queueDeclare("delay.5m.queue", true, false, false, map);

RabbitMQ實(shí)現(xiàn)延遲隊(duì)列二：在消息上設(shè)置TTL

Publish --> default exchange --> delay_queue(延遲隊(duì)列) --> amq.direct --> message_ttl_queue(正常隊(duì)列) --> Consumer

隊(duì)列：

//延遲隊(duì)列 Map<String,Object> arguments = new HashMap<String,Object>(); arguments.put("x-dead-letter-exchange", "amq.direct");//消息過期后會(huì)投遞到amq.direct arguments.put("x-dead-letter-routing-key", "message_ttl_routingKey");//出現(xiàn)dead letter之后將重新按照指定的routing-key發(fā)送 channel.queueDeclare("delay_queue", true, false, false, arguments);

消息發(fā)送：

//設(shè)置延遲屬性 AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder(); //deliveryMode：將消息標(biāo)記為持久（值為2）或瞬態(tài)（任何其他值） AMQP.BasicProperties properties = builder.expiration("10000").deliveryMode(2).build(); channel.basicPublish("", "delay_queue", properties, msg.getBytes());

?

轉(zhuǎn)載于:https://www.cnblogs.com/yifanSJ/p/9007409.html

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ —— 延迟队列的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。