死信交换 RabbitMQ 丢弃消息答案

【问题标题】：Dead letter exchange RabbitMQ dropping messages死信交换 RabbitMQ 丢弃消息
【发布时间】：2012-11-17 10:02:18
【问题描述】：

我正在尝试在 RabbitMQ 中实现一个 dlx 队列。场景很简单我有 2 个队列： 1) 活着 2) dead (x-dead-letter-exchange: "immediate", x-message-ttl: 5000)

以及绑定到 1) 活着的“立即”交换

我试图运行这个例子： http://blog.james-carr.org/2012/03/30/rabbitmq-sending-a-message-to-be-consumed-later/ 但似乎消息在 ttl 过期后被丢弃并且它们不会在交换器上发布，所以我的活动队列总是空的。

我还尝试在管理控制台中手动创建队列，我得到了相同的行为。

我使用 Ubuntu/rabbitmq 3.0.0 以及 Mac OS X 和 rabbitmq 2.8.7 对其进行了测试

我错过了什么吗？

【问题讨论】：

【解决方案1】：

当消息在 RabbitMQ 中“消失”时，问题通常归结为绑定。因此，为了让您的示例正常工作，我执行了以下操作：

创建了 2 个队列，活的，死的（使用 TTL 和 DLX）
创建了一个名为 immediate 的 DIRECT 类型的交换
使用路由键“dead”在交换“立即”和“活动”队列之间创建绑定 - 原因是，消息进入死队列的路由键（如果使用默认exchange is 'dead' 这需要在死信交换的绑定中匹配）。

这里的重要部分是 immediate 交换和 alive 队列之间的绑定。

为了测试我将消息发布到死队列中，我可以看到它短暂出现在死队列中，然后出现在活动队列中。

【讨论】：

我做了一个秒杀并击中了几个showstoppers： 1. 消息只有 DLQ:en 在 Q 的顶部（rabbitmq.com/ttl.html - 警告部分）这意味着如果我首先设置 msg 1 4 小时后过期，msg2 1 小时后过期 msg2 只会在 msg1 过期后过期。 2. 消息的 TTL 由 Rabbit 保存，因此假设您使用 10 秒的短超时。如果消费者在消息过期后 10 秒内无法消费该消息（由于积压），则该消息将被丢弃并丢失以上已使用 Rabbit 3.0.1 进行了验证。你们有什么解决方法吗？
@AndreasÖhlund，如果可能，尝试使用“每个队列 TTL”而不是“每个消息 TTL”进行设计。