rabbitmq:消费消息报错(AmqpException: PublisherCallbackChannel is closed)
错误日志
org.springframework.amqp.AmqpException: PublisherCallbackChannel is closed
原因分析:消费消息返回ack默认是需要一秒内回复的,超时未返回则重新发送,导致重复消费
解决方案:设置initial-interval为合理值
spring:
rabbitmq:
listener:
simple:
acknowledge-mode: manual
retry:
#60秒后重试
initial-interval: 60000
#启用发布重试
enabled: true
#传递消息的最大尝试次数
max-attempts: 3
#尝试的最大时间间隔
max-interval: 60000
#应用于先前传递重试时间间隔的乘数
multiplier: 1.0
注意:本文归作者所有,未经作者允许,不得转载