Spring Integration 配置RetryTemplate后HTTP出站异常致AMQP无限重入队的问题

• 当前无限重入队的完整触发链路：
  1. 你配置的入站RetryTemplate仅在单条消息单次拉取后的本地执行周期内生效，重试计数不会跨RabbitMQ的消息重入队周期累计——也就是说当消息被重入队后，下一次被消费者拉取时，RetryTemplate会从零开始重新计数，根本达不到累计重试N次后终止的效果。
  2. 当RetryTemplate达到设置的1次重试上限抛出最终异常时，默认的ConditionalRejectingErrorHandler会将java.net.UnknownHostException这类网络异常判定为“可临时恢复的异常”，直接返回给RabbitMQ触发消息重入队，不会对消息做ack/丢弃处理。
  3. 你的RetryTemplate配置存在无效代码段：仅对自定义的exceptionClassifierRetryPolicy做了policyMap填充，但从未将这个策略实例绑定到RetryTemplate上，后续代码硬编码的SimpleRetryPolicy(1)直接覆盖了分类重试逻辑，所有异常都会按1次重试规则执行，没有针对UnknownHostException的特殊终止标记。

• 在RetryTemplate的拦截链路加日志，验证单条消息被拉取时，是否真的执行了配置的1次本地重试，还是每次消息重入队后RetryTemplate才从零开始计数，没有跨周期的重试统计能力。
• 断点调试默认错误处理器的异常判定逻辑，确认重试耗尽抛出的异常被标记为重入队、丢弃还是死信路由。
• 校验当前容器的ack模式：默认的AUTO模式下，只要错误处理器正常返回不抛出新异常，容器会自动ack消息，不会触发重入队。

1. 修正RetryTemplate的无效配置：将定义好的异常分类重试策略显式绑定到RetryTemplate实例上，避免写了策略却不生效的问题：

   RetryTemplate retryTemplate = new RetryTemplate();
   ExceptionClassifierRetryPolicy exceptionClassifierRetryPolicy = new ExceptionClassifierRetryPolicy();
   // 原有policyMap填充逻辑保持不变
   retryTemplate.setRetryPolicy(exceptionClassifierRetryPolicy);
   retryTemplate.setBackOffPolicy(new ExponentialBackOffPolicy());
   retryTemplate.setThrowLastExceptionOnExhausted(true);
   

2. 替换默认的容器错误处理器，实现重试耗尽后的非重入队逻辑：在入站适配器的容器配置中，显式设置错误处理器，拦截RetryTemplate耗尽后抛出的异常，按业务需求执行消息丢弃或死信转存，从根源避免消息重入队：

   return Amqp
           .inboundAdapter(connectionFactory, rabbitConfig.inboundQueue())
           .configureContainer(c -> c
                   .concurrentConsumers(3)
                   .maxConcurrentConsumers(5)
                   .receiveTimeout(2000)
                   .alwaysRequeueWithTxManagerRollback(false)
                   // 自定义错误处理器，拦截重试耗尽的异常
                   .errorHandler((message, e) -> {
                       log.error("消息达到重试上限，不再重入队，消息标识：{}, 失败原因：{}", 
                               message.getMessageProperties().getMessageId(), e.getMessage());
                       // 如需保留失败消息，可在此处将消息手动发送到死信队列，替代直接丢弃逻辑
                   })
           )
           .retryTemplate(retryTemplate);
   

3. 适配Spring Integration 5.4.4版本的已知兼容问题：该版本的AMQP入站适配器存在重试耗尽后异常传递bug，默认会将重试耗尽的异常直接触发消息重入队，必须通过显式配置错误处理器的方式截断这个流程，不能依赖默认的错误处理逻辑。

核心逻辑说明：只要错误处理器正常返回，不抛出新的异常，SimpleMessageListenerContainer就会自动对当前消息执行ack确认，消息不会再回到队列触发下一轮消费，刚好满足“最多重试N次，达到上限后丢弃”的目标。

内容的提问来源于stack exchange，提问作者tosky