|
对于最新的稳定版本，请使用 Spring Integration 6.5.1！ |
TCP 消息关联
网关
网关会自动关联消息。 但是，对于相对较低容量的应用程序，应使用出站网关。 将连接工厂配置为对所有消息对使用单个共享连接 （'single-use=“false”'） 时，一次只能处理一条消息。 新消息必须等到收到对上一条消息的回复。 当为每条新消息配置连接工厂以使用新连接 （'single-use=“true”'） 时，此限制不适用。 虽然此设置可以提供比共享连接环境更高的吞吐量，但它会带来为每个消息对打开和关闭新连接的开销。
因此，对于大容量消息，请考虑使用一对协作通道适配器。 但是，为此，您需要提供协作逻辑。
Spring Integration 2.2 中引入的另一个解决方案是使用CachingClientConnectionFactory，这允许使用共享连接池。
协作出站和入站通道适配器
若要实现高容量吞吐量（避免使用网关的陷阱，如前所述），可以配置一对协作的出站和入站通道适配器。 您还可以使用协作适配器（服务器端或客户端）进行完全异步通信（而不是使用请求-回复语义）。 在服务器端，消息关联由适配器自动处理，因为入站适配器添加了一个标头，允许出站适配器确定在发送回复消息时要使用的连接。
在服务器端，您必须填充ip_connectionId标头，因为它用于将消息与连接相关联。
源自入站适配器的邮件会自动设置标头。
如果要构造其他消息以发送，则需要设置标头。
可以从传入邮件中获取标头值。 |
在客户端，应用程序必须根据需要提供自己的关联逻辑。 您可以通过多种方式做到这一点。
如果消息有效负载具有一些自然关联数据（例如事务 ID 或订单号），并且您不需要保留原始出站消息中的任何信息（例如回复通道标头），则关联很简单，并且在任何情况下都会在应用程序级别完成。
如果消息有效负载具有一些自然关联数据（例如事务标识或订单号），但您需要保留原始出站消息中的某些信息（例如应答通道头），则可以保留原始出站消息的副本（可能使用发布-订阅通道）并使用聚合器重新组合必要的数据。
对于前两种方案中的任何一种，如果有效负载没有自然关联数据，则可以在出站通道适配器的上游提供转换器，以使用此类数据增强有效负载。 这样的转换器可以将原始有效负载转换为包含原始有效负载和消息标头的某些子集的新对象。 当然，标头中的实时对象（例如回复通道）不能包含在转换后的有效负载中。
如果选择此类策略，则需要确保连接工厂具有适当的序列化程序-解序列化程序对来处理此类有效负载（例如DefaultSerializer和DefaultDeserializer，它使用 Java 序列化，或自定义序列化器和反序列化程序）。
这ByteArray*SerializerTCP 连接工厂中提到的选项，包括默认的ByteArrayCrLfSerializer，则不支持此类有效负载，除非转换后的有效负载是String或byte[].
|
在 2.2 版本之前，当协作通道适配器使用客户端连接工厂时， 此默认行为不适用于真正的异步环境，因此它现在默认为无限超时。
您可以通过将 |
从 V5.4 开始，多个出站通道适配器和一个TcpInboundChannelAdapter可以共享同一个连接工厂。
这允许应用程序同时支持请求/回复和任意服务器→客户端消息传递。
有关详细信息，请参阅 TCP 网关。
传输标头
TCP 是一种流协议。Serializers和Deserializers在流中划分消息。
在 3.0 之前，只有消息有效负载 （String或byte[]）可以通过 TCP 传输。
从 3.0 开始，您可以传输选定的标头以及有效负载。
但是，“活动”对象，例如replyChannelheader，无法序列化。
通过 TCP 发送标头信息需要一些额外的配置。
第一步是提供ConnectionFactory使用MessageConvertingTcpMessageMapper使用mapper属性。
此映射器委托给任何MessageConverter实现将消息转换为某个对象或从某个对象转换消息，这些对象可以由配置的serializer和deserializer.
Spring Integration 提供了一个MapMessageConverter，它允许指定添加到Map对象以及有效负载。
生成的地图有两个条目：payload和headers.
这headersentry 本身是一个Map并包含选定的标头。
第二步是提供一个序列化程序和一个反序列化程序，可以在Map和一些电线格式。
这可以是自定义Serializer或Deserializer，如果对等系统不是 Spring Integration 应用程序，您通常需要它。
Spring Integration 提供了一个MapJsonSerializer将Map与 JSON 之间。
它使用 Spring IntegrationJsonObjectMapper.
可以提供自定义JsonObjectMapper如果需要的话。
默认情况下，序列化程序插入换行符 （0x0a） 字符。
有关更多信息，请参阅 Javadoc。
这JsonObjectMapper使用任何版本的Jackson在类路径上。 |
您还可以使用Map，通过使用DefaultSerializer和DefaultDeserializer.
以下示例显示了传输correlationId,sequenceNumber和sequenceSize标头：
<int-ip:tcp-connection-factory id="client"
type="client"
host="localhost"
port="12345"
mapper="mapper"
serializer="jsonSerializer"
deserializer="jsonSerializer"/>
<bean id="mapper"
class="o.sf.integration.ip.tcp.connection.MessageConvertingTcpMessageMapper">
<constructor-arg name="messageConverter">
<bean class="o.sf.integration.support.converter.MapMessageConverter">
<property name="headerNames">
<list>
<value>correlationId</value>
<value>sequenceNumber</value>
<value>sequenceSize</value>
</list>
</property>
</bean>
</constructor-arg>
</bean>
<bean id="jsonSerializer" class="o.sf.integration.ip.tcp.serializer.MapJsonSerializer" />使用上述配置发送的消息，有效负载为“something”，将显示在网络上，如下所示：
{"headers":{"correlationId":"things","sequenceSize":5,"sequenceNumber":1},"payload":"something"}