如何为返回Mono的RabbitHandler配置全局执行成功后自动ack策略？

解决方案 #

你不需要修改任何业务方法代码，只需要全局配置RabbitMQ监听器的确认模式为MANUAL即可，Spring AMQP原生支持响应式返回类型（Mono/Flux）在MANUAL模式下的自动ack/nack逻辑：当返回的Mono正常完成时框架自动ack消息，出现异常时自动nack消息。

配置方式1：通过配置文件全局生效 #

直接在application.yml（或application.properties）中添加如下配置即可覆盖所有默认监听器容器的确认策略：

spring:
  rabbitmq:
    listener:
      simple:
        acknowledge-mode: manual
        # 可选配置：业务异常时是否将消息重新入队，false表示直接丢弃/进死信队列
        default-requeue-rejected: false
      direct:
        acknowledge-mode: manual
        default-requeue-rejected: false

如果用properties格式配置，对应写法如下：

spring.rabbitmq.listener.simple.acknowledge-mode=manual
spring.rabbitmq.listener.simple.default-requeue-rejected=false
spring.rabbitmq.listener.direct.acknowledge-mode=manual
spring.rabbitmq.listener.direct.default-requeue-rejected=false

配置方式2：通过JavaConfig自定义容器工厂生效 #

如果你项目中自定义了RabbitListenerContainerFactory，直接在工厂配置中添加确认模式设置即可：

import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.core.AcknowledgeMode;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMqConfig {

    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        // 全局设置手动确认模式
        factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
        // 原有其他工厂配置保持不变
        factory.setConcurrentConsumers(3);
        factory.setMaxConcurrentConsumers(10);
        return factory;
    }
}

配置完成后原有警告会自动消失，所有返回Mono的消息处理方法都会在异步逻辑执行成功后自动ack，执行失败时自动nack，完全不需要修改原有业务代码。

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