5.3. 消息端点
概述
消息端点 是应用与消息传递系统之间的接口。如 图 5.3 “消息端点模式” 所示,您可以有一个发送者端点,有时称为代理或服务消费者,它负责发送 In 消息和接收器端点,有时也称为端点或服务,后者负责接收 In 消息。
图 5.3. 消息端点模式
端点类型
Apache Camel 定义两种基本端点类型:
- 在 Apache Camel 路由开始时的消费者 端点 mvapich-wagon Appears,并从 传入频道读取信息(等同于 接收器 端点)。
- 在 Apache Camel 路由末尾,生成者 端点 criu-wagon Appears,并将消息写入传出频道(等同于 发送者 端点)。可以使用多个制作者端点定义路由。
端点 URI
在 Apache Camel 中,端点由 端点 URI 表示,它通常封装以下种类的数据:
- 消费者端点的端点 URI Advertise Advertises 一个特定位置(例如,向哪些服务公开发送者可以连接到的服务)。或者,URI 可以指定消息源,如消息队列。端点 URI 可以包含用于配置端点的设置。
- producer 端点 ProductShortName-ProductShortNames 的端点 URI,包含用于发送消息并包含用于配置端点的设置。在某些情况下,URI 指定远程接收器端点的位置;在其他情况下,目的地可以具有抽象的形式,如队列名称。
Apache Camel 中的端点 URI 有以下通用形式:
ComponentPrefix:ComponentSpecificURI
其中 ComponentPrefix 是一个 URI 前缀,用于标识特定的 Apache Camel 组件(请参阅 Apache Camel 组件参考 以了解所有支持组件的详情)。URI 组件特定URI 的剩余部分具有特定组件定义的语法。例如,要连接到 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
> 参数允许您使用连接在一起的一个或多个表达式向动态计算端点发送消息。
默认情况下,简单语言用于计算端点。以下示例将消息发送到标头定义的端点:
<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
。
要使用简单 之外的语言,您需要定义 language: 参数。请参阅 第 II 部分 “路由表达式和 predicates 语言”。
使用不同语言的格式是在 URI 中使用 language:languagename
:。例如,要使用 Xpath,使用以下格式:
<route> <from uri="direct:start"/> <toD uri="language:xpath:/order/@uri/"> </route>
以下是 Java DSL 中的相同示例:
from("direct:start") .toD("language:xpath:/order/@uri");
如果没有指定 语言:
则端点是一个组件名称。在某些情况下,组件和语言的名称相同,如 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");
很多语言可以一次连接,每个语言仅用 +
分隔,并使用语言来指定每个语言 :languagename
。
toD
可以使用以下选项:
Name | 默认值 | 描述 |
| 必需:要使用的 URI。 | |
| 设置在发送到端点时使用的特定 Exchange Pattern。原来的 MEP 已恢复。 | |
|
配置 | |
|
| 指定是否忽略无法解析的端点 URI。如果禁用,Camel 将抛出一个标识无效端点 URI 的异常。 |