rabbitmq的延迟队列,延迟时间问题?

自定义延迟时间,不生效,消息消费失败。消息一直在exchange堆积。

原因有很多,下面说几种常见的

一.RabbitMQ自身并不支持延时消费

使用RabbitMQ需要通过集成延时插件方式或死信方式才能实现,可以参考我的另外两个文章:

1.死信方式:https://blog.csdn.net/weixin_43945983/article/details/109293486
2.插件方式:https://blog.csdn.net/weixin_43945983/article/details/109316430

注:个人更倾向于插件方式,因为可以实现最基本的先进先出

二.插件版本不一致

如果已经安装了延迟插件,需要检查RabbitMQ的版本与插件版本是否一致,否则延时不会生效

三.发送消息的接口不正确

如果以上两个步骤都确认没问题,需要检查发送消息是使用的是哪个模板API

1.AmqpTemplate:AmqpTemplate接口定义了发送和接收消息的所有基本操作

2.RabbitTemplate:实现自AmqpTemplate

注:查看源码会发现rabbitTemplate其实是实现自amqpTemplate接口,所以貌似使用起来并不会有什么区别,但是实际项目中我发现,如果使用RabbitTemplate发送消息,延时会无效;而切换成AmqpTemplate延时消费就生效了。

四.删除已生成的QUEUE(消息队列)和EXCHANGE(交换器)
五.延迟时间超过了rabbitMQ的临界值

rabbitMQ的延迟时间不能超过4294967296毫秒这个临界值,也就是大约49.7天!一旦超过,
消息会被即时消费。也就导致了延时失效的现象。
解决方案:创建一个缓冲队列,如果延迟时间大于临界值,就把这个消息扔到缓冲队列里,延迟时间小于等于临界值。

如果以上几步执行完毕后,延时还不生效,登录RabbitMQ的管理平台,找到对应的QUEUE(消息队列)和EXCHANGE(交换器),并删除,延时发送即刻生效


参考链接:


如有问题及时沟通

参考 :
https://blog.csdn.net/weixin_43945983/article/details/112938645

RabbitMQ过期时间和延迟队列
https://www.csdn.net/tags/MtTaAg2sNDc5MTkwLWJsb2cO0O0O.html