Spring Boot RabbitMQ手动ACK的Channel获取及依赖选择问题

一、@RabbitListener手动ACK获取Channel的方法 #

无需单独定义Channel Bean，Spring AMQP会自动将Channel对象传入监听方法，前提是已开启手动ACK模式。

1. 配置手动ACK模式的容器工厂 #

@Configuration
public class RabbitConfig {

    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        // 开启手动ACK模式
        factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
        return factory;
    }

    // 队列、交换机、绑定配置示例
    @Bean
    public Queue testQueue() {
        return new Queue("test.queue", true);
    }

    @Bean
    public DirectExchange testExchange() {
        return new DirectExchange("test.exchange", true, false);
    }

    @Bean
    public Binding binding(Queue testQueue, DirectExchange testExchange) {
        return BindingBuilder.bind(testQueue).to(testExchange).with("test.routing.key");
    }
}

2. 消费者方法直接注入Channel #

@Component
public class TestConsumer {

    @RabbitListener(queues = "test.queue")
    public void handleMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) throws IOException {
        try {
            // 执行业务逻辑
            System.out.println("收到消息：" + message);

            // 手动确认消息，multiple为false表示仅确认当前消息
            channel.basicAck(deliveryTag, false);
        } catch (Exception e) {
            // 处理失败时拒绝消息，第三个参数true表示将消息重新入队
            channel.basicNack(deliveryTag, false, true);
        }
    }
}

注：方法参数中的Channel由Spring自动注入，无需手动创建；deliveryTag通过@Header注解获取，用于标识待确认的消息。

二、是否需要改用rabbitmq.client库？不用完全替换 #

Spring AMQP本身就是基于rabbitmq.client封装的，绝大多数场景下，用Spring注解式开发足够简洁高效。只有需要极底层的定制化操作（比如手动管理连接生命周期、自定义通道参数等）时，才需要直接使用rabbitmq.client。

手动创建连接/通道的示例（与Spring AMQP共存） #

如果确实需要手动操作底层API，可参考以下代码，无需替换现有Spring AMQP的代码：

import com.rabbitmq.client.*;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;

public class RabbitManualClient {

    private static final String QUEUE_NAME = "test.queue";
    private static final String HOST = "localhost";
    private static final int PORT = 5672;
    private static final String USERNAME = "guest";
    private static final String PASSWORD = "guest";

    public static void main(String[] args) throws IOException, TimeoutException {
        // 初始化连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost(HOST);
        factory.setPort(PORT);
        factory.setUsername(USERNAME);
        factory.setPassword(PASSWORD);

        // 创建连接和通道
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {

            // 声明队列
            channel.queueDeclare(QUEUE_NAME, true, false, false, null);

            // 手动ACK模式消费消息
            DeliverCallback deliverCallback = (consumerTag, delivery) -> {
                String message = new String(delivery.getBody(), StandardCharsets.UTF_8);
                try {
                    System.out.println("手动客户端收到消息：" + message);
                    // 确认当前消息
                    channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
                } catch (Exception e) {
                    // 拒绝消息并重新入队
                    channel.basicNack(delivery.getEnvelope().getDeliveryTag(), false, true);
                }
            };

            // 启动消费，autoAck设为false开启手动ACK
            channel.basicConsume(QUEUE_NAME, false, deliverCallback, consumerTag -> {});

            // 保持程序运行
            System.out.println("Press any key to exit...");
            System.in.read();
        }
    }
}

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