Spring Integration中带拦截器的TcpConnectionOpenEvent工厂属性显示unknown问题

这个问题是Spring Integration 4.3.x版本中TCP连接拦截器与事件传递逻辑的一个已知问题，具体原因可以拆解为：

当你给TcpNetClientConnectionFactory配置TcpConnectionInterceptorFactoryChain后，创建的TCP连接会被拦截器包装成代理对象。在4.3.12版本的实现中，这个代理连接对象在触发TcpConnectionOpenEvent时，没有正确继承原始连接工厂的名称标识——原始连接的factoryName属性没有被传递给代理实例，导致事件中的factory字段默认显示为"unknown"。

而像TcpConnectionCloseEvent这类事件表现正常，是因为它们的触发时机或事件传递逻辑不同：比如关闭事件可能由底层原始连接直接触发，或者在拦截器的处理链路中，正确传递了原始连接的factoryName信息。

验证与解决方案 #

1. 版本升级（推荐）
   这个问题在Spring Integration 5.x及以后的版本中已经被修复，框架优化了拦截器链与TCP连接事件的绑定逻辑，确保代理连接也能正确携带原始连接工厂的名称。如果项目允许，升级到5.x及以上版本就能直接解决这个问题。

2. 临时修复（无法升级时）
   如果你暂时无法升级版本，可以尝试自定义TcpConnectionInterceptor，在拦截器的wrapConnection方法中，手动将原始连接的factoryName传递给代理连接；或者在监听TcpConnectionOpenEvent时，通过连接的其他属性（比如远程地址、本地端口）来关联对应的连接工厂，替代factory字段的识别作用。

举个简单的自定义拦截器示例：

public class FactoryNamePropagatingInterceptor implements TcpConnectionInterceptor {

    private TcpConnection delegate;
    private String factoryName;

    @Override
    public void wrapConnection(TcpConnection connection) {
        this.delegate = connection;
        // 手动传递原始连接的factoryName
        if (connection instanceof AbstractTcpConnection) {
            AbstractTcpConnection tcpConn = (AbstractTcpConnection) connection;
            this.factoryName = tcpConn.getFactoryName();
        }
    }

    // 重写获取factoryName的方法，确保事件能拿到正确值
    @Override
    public String getFactoryName() {
        return this.factoryName;
    }

    // 实现其他拦截器方法，直接委托给delegate
    @Override
    public void send(Message<?> message) throws Exception {
        this.delegate.send(message);
    }
    // ... 其他方法按需实现
}

将这个拦截器加入你的拦截器工厂链配置中，就能确保TcpConnectionOpenEvent获取到正确的工厂名称。

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