35.11. 通过与 request/reply 连接的多个并发消息
当通过 netty producer 使用 Netty 进行请求/回复消息时,默认情况下,每个消息都通过非共享连接(池)发送每个消息。这样可确保回复自动映射到正确的请求线程,以便在 Camel 中进行进一步路由。换而言之,请求/回复信息之间的词语关联将不会出现,因为回复会返回用于发送请求的相同连接;而且此连接不会与他人共享。当响应返回时,连接会返回连接池,从中可以被其他人重复使用。
但是,如果您要在单个共享连接上有多个并发请求/响应,需要通过设置 producerPoolEnabled=false
来关闭连接池。现在,这意味着如果回复返回异常,则存在交集响应的问题。因此,您需要在请求和回复消息中有一个关联 id,以便您可以正确地将回复与负责在 Camel 中处理消息的 Camel 回调相关联。要这样做,您需要将 NettyCamelStateCorrelationManager
作为关联管理器实施,并通过 correlationManager=#myManager
选项进行配置。
我们建议在构建自定义关联管理器时扩展 TimeoutCorrelationManagerSupport
。这为需要实施的超时和其他复杂性提供支持。
您可以在 camel-example-netty-custom-correlation
目录下找到带有 Apache Camel 源代码的示例。