概念
延迟队列存储的对象是对应的延迟消息,所谓"延迟消息"是指当消息被发送以后,并不想让消费者立刻拿到消息,而是等待特定时间后,消费者才能拿到这个消息进行消费。
实现
rabbitmq中延迟队列是用DLX和TTL搭配实现的。如下图队列分别设置了过期时间为5秒、10 秒、30 秒、1分钟。
同时也分别配置了 DLX 和相应的死信队列。当相应的消息过期时,就会转存到相应的死信队列(即延迟队列)中。
image.png
延迟队列存储的对象是对应的延迟消息,所谓"延迟消息"是指当消息被发送以后,并不想让消费者立刻拿到消息,而是等待特定时间后,消费者才能拿到这个消息进行消费。
rabbitmq中延迟队列是用DLX和TTL搭配实现的。如下图队列分别设置了过期时间为5秒、10 秒、30 秒、1分钟。
同时也分别配置了 DLX 和相应的死信队列。当相应的消息过期时,就会转存到相应的死信队列(即延迟队列)中。
本文标题:延迟队列
本文链接:https://www.haomeiwen.com/subject/ncnliktx.html
网友评论