• 本站域名更换为 qyi.io

RabbitMQ double ack 报错

学无止境 admin 1年前 (2020-02-02) 2305次浏览 0个评论
16:50:10.134 ERROR 17788 --- o.s.a.r.c.CachingConnectionFactory :
Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80)

 
在设置手动确认ACK后老是会出现这个错误,虽然不影响消息接收,但是每次报错都会重连。
除了在配置文件中设置手动ack以外,还需要在RabbitMQConfig中设置,按照参考文章上说的是

被注解注入的SimpleRabbitListenerContainerFactory覆盖,而它默认使用了自动签收。但是消费消息的时候又手动进行channel.basicAck(deliveryTag, false),于是导致了两次ack,所以报错。

因为需要手动设置ack的话,那么在消费端需要@RabbitListener注解放到方法上,同时指定containerFactory,不然会出现无限循环错误。官方解释
而刚好设置了 rabbitListenerContainerFactory ,返回类型是SimpleRabbitListenerContainerFactory,刚好被覆盖了,所以得再次手动设置一次。

  @RabbitHandler
  @RabbitListener(queues = "DirectQueue", containerFactory = "rabbitListenerContainerFactory")
  public void listen(Message message, Channel channel) {
  //...........................
}

 

#消费者最小数量
spring.rabbitmq.listener.simple.concurrency=1
#消费之最大数量
spring.rabbitmq.listener.simple.max-concurrency=10
#设置消费端手动 ack
# 被注解注入的SimpleRabbitListenerContainerFactory覆盖,而它默认使用了自动签收。但是消费消息的时候又手动进行channel.basicAck(deliveryTag, false),于是导致了两次ack,所以报错。
spring.rabbitmq.listener.simple.acknowledge-mode=manual
# 限流
#spring.rabbitmq.listener.simple.prefetch=1

 

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate template = new RabbitTemplate(connectionFactory);
        template.setMessageConverter(new Jackson2JsonMessageConverter());
        return template;
    }
    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        //此处也设置为手动ack
        factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
        factory.setConnectionFactory(connectionFactory);
        factory.setMessageConverter(new Jackson2JsonMessageConverter());
        return factory;
    }

 
参考文章:https://blog.csdn.net/more_try/article/details/82804387


版权所有丨如未注明 , 均为原创丨本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:RabbitMQ double ack 报错
喜欢 (1)
发表我的评论
取消评论
表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址
(0)个小伙伴在吐槽
  1. 真好,解决问题
    AndresFeng2021-02-04 15:25 回复