Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

179.14. JMS 上的 request-reply

Camel 支持 Request Reply over JMS。本质上，当您向 JMS 队列发送消息时，Exchange 的 MEP 应该为 InOut。

Camel 提供了很多选项，来通过 JMS 配置请求/回复，这会影响性能和集群环境。下表总结了选项。

Expand
选项性能集群描述

Temporary

速度快

是

临时队列用作回复队列，由 Camel 自动创建。要使用此选项，请不要 指定 replyTo 队列名称。另外，您还可以配置 replyToType=Temporary，使它成为正在使用该临时队列。

共享

速度较慢

是

共享持久队列用作回复队列。必须先创建队列，但某些代理可以实时创建它们，如 Apache ActiveMQ。要使用此功能，您必须指定 replyTo 队列名称。另外，您还可以配置 replyToType=Shared，使其认为使用共享队列。共享队列可用于同时运行此 Camel 应用程序的多个节点。所有都使用相同的共享回复队列。这是因为 JMS 消息选择器用于关联预期的回复消息；这会影响到性能。JMS 消息选择器较慢，因此无法快速作为 Temporary 或 Exclusive 队列。请参阅以下如何调整它以提高性能。

exclusive

速度快

否(*是)

专用持久队列用作回复队列。必须先创建队列，但某些代理可以实时创建它们，如 Apache ActiveMQ。要使用此功能，您必须指定 replyTo 队列名称。此外，您必须配置 replyToType=Exclusive 来指示 Camel 使用专用队列，因为如果配置了 replyTo 队列名称，则默认使用 Shared。在使用专用回复队列时，不使用 JMS 消息选择器，因此其他应用不得使用此队列。在集群环境中不能同时使用具有同时运行此 Camel 应用程序的多个节点；因为如果回复队列回到发送请求消息的相同节点，我们就没有控制该队列；因此，共享队列使用 JMS 消息选择器来确保这一点。虽然 如果您为每个节点配置带有唯一的名称的 Exclusive reply 队列，您可以在集群环境中运行。与那时，回复消息将发回到给定节点的该队列，等待回复消息。

concurrentConsumers

速度快

是

Camel 2.10. 3：允许使用并发消息监听程序同时处理回复消息。您可以使用 concurrentConsumers 和 maxConcurrentConsumers 选项指定范围。注意： 使用共享 回复队列可能无法用于并发监听程序，因此请谨慎使用这个选项。

maxConcurrentConsumers

速度快

是

Camel 2.10. 3：允许使用并发消息监听程序同时处理回复消息。您可以使用 concurrentConsumers 和 maxConcurrentConsumers 选项指定范围。注意： 使用共享 回复队列可能无法用于并发监听程序，因此请谨慎使用这个选项。

JmsProducer 检测到 InOut，并提供 JMSReplyTo 标头，其中包含要使用的回复目的地。默认情况下，Camel 使用临时队列，但您可以使用端点上的 replyTo 选项指定固定回复队列（请参阅以下关于固定回复队列的信息）。

Camel 将自动设置侦听回复队列的消费者，因此 您不应 执行任何操作。
这个消费者是一个 Spring DefaultMessageListenerContainer，用于侦听回复。但是，它被修复为 1 个并发消费者。
这意味着，回复将按顺序处理，因为只有 1 个线程来处理回复。如果要更快地处理回复，我们需要使用并发。但不使用 concurrentConsumer 选项。我们应使用 Camel DSL 中的 线程，如以下路由所示：

如果使用 Camel 2.10.3 或更高版本，则使用 concurrentConsumers 选项，而不是使用 threads。请参见以下内容。 

from(xxx)
.inOut().to("activemq:queue:foo")
.threads(5)
.to(yyy)
.to(zzz);
Copy to Clipboard Toggle word wrap

在这个路由中，我们指示 Camel 使用有 5 个线程的线程池异步路由回复。

从 Camel 2.10.3 开始，您可以使用 concurrentConsumers 和 maxConcurrentConsumers 选项将监听程序配置为使用并发线程。这可让您在 Camel 中更轻松地进行配置，如下所示： 

from(xxx)
.inOut().to("activemq:queue:foo?concurrentConsumers=5")
.to(yyy)
.to(zzz);
Copy to Clipboard Toggle word wrap

如果您在执行 Request Reply over JMS 时使用了固定的回复队列，如以下示例所示，请留意。 

from(xxx)
.inOut().to("activemq:queue:foo?replyTo=bar")
.to(yyy)
Copy to Clipboard Toggle word wrap

在本例中，使用了名为 "bar" 的固定回复队列。默认情况下，Camel 假设队列在使用固定回复队列时共享，因此它使用 JMSSelector 仅提取预期的回复消息（例如，基于 JMSCorrelationID）。有关专用固定回复队列，请参见下一部分。这意味着它不像临时队列一样快。您可以使用 receiveTimeout 选项加快 Camel 将拉取回复消息的频率。默认情况下，其 1000 millis。因此，要更快地将其设置为 250 个 millis，以每秒拉取 4 次，如下所示： 

from(xxx)
.inOut().to("activemq:queue:foo?replyTo=bar&receiveTimeout=250")
.to(yyy)
Copy to Clipboard Toggle word wrap

请注意，这会导致 Camel 更频繁地向消息代理发送拉取请求，因此需要更多网络流量。
通常建议尽可能使用临时队列。

从 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)
Copy to Clipboard Toggle word wrap

请记住，队列必须为每个端点和每个端点排斥。因此，如果您有两个路由，则每个路由都需要一个唯一的回复队列，如下例所示： 

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)
Copy to Clipboard Toggle word wrap

如果您在集群环境中运行，则同样适用。然后，集群中的每个节点都必须使用唯一的回复队列名称。如其他情况下，集群中的每个节点可能会获取旨在作为另一节点上的回复的消息。对于集群环境，建议改为使用共享回复队列。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2025 Red Hat