RabbitMQ basic.get 和确认

Question

我正在调用：

GetResponse response = channel.basicGet("some.queue", false); // no auto-ack
....
channel.basicAck(deliveryTag, ...);

但是，当我调用 basicGet 时，队列中的消息保持“就绪”状态，而不是“未确认”状态。我希望它们处于未确认状态，以便我可以 basic.ack 它们（从而从队列中丢弃它们），或者 basic.nack 它们

Answer 1

我正在执行以下操作来模仿延迟确认：

在消费时从

1. 初始队列获取（消费）消息。
2. 创建一个“PendingAck_123456”队列。
   123456 是消息的唯一 ID。
   设置以下属性
   • x-message-ttl（在之后重新排队
     超时）
   • x-expires（以确保临时队列将被删除）
   • x-dead-letter-exchange 和 x-deal-letter-routing-key 来重新排队
     TTL 到期时的初始队列。
3. 将消息 Pending ack 发布到此“PendingAck_123456”队列 确认
4. 消息以将其从初始队列中删除

在确认时

1. 根据消息 Id 计算队列名称并从“PendingAck_123456”队列获取
2. 确认它（无需调用 .getBody () ).
   这会将其从待处理队列中删除，从而防止 TTL 将其重新排队

。备注

• 一个队列仅容纳 1 条消息。如果有很多这样的队列，这会是一个问题吗？
• 重新排队的消息将在队列输入端发送。而不是在队列输出端发送（就像真正的确认一样）。这对消息顺序有影响。
• 消息由应用程序复制到待处理队列。这是可能会影响整体性能的附加步骤。
• 要模拟 Nack/Reject，您可能需要将消息复制到初始队列，然后从 PendingAck 队列中确认它。默认情况下，TTL 会执行此操作（稍后）。

Answer 2

在 get 之后立即执行 ack 时，效果很好。然而，就我而言，他们是因一个请求而分开的。 spring 的模板会在每次执行时关闭通道和连接。因此，存在三种选择：

• 在应用程序的整个生命周期中保持一个通道和连接打开；
• 具有某种对话范围（或最坏情况：使用会话）来存储相同的通道并重用它。
• 每个请求使用一个通道，立即确认收到，并将消息存储在内存中。

在前两种情况下，你不能使用 spring 的 RabbitTemplate 来做到这一点

Answer 3

GetResponse resp = channel.basicGet(queueName, false);
Envelope envelope = resp.getEnvelope();
long deliveryTag = envelope.getDeliveryTag();
channel.basicAck(deveryTag,false)