对于最新的稳定版本，请使用 Spring Integration 6.4.0！spring-doc.cn

TCP 连接拦截器

您可以使用对 . 您可以使用侦听器向连接添加行为，例如协商、安全性和其他选项。框架目前没有提供拦截器，但有关示例，请参阅源存储库中的 InterceptedSharedConnectionTests。TcpConnectionInterceptorFactoryChainspring-doc.cn

测试用例中使用的 The used 工作原理如下：HelloWorldInterceptorspring-doc.cn

拦截器首先使用 Client 端连接工厂进行配置。当第一条消息通过被拦截的连接发送时，拦截器通过该连接发送 'Hello' 并期望接收 'world！'。发生这种情况时，协商完成并发送原始消息。此外，使用同一连接的消息无需任何其他协商即可发送。spring-doc.cn

当配置了服务器连接工厂时，拦截器要求第一条消息是 'Hello'，如果是，则返回 'world！'。否则，它将引发导致连接关闭的异常。spring-doc.cn

所有方法都被拦截。拦截器实例由拦截器工厂为每个连接创建。如果拦截器是有状态的，则工厂应为每个连接创建一个新实例。如果没有状态，则同一个拦截器可以包装每个连接。拦截器工厂被添加到拦截器工厂链的配置中，你可以通过设置属性将其提供给连接工厂。拦截器必须扩展 . 工厂必须实现接口。具有直通方法。通过扩展这个类，你只需要实现你想要拦截的那些方法。TcpConnectioninterceptor-factoryTcpConnectionInterceptorSupportTcpConnectionInterceptorFactoryTcpConnectionInterceptorSupportspring-doc.cn

下面的示例展示了如何配置连接拦截器工厂链：spring-doc.cn

<bean id="helloWorldInterceptorFactory"
    class="o.s.i.ip.tcp.connection.TcpConnectionInterceptorFactoryChain">
    <property name="interceptors">
        <array>
            <bean class="o.s.i.ip.tcp.connection.HelloWorldInterceptorFactory"/>
        </array>
    </property>
</bean>

<int-ip:tcp-connection-factory id="server"
    type="server"
    port="12345"
    using-nio="true"
    single-use="true"
    interceptor-factory-chain="helloWorldInterceptorFactory"/>

<int-ip:tcp-connection-factory id="client"
    type="client"
    host="localhost"
    port="12345"
    single-use="true"
    so-timeout="100000"
    using-nio="true"
    interceptor-factory-chain="helloWorldInterceptorFactory"/>