RabbitMq报错reply-code=406 reply-text=PRECONDITION_FAILED解决

 更新时间:2022年12月26日 11:29:05   作者:刨红薯的小羊竿尔  
这篇文章主要为大家介绍了RabbitMq报错reply-code=406 reply-text=PRECONDITION_FAILED分析解决,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

一、检查配置是否正确

今天看生产日志发现了很多的RabbitMq报错:reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80,全都是异常之后重复消费,重复报错。

unknown delivery tag 1-参考rabbitMQ的tag机制可知这条消息已经完成了消费;那么出现这个原因是配置不对了。

首先排查SimpleRabbitListenerContainerFactory是否加上手动ack

private SimpleRabbitListenerContainerFactory getSimpleRabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    //使用jackson进行消息序列与反序列
    factory.setMessageConverter(new Jackson2JsonMessageConverter());
    factory.setAcknowledgeMode(AcknowledgeMode.MANUAL); // 开启手动 ack
    return factory;
}

Jackson2JsonMessageConverter是rabbitmq 对java对象json序列化的支持,在发送消息时,会先将自定义的消息类序列化成json格式,再转成byte构造 Message,rabbitmq的ack就被设置为自动提交;需要手动开启ack,没得问题:factory.setAcknowledgeMode(AcknowledgeMode.MANUAL)。

其次检查配置文件,配置文件设置为手动ack

spring.rabbitmq.listener.direct.acknowledge-mode=manual

rabbitmq:
  host: 127.0.0.1
  port: 5672
  username: guest
  password: guest
  ###开启消息确认机制 confirms
  virtual-host: /
  publisher-confirms: true
  publisher-returns: true
  #rabbitmq配置加上手动应答
  listener:
      simple:
        acknowledge-mode: manual

二、rabbitmq消息重回队列,回到队尾

当出现异常时,我们需要把这个消息回滚到消息队列,有两种方式:

  • ack返回false,并重新回到队列channel.basicNack channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
  • 拒绝消息channel.basicReject channel.basicReject(message.getMessageProperties().getDeliveryTag(), true)

但是环境中的实际情况是,当消息回滚到消息队列时,这条消息不会回到队列尾部,而是仍是在队列头部,这时消费者会立马又接收到这条消息进行处理,接着抛出异常,进行回滚,如此反复进行。这种情况会导致消息队列处理出现阻塞,消息堆积,导致正常消息也无法消费

对于消息回滚到消息队列,我们希望方式是出现异常的消息到达消息队列尾部,这样既保证消息不会丢失,又保证了正常业务的进行

因此我们采取的解决方案是,将消息先进行应答,这时消息队列会删除该消息,同时再次发送该消息到消息队列,这时就实现了错误消息进行消息队列尾部的方案。

具体方案为:

//手动进行应答
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
//重新发送消息到队尾
channel.basicPublish(message.getMessageProperties().getReceivedExchange(),
message.getMessageProperties().getReceivedRoutingKey(), MessageProperties.PERSISTENT_TEXT_PLAIN,
JSON.toJSONBytes(new Object()));

三、消息体本身有误

如果一个消息体本身有误,会导致该消息体,一直无法进行处理,而服务器中刷出大量无用日志

解决这个问题可以采取两种方案:

1、对于日常细致处理,分清哪些是可以恢复的异常,哪些是不可以恢复的异常。对于可以恢复的异常我们采取第三条中的解决方案,对于不可以处理的异常,我们采用记录日志,直接丢弃该消息方案。

2、对每条消息进行标记,记录每条消息的处理次数,当一条消息,多次处理仍不能成功时,处理次数到达我们设置的值时,我们就丢弃该消息,但需要记录详细的日志。

消息监听内的异常处理有两种方式:

1、内部catch后直接处理,然后使用channel对消息进行确认

2、配置RepublishMessageRecoverer将处理异常的消息发送到指定队列专门处理或记录。监听的方法内抛出异常貌似没有太大用处。因为抛出异常就算是重试也非常有可能会继续出现异常,当重试次数完了之后消息就只有重启应用才能接收到了,很有可能导致消息消费不及时。当然可以配置RepublishMessageRecoverer来解决,但是万一RepublishMessageRecoverer发送失败了呢。那就可能造成消息消费不及时了。所以即使需要将处理出现异常的消息统一放到另外队列去处理,个人建议两种方式:

  • catch异常后,手动发送到指定队列,然后使用channel给rabbitmq确认消息已消费
  • 给Queue绑定死信队列,使用nack(requque为false)确认消息消费失败

以上就是RabbitMq报错reply-code=406 reply-text=PRECONDITION_FAILED解决的详细内容,更多关于RabbitMq reply报错解决的资料请关注脚本之家其它相关文章!

相关文章

  • Springboot设置文件上传大小限制的实现示例

    Springboot设置文件上传大小限制的实现示例

    Spring Boot工程嵌入的tomcat限制了请求的文件大小默认为1MB,单次请求的文件的总数不能大于10Mb,本文主要介绍了Springboot设置文件上传大小限制的实现示例,感兴趣的可以了解一下
    2023-11-11
  • Spring Cloud gateway 网关如何拦截Post请求日志

    Spring Cloud gateway 网关如何拦截Post请求日志

    这篇文章主要介绍了Spring Cloud gateway 网关如何拦截Post请求日志的操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-07-07
  • Java实现UDP互发消息

    Java实现UDP互发消息

    这篇文章主要为大家详细介绍了Java实现UDP互发消息,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-07-07
  • java输出镂空金字塔实现案例

    java输出镂空金字塔实现案例

    小编最近接到领导安排,要求根据用户输入,打印出相应层数的镂空金字塔效果,本文分步骤通过实例代码给大家介绍的非常详细,需要的朋友参考下吧
    2021-09-09
  • 浅析Java如何优雅的设计接口状态码和异常

    浅析Java如何优雅的设计接口状态码和异常

    HTTP协议里定义了一系列的状态码用来表明请求的状态,如常用的200表示请求正常,404表示请求的资源不存在,所以本文就来和大家讨论一下如何优雅的设计接口状态码和异常,感兴趣的可以了解下
    2024-03-03
  • Hadoop环境配置之hive环境配置详解

    Hadoop环境配置之hive环境配置详解

    这篇文章主要介绍了Hadoop环境配置之hive环境配置,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-12-12
  • 修改IDEA代码左侧折叠线颜色的操作

    修改IDEA代码左侧折叠线颜色的操作

    这篇文章主要介绍了修改IDEA代码左侧折叠线颜色的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2021-02-02
  • dubbo filter中有关bean注入和配置文件读取方式

    dubbo filter中有关bean注入和配置文件读取方式

    这篇文章主要介绍了dubbo filter中有关bean注入和配置文件读取方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-05-05
  • 解决Mybatis-Plus更新方法不更新NULL字段的问题

    解决Mybatis-Plus更新方法不更新NULL字段的问题

    这篇文章主要介绍了解决Mybatis-Plus更新方法不更新NULL字段的问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-12-12
  • Mybatis逆向工程实现连接MySQL数据库

    Mybatis逆向工程实现连接MySQL数据库

    本文主要介绍了Mybatis逆向工程实现连接MySQL数据库,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-06-06

最新评论