TCP 连接拦截器

您可以使用对TcpConnectionInterceptorFactoryChain的引用来配置连接工厂。您可以使用拦截器为连接添加行为，例如协商、安全和其他选项。框架目前没有提供任何拦截器，但请参阅源代码库中的InterceptedSharedConnectionTests以获取示例。

测试用例中使用的HelloWorldInterceptor的工作原理如下

拦截器首先使用客户端连接工厂进行配置。当第一个消息通过被拦截的连接发送时，拦截器通过连接发送“Hello”并期望接收“world!”。当这种情况发生时，协商完成，原始消息被发送。此外，使用相同连接的消息将被发送，无需任何额外的协商。

当使用服务器连接工厂配置时，拦截器要求第一个消息为“Hello”，如果是，则返回“world!”。否则，它将抛出异常，导致连接关闭。

所有TcpConnection方法都被拦截。拦截器实例由拦截器工厂为每个连接创建。如果拦截器是有状态的，则工厂应该为每个连接创建一个新实例。如果没有状态，则相同的拦截器可以包装每个连接。拦截器工厂被添加到拦截器工厂链的配置中，您可以通过设置interceptor-factory属性将其提供给连接工厂。拦截器必须扩展TcpConnectionInterceptorSupport。工厂必须实现TcpConnectionInterceptorFactory接口。TcpConnectionInterceptorSupport具有直通方法。通过扩展此类，您只需要实现您希望拦截的方法。

以下示例显示了如何配置连接拦截器工厂链

<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"/>