调用Azure Service Bus的Abandon()后消息入死信队列的原因排查

为什么调用Abandon()后消息进入死信队列？ #

你的问题主要来自两个核心原因：

1. 自动完成机制引发的冲突与死信触发

你注册消息处理器时使用了默认的autoComplete=true配置——这意味着在onMessageAsync方法返回的Future完成后，框架会**额外自动调用completeAsync**来收尾消息处理。但当你手动调用abandonAsync后，消息的锁已经被释放，此时框架再尝试完成消息，就会找不到对应的Delivery链接，抛出Delivery not found on the receive link异常。

框架捕获到这个异常后，会判定消息处理失败，进而触发死信逻辑，直接将消息移入死信队列，而非让它重回正常队列。

2. 消息传递次数的累积触发阈值

Azure Service Bus中，每条消息的Delivery Count会在每次被PeekLock模式接收时自动+1。如果你的队列Max Delivery Count设置得较低（比如被修改为1），那么即使只Abandon一次，消息再次被接收时传递次数就会达到阈值，直接进入死信队列。

如何让指定消息通过Abandon()重回队列？ #

只需两步调整即可解决问题：

1. 关闭自动完成，手动控制消息状态

注册消息处理器时，显式关闭自动完成功能，避免框架操作和你的手动处理冲突：

// 配置消息处理器选项，关闭自动完成
MessageHandlerOptions handlerOptions = new MessageHandlerOptions()
    .setAutoComplete(false)
    .setMaxConcurrentCalls(1); // 可选：单线程处理方便调试

// 注册处理器时传入配置
receiveClient.registerMessageHandler(ih, handlerOptions, executorService);

2. 修正消息处理逻辑，明确所有分支的状态操作

确保每条消息都被手动处理状态，避免遗漏：

IMessageHandler ih = new IMessageHandler() {
    public CompletableFuture<Void> onMessageAsync(IMessage message) {
        byte[] body = message.getBody();
        Map map = GSON.fromJson(new String(body, UTF_8), Map.class);
        try {
            if (map.get("lastname").equals("test25")) {
                // 手动调用Abandon，让消息重回队列
                return receiveClient.abandonAsync(message.getLockToken());
            } else {
                // 正常处理完成，手动调用Complete
                return receiveClient.completeAsync(message.getLockToken());
            }
        } catch (Exception e) {
            e.printStackTrace();
            // 异常情况下，选择Abandon让消息重试，或DeadLetter永久移除
            return receiveClient.abandonAsync(message.getLockToken());
        }
    }

    public void notifyException(Throwable throwable, ExceptionPhase exceptionPhase) {
        System.out.printf("%s - %s%n", exceptionPhase, throwable.getMessage());
    }
};

3. 可选：调整队列的Max Delivery Count

如果你希望消息可以多次重试，登录Azure门户找到你的Service Bus队列，在属性页面调整Max Delivery Count的值（默认是10），设置为符合你需求的重试次数上限。

额外提示 #

• Abandon()会将消息放回队列尾部，同时Delivery Count+1，当次数达到阈值后仍会进入死信。
• 如果需要消息重回队列但不增加传递次数，可以使用Defer()操作，但延迟的消息需要通过receiveDeferredMessageAsync主动接收，不会自动回到正常消息流中。

内容的提问来源于stack exchange，提问作者Sreekanth Dabbeeru