TCP 适配器

提供了使用前面提到的连接工厂的 TCP 入站和出站通道适配器。 这些适配器具有两个相关属性:connection-factorychannel. 这connection-factory属性指示要使用哪个连接工厂来管理适配器的连接。 这channel属性指定消息到达出站适配器的通道,以及入站适配器放置消息的通道。 虽然入站和出站适配器可以共享一个连接工厂,但服务器连接工厂始终由入站适配器“拥有”。 客户端连接工厂始终由出站适配器“拥有”。 每种类型只有一个适配器可以获得对连接工厂的引用。 以下示例说明如何定义客户端和服务器 TCP 连接工厂:spring-doc.cadn.net.cn

<bean id="javaSerializer"
      class="org.springframework.core.serializer.DefaultSerializer"/>
<bean id="javaDeserializer"
      class="org.springframework.core.serializer.DefaultDeserializer"/>

<int-ip:tcp-connection-factory id="server"
    type="server"
    port="1234"
    deserializer="javaDeserializer"
    serializer="javaSerializer"
    using-nio="true"
    single-use="true"/>

<int-ip:tcp-connection-factory id="client"
    type="client"
    host="localhost"
    port="#{server.port}"
    single-use="true"
    so-timeout="10000"
    deserializer="javaDeserializer"
    serializer="javaSerializer"/>

<int:channel id="input" />

<int:channel id="replies">
    <int:queue/>
</int:channel>

<int-ip:tcp-outbound-channel-adapter id="outboundClient"
    channel="input"
    connection-factory="client"/>

<int-ip:tcp-inbound-channel-adapter id="inboundClient"
    channel="replies"
    connection-factory="client"/>

<int-ip:tcp-inbound-channel-adapter id="inboundServer"
    channel="loop"
    connection-factory="server"/>

<int-ip:tcp-outbound-channel-adapter id="outboundServer"
    channel="loop"
    connection-factory="server"/>

<int:channel id="loop"/>

在前面的配置中,到达inputchannel 通过client连接工厂,在服务器上接收,并放置在loop渠道。 因为loopoutboundServer,消息将通过同一连接环回,由inboundClient,并存入replies渠道。 Java 序列化用于网络。spring-doc.cadn.net.cn

通常,入站适配器使用type="server"connection factory,用于侦听传入的连接请求。 在某些情况下,您可能希望反向建立连接,以便入站适配器连接到外部服务器,然后等待该连接上的入站消息。spring-doc.cadn.net.cn

此拓扑支持,方法是将client-mode="true"在入站适配器上。 在这种情况下,连接工厂的类型必须为client并且必须具有single-use设置为false.spring-doc.cadn.net.cn

两个附加属性支持此机制。 这retry-interval指定框架在连接失败后尝试重新连接的频率(以毫秒为单位)。 这scheduler供应一个TaskScheduler以计划连接尝试并测试连接是否仍处于活动状态。spring-doc.cadn.net.cn

如果您不提供调度程序,则使用框架的默认taskScheduler Bean。spring-doc.cadn.net.cn

对于出站适配器,通常在发送第一条消息时建立连接。 这client-mode="true"在出站适配器上,则在启动适配器时建立连接。 默认情况下,适配器会自动启动。 同样,connection factory 的类型必须为client并且具有single-use="false". 一个retry-intervalscheduler也受支持。 如果连接失败,则调度程序或在发送下一条消息时重新建立连接。spring-doc.cadn.net.cn

对于入站和出站,如果适配器已启动,您可以通过发送<control-bus />命令:@adapter_id.retryConnection(). 然后,您可以使用@adapter_id.isClientModeConnected().spring-doc.cadn.net.cn