如何为每个新建的RabbitMQ Channel绑定关闭事件监听器？

要为每个由监听器容器创建的通道（包括通道关闭后重建的新通道）一次性注册ShutdownListener，处理PRECONDITION_FAILED错误，你可以通过SimpleRabbitListenerContainerFactory配置容器自定义器，在通道创建时添加监听器。

实现步骤 #

在你的容器工厂配置类中，添加容器自定义逻辑，利用ChannelListener在新通道创建时注册ShutdownListener：

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
    var factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    
    // 为每个容器实例配置通道创建回调
    factory.setContainerCustomizer(container -> {
        container.addChannelListener((channel, transactional) -> {
            // 为新创建的通道添加ShutdownListener，每个通道仅注册一次
            channel.addShutdownListener(shutdownCause -> {
                // 判断是否为PRECONDITION_FAILED导致的通道关闭
                if (shutdownCause.isHardError()) {
                    Object reason = shutdownCause.getReason();
                    if (reason instanceof AMQP.Channel.Close closeFrame) {
                        if (closeFrame.getReplyCode() == AMQP.PRECONDITION_FAILED) {
                            // 这里执行你的自定义处理逻辑
                            // 例如：记录告警日志、清理关联资源、触发重试机制等
                            System.err.println("通道因投递确认超时（PRECONDITION_FAILED）关闭，执行处理：" + closeFrame.getReplyText());
                        }
                    }
                }
            });
        });
    });
    
    return factory;
}

关键说明 #

1. 容器自定义器作用：setContainerCustomizer会对工厂创建的每一个SimpleMessageListenerContainer生效，确保所有@RabbitListener对应的容器都会应用此逻辑。
2. 通道创建回调时机：ChannelListener.onCreate会在容器初始创建通道，以及旧通道关闭后重建新通道时触发，保证每个新通道都能被注册监听器。
3. 精确错误判断：通过解析AMQP.Channel.Close帧的回复码（AMQP.PRECONDITION_FAILED），可以精准识别投递确认超时导致的通道关闭，避免字符串匹配的误差。
4. 避免重复注册：监听器仅在通道创建时添加一次，不会像在消息处理方法中添加那样，为每条消息重复注册。

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