此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring Integration 6.4.0! |
TCP 连接拦截器
您可以使用对 .
您可以使用侦听器向连接添加行为,例如协商、安全性和其他选项。
框架目前没有提供拦截器,但有关示例,请参阅源存储库中的 InterceptedSharedConnectionTests
。TcpConnectionInterceptorFactoryChain
测试用例中使用的 The used 工作原理如下:HelloWorldInterceptor
拦截器首先使用 Client 端连接工厂进行配置。 当第一条消息通过被拦截的连接发送时,拦截器通过该连接发送 '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"/>