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 可以使用以下选项:

名称

默认值

描述

uri

 

必需:要使用的 URI。

pattern

 

设置在发送到端点时使用的特定 Exchange Pattern。原来的 MEP 已恢复。

cacheSize

 

配置 ProducerCache 的缓存大小,它将缓存生成者以供重复使用。默认缓存大小为 1000,如果没有指定其他值,则会使用它。将值设为 -1 可完全关闭缓存。

ignoreInvalidEndpoint

false

指定是否忽略无法解析的端点 URI。如果禁用,Camel 将抛出一个标识无效端点 URI 的异常。

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.