Spring Integration TCP与UDP支持详解（续篇）如何实现？

本文共计11315个文字，预计阅读时间需要46分钟。

网关+网关可实现自动关联消息。然而，对于容量相对较小的应用程序，建议使用网站网关。将连接工厂配置为对所有消息使用单个共享连接（single-use=false）时，每次只能处理一条消息。

网关

网关会自动关联消息。 但是，对于容量相对较小的应用程序，应使用出站网关。 将连接工厂配置为对所有消息对使用单个共享连接（“single-use=”false“）时，一次只能处理一条消息。 新消息必须等到收到对上一条消息的答复。 当为每个新消息配置连接工厂以使用新连接（“single-use=”true“）时，此限制不适用。 虽然此设置可以提供比共享连接环境更高的吞吐量，但它会带来为每个消息对打开和关闭新连接的开销。

因此，对于高容量消息，请考虑使用一对协作通道适配器。 但是，为此，您需要提供协作逻辑。

Spring Integration 2.2 中引入的另一个解决方案是使用 ，它允许使用共享连接池。​​CachingClientConnectionFactory​​

协作出站和入站通道适配器

若要实现高容量吞吐量（避免使用网关的陷阱，如前所述），可以配置一对协作的出站和入站通道适配器。 您还可以使用协作适配器（服务器端或客户端）进行完全异步的通信（而不是使用请求-答复语义）。 在服务器端，消息关联由适配器自动处理，因为入站适配器添加一个标头，允许出站适配器确定在发送回复消息时使用哪个连接。

在服务器端，必须填充标头，因为它用于将消息与连接相关联。 源自入站适配器的消息会自动设置标头。 如果您希望构造要发送的其他消息，则需要设置标头。 您可以从传入消息中获取标头值。