事情要追溯到两年多前，当时在一个项目组工作，有一个业务场景是A服务器处理完平账，同时向外推送已平账的消息。但是but然而，消费者接收到消息，去A服务查询信息，有可能查不到平账的记录。十分垃圾。于是需要消费者接收到消息之后，过5分钟再进行逻辑处理。
基于这个业务场景，打算使用延时队列。
基本思路是，利用死信队列的超时转发功能。监听到A服务发送的消息，扔到死信队列B并设置超时5分钟转发到C队列，由C队列消费者来进行业务处理。代码如下
正常监听服务A的队列并发送到死信队列
发送到死信交换机，设置路由规则（可能有多个私信队列使用同一个死信交换机）
声明延时队列
绑定延时队列到死信交换机，并设置路由规则
声明死信队列和超时规则
绑定死信队列到死信交换机
设置死信队列超时规则，仍然发到死信交换机并根据routingKey转发到延时队列
声明死信交换机
监听延时队列并进行业务处理
mq的其他配置
事情要追溯到两年多前，当时在一个项目组工作，有一个业务场景是A服务器处理完平账，同时向外推送已平账的消息。但是bu...
如果你不熟悉RabbitMQ，本文从图形界面入手介绍 RabbitMQ 的基本使用方法和 延时队列和死信队列的实现...
前一章我们讲了《SpringBoot RabbitMQ消息队列的重试、超时、延时、死信队列[https://my....
延时消息 延时消息的两种实现办法 过期消息+死信队列（问题 支持顺序 但是消息的粒度不够） 使用延时消息插件 消息...
在上一篇文章中，我们学习了死信队列的相关内容，文章最后我们提到，超时消息结合死信队列也可以实现一个延时队列。大致的...
接之前分享过的文章【RabbitMQ的死信队列和延时队列】[https://www.jianshu.com/p/2...
死信队列(DLX) Dead-Letter-Exchange 利用DLX, 当消息在一个队列中变成死信(dead ...
基于队列和基于消息的TTL TTL是time to live 的简称，顾名思义指的是消息的存活时间。rabbitM...
在RabbitMQ中,队列支持下面几个属性.x-message-ttl: 10000 表示队列中的消息只能存活10...
死信队列介绍 死信队列：DLX（dead-letter-exchange） 利用DLX，当消息在一个队列中变成死信...
本文标题：使用死信队列完成延时队列
本文链接：https://www.haomeiwen.com/subject/bupzbktx.html
网友评论