Apache Camel 路由简介

介绍

Apache Camel 的主要功能之一是路由。路由发生在日常生活的许多地方。例如，当我们向某人发送一封信时，它可能会经过各个城市或州，然后才能到达最终目的地。与此类似的是发送电子邮件的情况。电子邮件在到达其接收者之前会经过各种网络。

在 Apache Camel 的案例中，在 EMS（企业消息系统）中完成的路由是根据定义的条件将消息从输入队列带到不同输出队列的过程。他们不知道输入和输出队列之间设置的条件。消息消费者和生产者与条件逻辑分开。

在 Apache Camel 中，路由更像是一个一般概念，因为它定义为消息从源到目标的逐步移动。消息的使用者可以从外部服务获取消息，在系统上轮询消息，甚至自己编写消息。消息通过一个可以是 EIP 的处理节点，然后是一个处理消息的处理器，然后是一个拦截器（路由消息的条件），最后消息被传递到端点。

理解和消费消息，然后从端点发送

1、消费消息

使 Camel 如此用户友好的一件事是端点 URI。我们可能会识别您希望使用的组件以及如何使用端点 URI 进行设置。然后，我们可以选择是向该 URI 指定的组件发送消息还是使用来自该组件的消息。让我们看看我们如何使用下面的示例使用 URI 表示法轻松配置 Camel。

Camel 首先在组件注册表中搜索 ftp 方案，该方案解析为 FtpComponent。然后 FtpComponent 充当工厂，从上下文路径和选项生成 FtpEndpoint。 FtpComponent 在默认的 FTP 端口上登录到位于 rider.com 的 FTP 服务器，并通过 Rider.com/orders 的上下文路径将目录更改为订单。最后，提供的唯一选项是登录 FTP 服务器的用户名和密码。

由于 FtpComponent 不是 Apache Camel 核心模块的一部分，因此我们需要使用 maven 依赖项显式添加它

<dependency> 
<groupId>org.apache.camel</groupId> 
<artifactId>camel-ftp</artifactId> 
<version>2.20.1</version> 
</dependency>

2、向 JMS 端点发送消息

Java 消息服务 (JMS) 是一种 Java API，允许您创建、发送、接收和读取消息。它还要求异步消息传递和可靠性的特定特征，例如保证和一次性交付。在 JMS 中，消息消费者和生产者通过中间 JMS 目的地相互通信。现在，消费者和生产者通信的这个目的地可以是队列或主题。队列是严格单向的，这意味着消息只有一个消费者。另一方面，主题在发布/订阅技术上运行。这意味着消息可能有也可能没有多个消费者。

由于 JMS 组件不是 Apache Camel 核心模块的一部分，因此我们需要使用 maven 依赖项显式添加它

<dependency> 
<groupId>org.apache.camel</groupId> 
<artifactId>camel-jms</artifactId> 
<version>2.20.1</version> 
</dependency>

JMS 还包括一个 ConnectionFactory，客户端（例如 Camel）可以使用它来连接到 JMS 提供者。因为它们管理消息生产者和消费者之间的通信，所以 JMS 提供者通常被称为代理。

使用 JMS 的优势

JMS 是一种异步协议。客户端不需要查询是否订阅了消息。
JMS 是可靠的，因为它保证“消息传递”。

在 Camel 中定义路线的优点

它更快、更灵活。
可视化、管理、维护、调试和测试（通过模拟等）变得更加容易。
有更容易理解的例子
支持内联处理器

文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/94739.html

Apache Camel 路由简介

相关推荐