rabbitmq:消費消息報錯(AmqpException: PublisherCallbackChannel is closed)
錯誤日志:
org.springframework.amqp.AmqpException: PublisherCallbackChannel is closed
原因分析:消費消息返回ack默認是需要一秒內回復的,超時未返回則重新發(fā)送,導致重復消費
解決方案:設置initial-interval為合理值
spring:
rabbitmq:
listener:
simple:
acknowledge-mode: manual
retry:
#60秒后重試
initial-interval: 60000
#啟用發(fā)布重試
enabled: true
#傳遞消息的最大嘗試次數
max-attempts: 3
#嘗試的最大時間間隔
max-interval: 60000
#應用于先前傳遞重試時間間隔的乘數
multiplier: 1.0