rabbitmq：消费消息报错（AmqpException: PublisherCallbackChannel is closed）

9月前作者：small+ 分类：Toy博客阅读(45) 违法举报

这篇具有很好参考价值的文章主要介绍了rabbitmq：消费消息报错（AmqpException: PublisherCallbackChannel is closed）。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

rabbitmq：消费消息报错（AmqpException: PublisherCallbackChannel is closed）

错误日志：

org.springframework.amqp.AmqpException: PublisherCallbackChannel is closed

原因分析：消费消息返回ack默认是需要一秒内回复的，超时未返回则重新发送，导致重复消费

解决方案：设置initial-interval为合理值文章来源地址https://www.toymoban.com/news/detail-544924.html

spring:
  rabbitmq:
    listener:
      simple:
        acknowledge-mode: manual
        retry:
          #60秒后重试
          initial-interval: 60000 
          #启用发布重试
          enabled: true
          #传递消息的最大尝试次数
          max-attempts: 3 
          #尝试的最大时间间隔
          max-interval: 60000 
          #应用于先前传递重试时间间隔的乘数
          multiplier: 1.0

到了这里，关于rabbitmq：消费消息报错（AmqpException: PublisherCallbackChannel is closed）的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：

领支付宝红包赞助服务器费用

【RabbitMQ】RabbitMQ 消息的可靠性 —— 生产者和消费者消息的确认，消息的持久化以及消费失败的重试机制_rabbitmq 生产者消息确认

先自我介绍一下，小编浙江大学毕业，去过华为、字节跳动等大厂，目前阿里P7 深知大多数程序员，想要提升技能，往往是自己摸索成长，但自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！因此收集整理了一份《2024年最新大数据全套学习资料》，

2024年04月26日
浏览(83)
Centos安装RabbitMQ，JavaSpring发送RabbitMQ延迟延时消息，JavaSpring消费RabbitMQ消息

erlang 和 rabbitmq 版本说明 https://www.rabbitmq.com/which-erlang.html 确认需要安装的mq版本以及对应的erlang版本。 RabbitMQ下载地址： https://packagecloud.io/rabbitmq/rabbitmq-server Erlang下载地址： https://packagecloud.io/rabbitmq/erlang RabbitMQ延迟消息插件下载 https://github.com/rabbitmq/rabbitmq-delayed-message-exc

2024年02月08日
浏览(49)
SpringBoot: RabbitMQ消息队列之同时消费多条消息

1. basicQos预取方法参数解析 basicQos(int prefetchCount) basicQos(int prefetchCount, boolean global) basicQos(int prefetchSize, int prefetchCount, boolean global) 参数： prefetchSize：可接收消息的大小 prefetchCount：处理消息最大的数量。 global：是不是针对整个Connection的，因为一个Connection可以有多个Channel，如

2024年02月01日
浏览(73)
【RabbitMQ】RabbitMQ 消息的可靠性 —— 生产者和消费者消息的确认，消息的持久化以及消费失败的重试机制

在现代分布式应用程序中，消息队列扮演了至关重要的角色，允许系统中的各个组件之间进行异步通信。这种通信模式提供了高度的灵活性和可伸缩性，但也引入了一系列的挑战，其中最重要的之一是消息的可靠性。首先让我们来了解一下，在消息队列中，消息从生产者发送

2024年02月05日
浏览(48)
消息队列-RabbitMQ：MQ作用分类、RabbitMQ核心概念及消息生产消费调试

1）什么是 MQ MQ (message queue)，从字面意思上看，本质是个队列，FIFO 先入先出，只不过队列中存放的内容是 message 而已，还是一种跨进程的通信机制，用于上下游传递消息。在互联网架构中，MQ 是一种非常常见的上下游 “ 逻辑解耦 + 物理解耦” 的消息通信服务。使用了

2024年02月20日
浏览(42)
RabbitMQ防止消息重复消费、保证异步消息的幂等性

一、rabbitmq出现消息重复的场景 1、消费成功，没有进行ack，这时 Broker 会重新发送 2、不确认(unack)或 reject 之后，重新排队，Broker 会重新发送 3、消费成功，ack时宕机，没有ack成功，消息由unack变为ready，Broker又重新发送 4、总的来说就是 Broker 发送消息后，消费端收到消息

2024年02月13日
浏览(41)
RabbitMQ(二) - RabbitMQ与消息发布确认与返回、消费确认

SpringBoot与RabbitMQ整合后，对RabbitClient的“确认”进行了封装、使用方式与RabbitMQ官网不一致；生产者给交换机发送消息后、若是不管了，则会出现消息丢失；解决方案1：交换机接受到消息、给生产者一个答复ack, 若生产者没有收到ack, 可能出现消息丢失，因此重新发送消息；

2024年02月14日
浏览(45)
springboot整合rabbitmq 实现消息发送和消费

Spring Boot提供了RabbitMQ的自动化配置，使得整合RabbitMQ变得非常容易。首先，需要在pom.xml文件中引入amqp-client和spring-boot-starter-amqp依赖：接下来需要在application.properties文件中配置RabbitMQ连接信息：然后编写消息发送者：其中，my-exchange和my-routing-key是需要自己定义的交换机和

2024年02月07日
浏览(40)
记一次rabbitmq消息发送成功，消费丢失问题

测试数据归档，偶现数据未归档 idea线上调试，log日志，数据库消息发送记录，代码分块重复执行看哪块出的问题，结果均无问题，最后使用rabbitmq trace日志，发现问题所在 1. 什么是Trace Trace 是Rabbitmq用于记录每一次发送的消息，方便使用Rabbitmq的开发者调试、排错。可通过插

2024年02月16日
浏览(47)
RabbitMq(七) -- 常见问题：幂等性问题（消息重复消费）、消息丢失

用户对于同一操作发起的一次请求或者多次请求的结果是一致的，不会因为多次点击而产生了副作用。举个最简单的例子，那就是支付，用户购买商品后支付，支付扣款成功，但是返回结果的时候网络异常，此时钱已经扣了，用户再次点击按钮，此时会进行第二次扣款，返

2024年02月05日
浏览(36)