179.14. 通过 JMS 的 request-reply
Camel 支持通过 JMS 进行请求。当您向 JMS 队列发送消息时,交换的 MEP 应该为 InOut
。
Camel 提供了多个选项,用于通过 JMS 配置请求/回复,影响性能和集群环境。下表总结了选项。
选项 | 性能 | 集群 | 描述 |
---|---|---|---|
| 速度快 | 是 |
临时队列用作回复队列,并由 Camel 自动创建。要使用它,不要指定 一个 replyTo 队列名称。您可选择配置 |
| slow | 是 |
共享持久队列用作回复队列。必须事先创建队列,但有些代理可以立即创建它们,如 Apache ActiveMQ。要使用它,您必须指定 replyTo 队列名称。另外,您还可以配置 |
| 速度快 | 否(*是) |
独占持久队列用作回复队列。必须事先创建队列,但有些代理可以立即创建它们,如 Apache ActiveMQ。要使用它,您必须指定 replyTo 队列名称。如果配置了 |
| 速度快 | 是 |
Camel 2.10. 3 :允许使用中的并发消息监听程序同时处理回复信息。您可以使用 |
| 速度快 | 是 |
Camel 2.10. 3 :允许使用中的并发消息监听程序同时处理回复信息。您可以使用 |
JmsProducer
检测到 InOut
,并提供带有要使用的回复目的地的 JMSReplyTo
标头。默认情况下,Camel 使用临时队列,但您可以使用端点上的 replyTo
选项指定固定的回复队列(请参阅以下有关固定回复队列)。
Camel 将自动设置侦听回复队列的消费者,因此 您不应该 执行任何操作。
这个消费者是一个 Spring DefaultMessageListenerContainer
,它侦听回复。但是,它被固定到 1 个并发消费者。
这意味着,将按顺序处理回复,因为只有 1 个线程来处理回复。如果您希望更快地处理回复,则需要使用并发。但不使用 concurrentConsumer
选项。我们应使用 Camel DSL 中的 线程
,如下所示:
如果使用 Camel 2.10.3 或更高版本,则使用 concurrentConsumers 选项而不是使用线程。请参阅以下。
from(xxx) .inOut().to("activemq:queue:foo") .threads(5) .to(yyy) .to(zzz);
在此路由中,我们指示 Camel 使用具有 5 个线程的线程池异步路由回复。
现在,从 Camel 2.10.3 开始,您可以使用 concurrentConsumers
和 maxConcurrentConsumers
选项将监听程序配置为使用并发线程。这可让您在 Camel 中更轻松地配置它,如下所示:
from(xxx) .inOut().to("activemq:queue:foo?concurrentConsumers=5") .to(yyy) .to(zzz);
179.14.2. 通过 JMS 的 request-reply 并使用专用固定回复队列
从 Camel 2.9 开始可用
在上例中,Camel 会预期名为"bar"的固定回复队列已共享,因此它使用 JMSSelector
只消耗期望的回复消息。但是,这样做的一个缺陷是因为 JMS selectos 较慢。此外,回复队列上的使用者使用新的 JMS 选择器 ID 更新速度较慢。实际上,它只在 receiveTimeout
选项超时时才更新,默认为 1 秒。因此,在回复信息中,会花费大约 1 秒的时间被检测。另一方面,如果固定回复队列专用于 Camel 回复消费者,我们可以避免使用 JMS 选择器,因此更高性能。实际上,使用临时队列就快。因此,在 Camel 2.9 中,我们引入了 ReplyToType
选项,您可以将它配置为 Exclusive
,以告知 Camel 回复队列是独占的,如下例所示:
from(xxx) .inOut().to("activemq:queue:foo?replyTo=bar&replyToType=Exclusive") .to(yyy)
请注意,队列必须专用于每个端点和每个端点。因此,如果您有两个路由,它们各自需要一个唯一的回复队列,如下例所示:
from(xxx) .inOut().to("activemq:queue:foo?replyTo=bar&replyToType=Exclusive") .to(yyy) from(aaa) .inOut().to("activemq:queue:order?replyTo=order.reply&replyToType=Exclusive") .to(bbb)
如果您在集群环境中运行,也是如此。然后,集群中的每个节点都必须使用唯一的回复队列名称。否则,集群中的每个节点可能会选择信息,该消息旨在作为另一节点上的回复。在集群环境中,建议使用共享回复队列。