我面临着这样一种场景:队列中的每条消息都应该在延迟一段时间后被消费,这可以使用RabbitMQ中的TTL和死信交换来实现,但当最大TTL将位于头部时,其他消息将不会被消费。
我希望实现队列中的每个消息在延迟后被消费,而不管它在队列中的位置。
发布于 2020-06-05 17:36:09
您可以使用delayed-message-exchange,而不是依赖TTL和死信交换。使用延迟消息交换,只有当消息的TTL过期时,消息才会发布到队列。消费队列中的每条消息都需要向队列中添加更多的消费者。
https://stackoverflow.com/questions/62148238
复制相似问题