死信队列和延迟队列的使用?

死信消息:

1.消息被拒绝(Basic.Reject或Basic.Nack)而且设置 requeue 参数的值为 false
2.消息过时了
3.队列达到最大的长度spa

过时消息:3d

在 rabbitmq 中存在2种方可设置消息的过时时间blog

第一种经过队列设置:在队列申明的时候使用 x-message-ttl 参数,单位为毫秒,这种设置后,该队列中全部的消息都存在相同的过时时间rabbitmq

第二种经过对单个消息设置,是设置消息属性的 expiration 参数的值,单位为毫秒。那么每条消息的过时时间都不同。队列

若是同时使用这2种方法,那么以过时时间小的那个数值为准。当消息达到过时时间尚未被消费,那么那个消息就成为了一个 死信 消息。it

 

延时队列:在rabbitmq中不存在延时队列,可是咱们能够经过设置消息的过时时间和死信队列来模拟出延时队列。消费者监听死信交换器绑定的队列,而不要监听消息发送的队列。io


有了以上的基础知识,咱们完成如下需求:class

需求:用户在系统中建立一个订单,若是超过期间用户没有进行支付,那么自动取消订单。基础

分析:queue

一、上面这个状况,咱们就适合使用延时队列来实现,那么延时队列如何建立
二、延时队列能够由 过时消息+死信队列 来时间
三、过时消息经过队列中设置 x-message-ttl 参数实现
四、死信队列经过在队列申明时,给队列设置 x-dead-letter-exchange 参数,而后另外申明一个队列绑定x-dead-letter-exchange对应的交换器。

相关文章
相关标签/搜索