欢迎您访问365答案网,请分享给你的朋友!
生活常识 学习资料

RabbitMQ延时队列解决分布式事务问题

时间:2023-05-02
一、RabbitMQ延时队列 1、场景

​ 比如未付款订单,超过一定时间后,系统自动取消订单并释放占有物品。

​ 常用解决方案:

​ spring的 schedule定时任务轮询数据库

​ 缺点:

​ 消耗系统内存、增加了数据库的压力、存在较大的时间误差

**解决:rabbitmq的消息TTL和死信Exchange结合**

2、消息的TTL

​ 1、消息的TTL就是消息的存活时间。

​ 2、RabbitMQ可以对队列和消息分别设置TTL

​ • 对队列设置就是队列没有消费者连着的保留时间,也可以对每一个单独的消息做单独的设置。超过了这个时间,我们认为这个消息就死了,称之为死信

​ • 如果队列设置了,消息也设置了,那么会取小的。所以一个消息如果被路由到不同的队 列中,这个消息死亡的时间有可能不一样(不同的队列设置)。这里单讲单个消息的 TTL,因为它才是实现延迟任务的关键。可以通过设置消息的expiration字段或者x- message-ttl属性来设置时间,两者是一样的效果。

3、死信路由

​ 1、一个消息在满足如下条件,会进入死信路由,记住这里是路由而不是队列。一个路由可以对应很多队列。

​ • 一个消息被Consumer拒收了,并且reject方法的参数里requeue是false。也就是说不会被再次放在队列里,被其他消费者使用。(basic.reject/ basic.nack)requeue=false

​ • 上面的消息的TTL到了,消息过期了。

​ • 队列的长度限制满了。排在前面的消息会被丢弃或者扔到死信路由上。

​ 2、 Dead Letter Exchange其实就是一种普通的exchange,和创建其他 exchange没有两样。只是在某一个设置Dead Letter Exchange的队列中有消息过期了,会自动触发消息的转发,发送到Dead Letter Exchange中去。

​ 3、 我们既可以控制消息在一段时间后变成死信,又可以控制变成死信的消息 被路由到某一个指定的交换机,结合二者,其实就可以实现一个延时队列

4、延时队列实现

1)方式一

2)方式二

一般使用第一种方式,对队列设置消息过期时间实现延时队列

3)实际使用场景

升级版本

以上是延时队列的流程图

1、第一步是生产者将消息发送到order-event-exchange交换机,交换机通过路由键order.create.order找到order.delay.queue这个队列

2、order.delay.queue队列设置TTL过期时间,当超过过期时间后,队列里面的消息将会通过路由键order.release.order找到order-event-exchange交换机,通过order.release.order路由键找到order.release.order.queue队列,将消息推送到该队列里面

3、到达order.release.order.queue队列里面的数据都是在order.delay.queue队列中过期的消息(死信),对应的业务场景是将订单的信息存到order.delay.queue队列中,超过30分钟后的数据就是订单失效的数据

Copyright © 2016-2020 www.365daan.com All Rights Reserved. 365答案网 版权所有 备案号:

部分内容来自互联网,版权归原作者所有,如有冒犯请联系我们,我们将在三个工作时内妥善处理。