本人在使用 RabbitMq 延时队列的时候有一些疑问,总感觉自己的方法是错的:
1.死亡消息队列达到死亡时间后如果没有被消费怎么做到持久化问题.
现在的做法是如果消费者死了,就让它进入一个队列,然后写日志.不然会自动消费,网上有一些方法,但是测试好像无效.
2.长延时比如三个月后,应该使用什么方式?
- 有人说直接指定过期时间,然后通过路由来订阅.参考了网上的一些文章,有人说这样在插入新消息的时候会造成队列重新排序,非常消耗性能.
- 我在使用的时候参考了 RocketMq 的做法,使用了 2 分法创建多个延时级别,比如 30 天首先会进入 1 天的那个延时级别,然后轮询调用检查.这样的缺点就是会创建很多中间消息队列.
如果有哪位大佬有这方面的经验麻烦指点一下.