java spring rabbit - 优雅地拒绝消息

Question

我有以下监听器方法:

@Override
public void onMessage(Message message, Channel channel) {
  try {
    // do something bad :)
  } catch (Exception e){
    try {
      long dt = null != message.getMessageProperties() 
          ? message.getMessageProperties().getDeliveryTag() 
          : 0;
      channel.basicReject(dt, true);
    } catch(IOException io) {
      logger.error("IO-COMMON", io);
    }
  }
}

问题是基本拒绝不起作用，我不知道为什么。如何优雅地拒绝？我认为如果我拒绝一条消息，它应该重新排队并驻留在缓存中，然后再转到下一个工作人员。但实际上这个消息似乎丢失了。

Answer 1

如果您正在执行自己的确认，则需要将确认模式设置为 MANUAL。我不确定为什么它不适合你； DEBUG/TRACE 日志记录可能会有所帮助。

你应该考虑让容器处理 acks - 使用 acknowledgemode=AUTO;如果监听器正常返回，容器通常会为抛出的任何异常重新排队消息或确认它。

您可以将 defaultRequeueRejected 设置为 false(默认情况下为 true)，消息将被丢弃(或路由到 DLX/DLQ)。

您还可以抛出一个 AmqpRejectAndDontRequeueException 来覆盖重新排队失败消息的默认机制。

如果 ack 模式为 NONE - 没有 ack，RabbitMQ 会在消息发送后立即自动 ack。