Spring AMQP结合@RefreshScope刷新连接工厂时日志ERROR问题优化

当配置了@RefreshScope的ConnectionFactory被刷新时，旧的连接实例会被销毁关闭。由于Listener容器开启了事务通道并关联了PlatformTransactionManager，容器在处理事务上下文时，会将连接关闭的ShutdownSignalException判定为严重错误并输出ERROR级日志，但这实际上是刷新流程中的正常资源回收行为，不会影响业务功能。

方案1：自定义错误处理器过滤刷新导致的关闭信号 #

通过自定义ErrorHandler，识别刷新触发的连接关闭信号，将其日志级别降级为INFO或直接忽略，同时保留真正的错误日志。

首先实现自定义错误处理器：

@Component
public class RefreshAwareRabbitErrorHandler extends ConditionalRejectingErrorHandler {

    private static final Logger log = LoggerFactory.getLogger(RefreshAwareRabbitErrorHandler.class);

    public RefreshAwareRabbitErrorHandler() {
        super(new FatalExceptionStrategy() {
            @Override
            public boolean isFatal(Throwable t) {
                // 仅当不是刷新导致的连接关闭时，才判定为致命错误
                if (t instanceof ShutdownSignalException sse) {
                    return !(sse.getReason() instanceof AMQP.Connection.Close
                            && ((AMQP.Connection.Close) sse.getReason()).getCode() == AMQP.CONNECTION_FORCED);
                }
                return super.isFatal(t);
            }
        });
    }

    @Override
    public void handleError(Throwable t) {
        if (t instanceof ShutdownSignalException sse) {
            log.info("RabbitMQ connection closed due to config refresh: {}", sse.getMessage());
            return;
        }
        super.handleError(t);
    }
}

然后在Listener容器工厂中注入该处理器：

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(
        ConnectionFactory connectionFactory,
        PlatformTransactionManager transactionManager,
        RefreshAwareRabbitErrorHandler errorHandler) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setTransactionManager(transactionManager);
    factory.setErrorHandler(errorHandler); // 绑定自定义错误处理器
    // 其他容器配置（如并发数、消息转换器等）
    return factory;
}

优点：精准过滤刷新导致的日志，不影响其他错误的正常输出；缺点：需要编写少量代码。

方案2：刷新前主动重启Listener容器 #

通过监听RefreshScopeRefreshedEvent，在ConnectionFactory刷新前先停止所有Listener容器，释放旧连接，刷新完成后再重启容器使用新连接，从根源避免旧连接关闭触发错误日志。

实现生命周期监听类：

@Component
public class RabbitContainerRefreshHandler implements SmartLifecycle {

    private final RabbitListenerEndpointRegistry containerRegistry;
    private boolean running = false;

    public RabbitContainerRefreshHandler(RabbitListenerEndpointRegistry containerRegistry) {
        this.containerRegistry = containerRegistry;
    }

    @Override
    public void start() {
        running = true;
    }

    @Override
    public void stop() {
        running = false;
    }

    @Override
    public boolean isRunning() {
        return running;
    }

    @EventListener(RefreshScopeRefreshedEvent.class)
    public void handleConfigRefresh() {
        // 遍历所有Listener容器，先停止再重启
        containerRegistry.getListenerContainers().forEach(container -> {
            if (container.isRunning()) {
                container.stop();
                container.start();
            }
        });
    }
}

优点：从根源避免错误日志生成；缺点：容器重启会短暂中断消息消费，适合对消费连续性要求不高的场景。

方案3：日志级别定向调整 #

直接通过日志配置，将特定场景下的ShutdownSignalException日志级别从ERROR降为INFO，这种方式最简单但不够精准，可能会过滤掉真正的异常。

在application.yml中配置：

logging:
  level:
    org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer:
      com.rabbitmq.client.ShutdownSignalException: INFO

如果使用Logback，可以在logback-spring.xml中添加更精准的过滤规则：

<logger name="org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer" additivity="false">
    <filter class="ch.qos.logback.classic.filter.LevelFilter">
        <level>ERROR</level>
        <onMatch>NEUTRAL</onMatch>
        <onMismatch>ACCEPT</onMismatch>
    </filter>
    <filter class="ch.qos.logback.core.filter.EvaluatorFilter">
        <evaluator>
            <expression>throwable instanceof com.rabbitmq.client.ShutdownSignalException && 
                        throwable.getCause() instanceof AMQP.Connection.Close && 
                        ((AMQP.Connection.Close) throwable.getCause()).getCode() == 320</expression>
        </evaluator>
        <onMatch>DENY</onMatch>
        <onMismatch>ACCEPT</onMismatch>
    </filter>
    <appender-ref ref="CONSOLE"/>
    <appender-ref ref="FILE"/>
</logger>

优点：零代码改动；缺点：可能误过滤真正的连接异常，需谨慎使用。

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