RabbitMQ报错:Shutdown Signal channel error; protocol method

ops/2025/2/22 23:26:56/

报错信息:

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不生效,重复答应的问题


http://www.ppmy.cn/ops/160624.html

相关文章

第四届图像、信号处理与模式识别国际学术会议(ISPP 2025)

重要信息 会议官网&#xff1a;www.icispp.com 会议时间&#xff1a;2025年3月28-30日 会议地点&#xff1a;南京 简介 由河海大学和江苏大学联合主办的第四届图像、信号处理与模式识别国际学术会议&#xff08;ISPP 2025) 将于2025年3月28日-30日在中国南京举行。会议主…

Ubuntu20.04.2安装Vmware tools

软件版本&#xff1a;Vmware Workstation Pro 17.6.2 操作系统镜像文件&#xff1a;ubuntu-20.04.2-desktop-amd64 方式1&#xff1a;用iso镜像安装 没用这种方法&#xff0c;太麻烦 方式2&#xff1a;用apt安装Open VM Tools 如果你使用的是较新的Ubuntu版本&#xff08;如…

【Python爬虫(35)】解锁Python多进程爬虫:高效数据抓取秘籍

【Python爬虫】专栏简介&#xff1a;本专栏是 Python 爬虫领域的集大成之作&#xff0c;共 100 章节。从 Python 基础语法、爬虫入门知识讲起&#xff0c;深入探讨反爬虫、多线程、分布式等进阶技术。以大量实例为支撑&#xff0c;覆盖网页、图片、音频等各类数据爬取&#xff…

基于LangGraph和Ollama实现可调用AI搜索引擎Tavily的Agentic RAG问答机器人

这篇博客将和大家分享如何快速实现一个运行逻辑相较于传统链式RAG&#xff08;用户询问 -> 检索相关信息作为上下文 -> LLM推理回复&#xff09;更为智能、适应性更强的Agentic RAG Chatbot&#xff08;实现思路参考 Langgraph Agentic RAG 实现官方文档教程&#xff09;…

com.alibaba.fastjson.JSONException: parseDecimal error, field

json.toJavaObject报这个错。 com.alibaba.fastjson.JSONException: parseDecimal error, field 一开始觉得报文的json里的key是少于java实体的&#xff0c;所以以为是key少取不到&#xff0c;所以报错&#xff0c;但是名称是一看转换报错的问题。 最后debug确实也是这样的问…

OSPF协议五种网络类型中DR和BDR选举说明

OSPF协议五种网络类型中DR和BDR选举说明 OSPF链路类型有3种&#xff1a;点到点&#xff0c;广播型&#xff0c;NBMA(非广播-多路访问网络&#xff08;Non-Broadcast Multiple Access&#xff0c;NBMA&#xff09;)。 在3种链路类型上扩展出5种网络类型&#xff1a;点到点&…

网络运维学习笔记 017HCIA-Datacom综合实验01

文章目录 综合实验1实验需求总部特性 分支8分支9 配置一、 基本配置&#xff08;IP二层VLAN链路聚合&#xff09;ACC_SWSW-S1SW-S2SW-Ser1SW-CoreSW8SW9DHCPISPGW 二、 单臂路由GW 三、 vlanifSW8SW9 四、 OSPFSW8SW9GW 五、 DHCPDHCPGW 六、 NAT缺省路由GW 七、 HTTPGW 综合实…

Huggingface简介和基础使用指南(抱脸)(NLP公司、Transformers库、Huggingface Hub)

文章目录 Huggingface 是什么&#xff1f;基础使用步骤&#xff08;命令行版&#xff09;1️⃣ 环境准备2️⃣ 账户认证3️⃣ 仓库管理4️⃣ 文件操作5️⃣ 调用模型 新手须知 Huggingface 是什么&#xff1f; Huggingface 是专注于自然语言处理&#xff08;NLP&#xff09;的…