如何配置RabbitMQ (在Spring Boot2.x中)以便手动确认有效

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

spring.rabbitmq.host=your_rabbitmq_host
spring.rabbitmq.port=your_rabbitmq_port
spring.rabbitmq.username=your_rabbitmq_username
spring.rabbitmq.password=your_rabbitmq_password

@Component
public class RabbitMQListener {

    @RabbitListener(queues = "your_queue_name")
    public void handleMessage(Message message) {
        // 处理消息的逻辑
    }
}

@Component
public class RabbitMQListener {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @RabbitListener(queues = "your_queue_name")
    public void handleMessage(Message message, Channel channel) throws IOException {
        try {
            // 处理消息的逻辑

            // 手动确认消息
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
        } catch (Exception e) {
            // 处理消息异常，可选择拒绝消息或重新入队
            channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
        }
    }
}