5.3. 消息端点

消息端点 是应用程序和消息传递系统之间的接口。如 图 5.3 “消息端点模式” 所示，您可以有一个发送者端点，有时被称为代理或服务消费者，它负责发送 In 消息和接收器端点，有时也称为端点或服务，它负责 接收信息。

图 5.3. 消息端点模式

Apache Camel 定义两种基本端点类型：

在 Apache Camel 中，端点由 端点 URI 表示，它通常封装以下类型的数据：

Apache Camel 中的端点 URI 具有以下通用形式：

ComponentPrefix:ComponentSpecificURI

其中 ComponentPrefix 是用于标识特定 Apache Camel 组件的 URI 前缀（请参阅 Apache Camel 组件参考 以了解所有受支持组件的详细信息）。URI 组件SpecificURI 的其余部分具有特定组件定义的语法。例如，要连接到 JMS 队列 Foo.Bar，您可以定义如下所示的端点 URI：

jms:Foo.Bar

要定义将消费者端点 file://local/router/messages/foo 连接到制作者端点 jms:Foo.Bar 的路由，您可以使用以下 Java DSL 片段：

from("file://local/router/messages/foo").to("jms:Foo.Bar");

另外，您可以在 XML 中定义相同的路由，如下所示：

<camelContext id="CamelContextID" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="file://local/router/messages/foo"/>
    <to uri="jms:Foo.Bar"/>
  </route>
</camelContext>

& lt;toD > 参数允许您使用连接在一起的一个或多个表达式向动态计算端点发送消息。

默认情况下，使用 Simple 语言计算端点。以下示例将消息发送到标头定义的端点：

<route>
  <from uri="direct:start"/>
  <toD uri="${header.foo}"/>
</route>

在 Java DSL 中，同一命令的格式是：

from("direct:start")
  .toD("${header.foo}");

URI 也可以以文字作为前缀，如下例所示：

<route>
  <from uri="direct:start"/>
  <toD uri="mock:${header.foo}"/>
</route>

在 Java DSL 中，同一命令的格式是：

from("direct:start")
  .toD("mock:${header.foo}");

在上例中，如果 header.foo 的值为 orange，则 URI 将解析为 mock:orange。

要使用 Simple 以外的语言，您需要定义 language: 参数。请参阅 第 II 部分 “路由表达式和 predicates 语言”。

使用不同语言的格式是使用 URI 中的 语言：languagename :。例如，要使用 Xpath，请使用以下格式：

<route>
  <from uri="direct:start"/>
  <toD uri="language:xpath:/order/@uri/">
</route>

以下是 Java DSL 中的相同示例：

from("direct:start")
  .toD("language:xpath:/order/@uri");

如果没有指定 language:，则端点是一个组件名称。在某些情况下，一个组件和语言具有相同的名称，如 xquery。

您可以使用 + 符号连接多个语言。在以下示例中，URI 是 Simple 和 Xpath 语言的组合。simple 是默认值，因此无需定义语言。+ 符号是 Xpath 指令后，使用 language:xpath 表示。

<route>
  <from uri="direct:start"/>
  <toD uri="jms:${header.base}+language:xpath:/order/@id"/>
</route>

在 Java DSL 中，格式如下：

from("direct:start")
  .toD("jms:${header.base}+language:xpath:/order/@id");

许多语言可以一次串联，每个语言都与 + 分开，并使用 语言名称指定各个语言。

以下选项可通过 toD 提供：