Spring AMQP setConfirmCallback批量消息回调异常问题求助

这个问题看起来有点矛盾——正确消息明明已经到达队列，但confirm回调却返回了ack=false，而且只在同时发送错误消息时才出现，单独发送正常。结合你的代码和RabbitMQ的confirm机制，我判断核心问题大概率是publisher confirm功能没有正确开启，或者配置方式与你的Spring AMQP版本不匹配，导致回调的ack状态出现异常。

下面是具体的排查和解决步骤：

1. 确保正确开启Publisher Confirm功能 #

RabbitTemplate的confirmCallback只有在开启了publisher confirm功能后才能正常工作，不同Spring Boot版本的配置方式有区别：

如果你使用Spring Boot 2.1及以上版本 #

在application.properties或application.yml中添加：

spring.rabbitmq.publisher-confirm-type=correlated

这个配置会启用关联式confirm，确保每个消息的confirm回调能正确对应到对应的CorrelationData。

如果你使用Spring Boot 2.0及以下版本 #

使用旧的配置项：

spring.rabbitmq.publisher-confirms=true

如果是用Java代码配置CachingConnectionFactory，需要手动设置：

@Bean
public CachingConnectionFactory connectionFactory() {
    CachingConnectionFactory factory = new CachingConnectionFactory();
    factory.setHost("你的RabbitMQ地址");
    factory.setUsername("用户名");
    factory.setPassword("密码");
    // 2.1+版本用这个
    factory.setPublisherConfirmType(CachingConnectionFactory.ConfirmType.CORRELATED);
    // 2.0及以下用这个
    // factory.setPublisherConfirms(true);
    return factory;
}

2. 明确Confirm回调的职责边界 #

你的回调逻辑本身没有问题，但需要牢记：RabbitMQ的confirm机制只负责确认消息是否到达交换机，和消息是否能路由到队列无关——路由失败的情况由ReturnCallback处理。正常情况下：

• 第一条消息（正确交换机+路由键）的confirm回调应该返回ack=true
• 第二、三条消息（错误交换机）的confirm回调返回ack=false（因为交换机不存在，消息无法到达交换机）

开启正确的publisher confirm后，同时发送三条消息时，应该能看到第一条的成功日志，后两条的失败日志，和实际消息的投递情况一致。

3. 完善重试模板的配置 #

你的重试模板只设置了退避策略，但没有指定重试次数，默认情况下SimpleRetryPolicy的最大重试次数是3次。这意味着错误消息会被重试3次，每次都会触发confirm回调（都是ack=false），可能会让你误以为所有消息都失败了。建议明确设置重试次数：

SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
// 设置最大重试次数为2次
retryPolicy.setMaxAttempts(2);
retryTemplate.setRetryPolicy(retryPolicy);

4. 用CorrelationData区分每条消息的日志 #

你已经为每个消息生成了唯一的CorrelationData，可以通过打印correlationData.getId()更清晰地对应每条消息的回调日志，避免混淆：

rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
    String msgId = correlationData != null ? correlationData.getId() : "unknown";
    if (!ack) {
        log.info("消息[{}]未送达交换机: ack={}, cause={}", msgId, ack, cause);
    } else {
        log.info("消息[{}]已成功送达交换机: ack={}", msgId, ack);
    }
});

为什么单独发送正确消息时看起来正常？ #

这可能是因为没有开启publisher confirm时，RabbitTemplate的回调逻辑出现了“伪成功”的情况——当消息发送没有抛出异常时，回调可能错误地返回ack=true，但这并不是RabbitMQ真正的confirm响应。而当同时发送错误消息时，异常触发了某种状态变化，导致所有回调都返回ack=false。

按照上面的步骤配置后，应该就能解决这个矛盾的问题，让confirm回调的日志和实际消息投递情况一致。

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