您的位置:首页 > 财经 > 产业 > 网站建站工具有哪些_360海南地方网站_怎样加入网络营销公司_网络营销论文3000字

网站建站工具有哪些_360海南地方网站_怎样加入网络营销公司_网络营销论文3000字

2025/2/24 3:12:12 来源:https://blog.csdn.net/java15655057970/article/details/145767308  浏览:    关键词:网站建站工具有哪些_360海南地方网站_怎样加入网络营销公司_网络营销论文3000字
网站建站工具有哪些_360海南地方网站_怎样加入网络营销公司_网络营销论文3000字

报错信息:

Shutdown Signal: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80)

原因

默认情况下 RabbitMQ 是自动ACK(确认签收)机制,就意味着 MQ 会在消息发送完毕后,自动帮我们去ACK(确认),若是在代码中再手动确认签收,就会造成确认错误。

“PRECONDITION_FAILED - unknown delivery tag” 表明交付标签(delivery tag)不合法或已经被确认过

因此我们需要在订阅者(消费者)的方法上标识,消息手动确认签收ackMode = “MANUAL”,代码如下:

    @RabbitListener(queues = RabbitMqContants.DIRECT_QUEUE1_NAME,ackMode = "MANUAL")public void directConsumerA(String msg, Channel channel, Message message) throws IOException {try {// 处理消息log.info("=================DIRECT-队列1-消费者A 接收到消息:msg = {}", msg);//消息消费手动确认channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);} catch (Exception e) {e.printStackTrace();// 处理异常,可能需要重新将消息放回队列channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);}}

关于rabbitMQ在yml配置手动ack不生效,重复消费的问题

spring:rabbitmq:host: xxxport: 5672username: guestpassword: guestlistener:direct:acknowledge-mode: manual # 手动ACK开启:自动确认 none ;手动确认 manual ;根据异常情况确认 auto (较麻烦,不推荐)
此处已经设置了手动答应,消费者代码是这样的:
@RabbitListener(queues = RabbitMqContants.DIRECT_QUEUE1_NAME)public void directConsumerA(String msg, Channel channel, Message message) throws IOException {try {// 处理消息log.info("=================DIRECT-队列1-消费者A 接收到消息:msg = {}", msg);//消息消费手动确认channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);} catch (Exception e) {e.printStackTrace();// 处理异常,可能需要重新将消息放回队列channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);}}
然而消费者会重复消费消息,控制台还是会打印如下异常:
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)

查找资料和测试发现,rabbitmq默认是用的SimpleRabbitListenerContainerFactory
配置文件中如果不指定监听容器类型的话,配置是不会生效的,
只要配置文件配置改成以下配置,这个问题就可以解决了。

spring:rabbitmq:host: xxxport: 5672username: guestpassword: guestlistener:# 设置监听容器(Listener container)类型,如不设置,将会默认为SimpleRabbitListenerContainerFactory,且下面的direct配置不生效type: directdirect:acknowledge-mode: manual # 手动ACK开启:自动确认 none ;手动确认 manual ;根据异常情况确认 auto (较麻烦,不推荐)
重点是type这个配置,如果不设置type的话,要将direct改成simple才会生效

总结

详情请参考:
RabbitMQ报错:Shutdown Signal: channel error; protocol method
关于rabbitMQ在yml配置手动ack不生效,重复答应的问题

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com