Spring Integration添加拦截器工厂链后无法监听TcpConnectionOpenEvent和TcpConnectionCloseEvent的问题

遇到这种情况确实挺闹心的——没加拦截器时事件监听好好的，一加拦截器工厂链就失效了。我之前也碰到过类似的问题，大概率是拦截器链的配置覆盖了默认的事件发布逻辑，或者自定义拦截器阻断了事件传递流程，下面给你梳理几个排查和解决的方向：

1. 确保拦截器链包含默认的事件发布拦截器 #

Spring Integration的TCP连接工厂默认会通过TcpConnectionEventPublisherInterceptor来发布连接相关的事件，但如果你配置了interceptor-factory-chain却没把这个默认拦截器加进去，就会导致事件发不出来。

你需要在拦截器链里显式添加这个拦截器，再加上你的自定义拦截器，示例XML配置如下：

<int-ip:tcp-connection-factory id="crLfServer"
                               using-nio="false"
                               deserializer="serverDeserializer"
                               serializer="serverSerializer"
                               single-use="false"
                               lookup-host="false"
                               type="server">
    <int-ip:interceptor-factory-chain>
        <!-- 先加默认的事件发布拦截器，保证事件能正常发布 -->
        <bean class="org.springframework.integration.ip.tcp.connection.TcpConnectionEventPublisherInterceptor"/>
        <!-- 再添加你的自定义拦截器 -->
        <bean class="com.yourpackage.YourCustomInterceptor"/>
    </int-ip:interceptor-factory-chain>
</int-ip:tcp-connection-factory>

2. 检查自定义拦截器的实现逻辑 #

如果你的自定义拦截器重写了open()或close()方法，一定要记得调用父类的对应方法！不然会阻断默认的事件发布流程。比如：

public class YourCustomInterceptor extends TcpConnectionInterceptorSupport {
    private static final Logger log = LoggerFactory.getLogger(YourCustomInterceptor.class);

    @Override
    public void open(TcpConnection connection) {
        // 你的自定义业务逻辑
        log.info("自定义逻辑：连接打开，ID：{}", connection.getConnectionId());
        // 必须调用父类方法，触发默认的事件发布
        super.open(connection);
    }

    @Override
    public void close(TcpConnection connection) {
        // 你的自定义业务逻辑
        log.info("自定义逻辑：连接关闭，ID：{}", connection.getConnectionId());
        // 必须调用父类方法，触发默认的事件发布
        super.close(connection);
    }
}

要是忘了调用super.open()或super.close()，默认的事件发布逻辑就不会执行，监听器自然收不到事件。

3. 确认事件监听器的配置是否正确 #

再检查下你的监听器是不是正确注册到Spring容器里了：

• 如果用注解方式，确保监听器类加了@Component，并且@EventListener注解正确绑定了事件类型：

@Component
public class TcpConnectionMetricsListener {
    private static final Logger log = LoggerFactory.getLogger(TcpConnectionMetricsListener.class);

    @EventListener
    public void onConnectionOpen(TcpConnectionOpenEvent event) {
        log.info("收到连接打开事件，连接ID：{}", event.getConnectionId());
        // 这里添加你的指标收集逻辑
    }

    @EventListener
    public void onConnectionClose(TcpConnectionCloseEvent event) {
        log.info("收到连接关闭事件，连接ID：{}", event.getConnectionId());
        // 这里添加你的指标收集逻辑
    }
}

• 如果用XML配置，确保<int:event-listener>或<bean>配置正确，监听器类被Spring管理。

4. 开启日志调试定位问题 #

如果还是不行，可以开启Spring Integration和事件相关的DEBUG日志，看看事件发布的流程有没有异常：
在application.properties里添加：

logging.level.org.springframework.integration.ip=DEBUG
logging.level.org.springframework.context.event=DEBUG

通过日志可以看到事件是否被发布、监听器是否收到事件，或者拦截器执行过程中有没有抛出异常。

备注：内容来源于stack exchange，提问作者P.W.