Rabbitmq 设置手动确认_rabbitmq手动确认

Rabbitmq 设置手动确认

1. 基于配置的方式

若代码中没有创建其他的 监听容器,可以直接在配置文件中配置
spring.rabbitmq.listener.simple.acknowledge-mode=manual
然后再容器中将所以要声明的监听队列,每个都在 用 @Configuration 注解的类中 用 @Bean 注解一一声明
,最后在 @RabbitListener 注解的方法中 用 channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false); 手动确认消息;这样这些声明的队列,就会被设置为 手动确认状态
如:

    @RabbitListener(queues = "test")
    public void receive(String info, Channel channel, Message msg) {
        try {
            logger.debug("consumer收到消息：" + msg);
            // 手动确认,只确认当条消息
            channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
        }catch (Exception e){
            logger.error(getStackTrace(e));
            e.printStackTrace();
        }

    }

1
2
3
4
5
6
7
8
9
10
11
12
13

2. 基于代码中约定的配置

也是在用 用 @Configuration 注解的类中 ,引入 RabbitProperties 修改其中的容器的确认方式,其实这个就是上面配置文件修改的属性,只不过这里 在代码中来修改了
如:

   @Autowired
    RabbitProperties rabbitProperties;


    @PostConstruct
    public void set() {
        rabbitProperties.getListener().getSimple().setAcknowledgeMode(AcknowledgeMode.MANUAL);
    }
1
2
3
4
5
6
7
8

3. @RabbitListener 注解的属性修改

注解中ackMode属性修改(注意:从 spring-rabbit-2.2-release.jar 开始),这个修改会覆盖上面的大属性的修改,不过只适用于监听的某个队列