rabbitmq延迟消息

Posted aaaazzzz

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了rabbitmq延迟消息相关的知识,希望对你有一定的参考价值。

 


一、RabbitMQ的两个概念

使用RabbitMQ来实现延迟消息必须先了解RabbitMQ的两个概念:消息的TTL和死信Exchange,通过这两者的组合来实现上述需求。 

1、消息的TTLTime To Live

消息的TTL就是消息的存活时间。RabbitMQ可以对队列和消息分别设置TTL。对队列设置就是队列没有消费者连着的保留时间,也可以对每一个单独的消息做单独的设置。超过了这个时间,我们认为这个消息就死了,称之为死信。
我们创建一个队列queue.temp,在Arguments 中添加x-message-ttl 5000 (单位是毫秒),那每一个进入这个队列的消息在5秒后会消失。

2.死信交换器 Dead Letter Exchanges

一个消息在满足如下条件下,会进死信交换机,记住这里是交换机而不是队列,一个交换机可以对应很多队列。
1) 一个消息被Consumer拒收了,并且reject方法的参数里requeuefalse。也就是说不会被再次放在队列里,被其他消费者使用。
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.ordercreateArguments添加

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.ordercreateArguments添加

x-message-ttl=10000
x-dead-letter-exchange: exchange.ordertimeout

技术图片

5)测试:向queue.ordercreate队列添加消息,等待10秒后消息从queue.ordercreate队列消失,

技术图片

 

以上是关于rabbitmq延迟消息的主要内容,如果未能解决你的问题,请参考以下文章

RabbitMQ 延迟任务(限时订单) 原理 以及代码 实战

RabbitMQ:第二章:Spring整合RabbitMQ(简单模式,广播模式,路由模式,通配符模式,消息可靠性投递,防止消息丢失,TTL,死信队列,延迟队列,消息积压,消息幂等性)(代码

rabbitmq死信队列及延迟队列

rabbitmq延迟消息

rabbitmq延迟消息

RabbitMQ 实现消息队列延迟