Apache Camel –从头开始开发应用程序（第1部分/第2部分）

开始之前

前一段时间，我写了一篇关于Spring Integration的教程，以演示如何在受现实发票处理系统启发的示例应用程序中使用Spring Integration。 我对此非常满意，因此我决定向您展示如何使用Apache Camel（Spring Integration的最大竞争对手）构建完全相同的应用程序。

我们将要构建的应用程序几乎相同，因此本教程中的很多文字也将如此。 新部分将主要集中在Apache Camel及其用法上。

您可以逐步按照本教程操作，并从头开始创建应用程序，也可以继续从github获取代码：在这里下载源： https : //github.com/vrto/apache-camel-invoices

请注意，还有更多方法来编写骆驼“路线” – Java DSL，Spring XML，Scala DSL…在本教程中，我将使用Java DSL ，但对于那些感兴趣的人–您也可以在此处找到通过Spring XML配置的相同项目。 。 无论您喜欢哪种方式，都该开始了！

发票处理申请书-功能说明

想象一下，您在某家公司工作，该公司会定期从各种承包商那里收到大量发票。 我们将建立一个能够接收发票，过滤掉相关发票，创建付款（本地或国外）并将其发送到某些银行服务的系统。 即使该系统非常幼稚，当然也不适合企业使用，我们仍将尝试在头脑中以良好的可伸缩性，灵活性和分离的设计来构建它。

Apache Camel是一个集成框架–这意味着它为要集成的复杂系统提供了有意义的抽象。
本教程有很多重要的概念需要理解。 让我为您总结一下：

  • 骆驼上下文 ：将所有部分保持在一起的运行时系统。
  • 消息 ：基本实体–消息传递的核心原理。 它由标题 ， 正文和附件组成 。
  • Exchange ：消息的容器（摘要实际通过系统发送的内容）。 它包含In消息，还可以包含Out消息。
  • 路线 ：处理器链。 如果您更喜欢“学术”的解释，则路由是一个图形，其中“节点”由某个处理器表示，“线”由某个通道表示。
  • 处理器 ：使用/修改传入的交换。 一个处理器的输出连接到另一处理器的输入。
  • 端点 ：建模通道末端。 使用URI进行配置。 例： 
    file:data/inbox?delay=5000
  • 组件 ：端点工厂。 用前缀引用（jms：，file：等）。

如果您想了解有关骆驼核心概念的更多详细信息，我强烈建议您阅读非常好的《 骆驼在行动》一书。

现在，我们对基本概念有了一些了解，让我们看一下下面的图片，它是系统的摘要，并遍历了重要的部分：

整合发票

在图片上，您可以看到一条路线，它说明了我们的消息传递结构和系统的核心组件-它们用红色数字标记。 让我们来看一下（稍后我们将更详细地介绍每个组件）：

  1. 发票网关 –这是我们放置新发票以便它们可以进入消息传递层的地方。
  2. 拆分器 -该系统旨在接受发票的集合，但是我们将需要单独处理每个发票。 更具体地说，具有“收集”类型正文的邮件将被拆分为多个邮件，其中每个邮件将具有单独的发票作为正文。
  3. 筛选器 -我们的系统旨在仅自动处理开具少于$ 10,000的那些发票。
  4. 基于内容的路由器 –有些发票使用IBAN帐号，我们有两个不同的帐号-一个用于本地交易，一个用于国外交易。 路由器组件的工作是将带有发票的消息发送到正确的通道-无论是本地发票还是国外发票。
  5. 变形金刚 –当我们在系统中接受发票时，我们的银行API可以与其他类型一起使用–付款。 转换器组件的工作是根据提供的逻辑获取一些消息并将其转换为另一条消息。 我们希望将原始消息（发票）的有效负载转换为新的有效负载-付款。
  6. Banking Service Activator –处理发票并生成一些实际付款后，我们准备与外部银行系统进行对话。 我们已经公开了此类系统的服务，当携带付款的消息进入正确的（银行）渠道时，我们想激活一些逻辑–将付款传递给银行，然后让银行进行进一步处理。

创建项目

到目前为止，您应该对系统的功能以及其结构有一个较高的概述。 在开始编码之前，您将需要一个实际的Maven项目，并设置结构和所需的依赖关系。 如果您熟悉Maven，请参见下面的pom.xml文件，否则，如果您想节省一些时间，欢迎使用我为您创建的项目模板： 下载Maven项目模板 。 

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>apache-camel-invoices</groupId><artifactId>apache-camel-invoices</artifactId><version>1.0-SNAPSHOT</version><properties><camel-version>2.12.0</camel-version></properties><dependencies><dependency><groupId>org.apache.camel</groupId><artifactId>camel-core</artifactId><version>${camel-version}</version></dependency><dependency><groupId>org.apache.camel</groupId><artifactId>camel-spring</artifactId><version>${camel-version}</version></dependency><dependency><groupId>org.apache.camel</groupId><artifactId>camel-quartz</artifactId><version>2.9.5</version></dependency><dependency><groupId>org.apache.camel</groupId><artifactId>camel-test-spring</artifactId><version>${camel-version}</version><scope>test</scope></dependency><dependency><groupId>log4j</groupId><artifactId>log4j</artifactId><version>1.2.16</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId><version>1.7.5</version></dependency><dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>14.0.1</version></dependency></dependencies><build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><configuration><source>1.7</source><target>1.7</target></configuration></plugin><!--- uncomment when InvoicesApplication class will exist<plugin><groupId>org.codehaus.mojo</groupId><artifactId>exec-maven-plugin</artifactId><version>1.2.1</version><configuration><mainClass>com.vrtoonjava.invoices.InvoicesApplication</mainClass></configuration></plugin>--></plugins></build></project>

自举骆驼

在使用Apache Camel之前，我们需要对其进行一些引导。 首先，我们将创建包com.vrtoonjava.routes ，在其中放置路由配置。 其次，我们将创建InvoicesRouteBuilder类，该类将是配置路由的地方。 因此，像这样创建类： 

package com.vrtoonjava.routes;import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;@Component
public class InvoicesRouteBuilder extends RouteBuilder {@Overridepublic void configure() throws Exception {//TODO configure route}
}

最后要做的是将Camel插入Spring（Camel将使用Spring作为bean的注册表）。 将文件camel-config.xml添加到您的src / main / resources文件夹中，其中包含以下内容： 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:camel="http://camel.apache.org/schema/spring"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsdhttp://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"><camelContext xmlns="http://camel.apache.org/schema/spring"><routeBuilder ref="invoicesRouteBuilder"/></camelContext></beans>

现在，让我们更详细地介绍系统的六个主要组件，并获得实际的代码。

1.发票网关

首先，让我们看一下Invoice的代码-这将是系统中的核心类之一。 我将使用com.vrtoonjava软件包作为根软件包，使用invoices和banking作为子软件包： 

package com.vrtoonjava.invoices;import com.google.common.base.Objects;import java.math.BigDecimal;public class Invoice {private final String iban;private final String address;private final String account;private final BigDecimal dollars;public Invoice(String iban, String address, String account, BigDecimal dollars) {this.iban = iban;this.address = address;this.account = account;this.dollars = dollars;}public boolean isForeign() {return null != iban && !iban.isEmpty();}public String getAddress() {return address;}public String getAccount() {return account;}public BigDecimal getDollars() {return dollars;}public String getIban() {return iban;}@Overridepublic String toString() {return Objects.toStringHelper(this).add("iban", iban).add("address", address).add("account", account).add("dollars", dollars).toString();}}

想象一下，我们从另一个系统（数据库，Web服务或其他系统）获取发票，但是我们不想将此部分耦合到集成层。 我们将为此使用网关组件。 Gateway引入了一个协议 ，该协议将客户端代码与集成层分离（在我们的示例中为Apache Camel依赖项）。 让我们看一下InvoiceCollectorGateway的代码： 

package com.vrtoonjava.invoices;import java.util.Collection;/*** Defines a contract that decouples client from the Apache Camel framework.*/
public interface InvoiceCollectorGateway {void collectInvoices(Collection<Invoice> invoices);}

我们定义了此接口，以使客户仅依赖合同。 实际的实现将是特定于骆驼的，我们可以这样创建它： 

package com.vrtoonjava.invoices;import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.springframework.stereotype.Component;import java.util.Collection;@Component
public class CamelInvoiceCollectorGateway implements InvoiceCollectorGateway {@Produce(uri = "seda:newInvoicesChannel")ProducerTemplate producerTemplate;@Overridepublic void collectInvoices(Collection<Invoice> invoices) {producerTemplate.sendBody(invoices);}}

请注意@Produce批注。 该注释告诉Camel，字段producerTemplate是端点seda:newInvoicesChannel 。 当客户端调用collectInvoices方法时，网关将向seda:newInvoicesChannel通道发送一条新消息（包含列表主体）。 这使客户端与消息传递工具脱钩，但是让我们将结果放置到实际的消息传递通道中。

为什么选择SEDA？

通常，在用Java构建消息传递系统时，最终会使用诸如JMS之类的东西，它提供了许多有用的功能，例如高可靠性或消息持久性。 在本教程中，我们将使用基于SEDA组件的更轻松的替代方法-它使我们能够利用几乎零配置的异步内存中消息传递。

2.发票分割器

从网关，我们向包含发票集合的系统发送一条大消息-换句话说，消息具有“ Collection类型的正文。 当我们要单独处理发票时，我们将从seda:newInvoicesChannel获得结果，并使用分离器组件，该组件将创建多个消息。 这些新消息中的每一个都有一个“发票”类型的正文。 然后，我们将消息放置到新渠道– seda:singleInvoicesChannel 。 这就是我们定义拆分器的方式（将以下代码添加到InvoicesRouteBuilder的configure方法中）： 

from("seda:newInvoicesChannel").log(LoggingLevel.INFO, "Invoices processing STARTED").split(body()).to("seda:singleInvoicesChannel");

3.过滤一些发票

我们系统的业务用例要求我们仅自动处理发出少于$ 10,000的发票。 为此，我们将介绍一个过滤器组件。 我们将从seda:singleInvoicesChannel抓取消息，对它们应用过滤逻辑，然后将匹配的结果写入新的seda:filteredInvoicesChannel通道。 在Apache Camel中，您可以插入自己的包含过滤逻辑的谓词 。 首先，让我们定义这样的谓词（通过扩展Camel的org.apache.camel.Predicate ）： 

package com.vrtoonjava.invoices;import org.apache.camel.Exchange;
import org.apache.camel.Predicate;public class LowEnoughAmountPredicate implements Predicate {public static final int LOW_ENOUGH_THRESHOLD = 10_000;@Overridepublic boolean matches(Exchange exchange) {Invoice invoice = exchange.getIn().getBody(Invoice.class);boolean lowEnough = invoice.getDollars().intValue() < LOW_ENOUGH_THRESHOLD;System.out.println("Amount of $" + invoice.getDollars()+ (lowEnough ? " can" : " can not") + " be automatically processed by system");return lowEnough;}}

为了简洁起见，我不在本教程中粘贴单元测试–但是，如果您有兴趣， 请继续下载github项目并亲自查看测试 。

现在我们需要将此谓词连接到我们的路由，因此将以下代码添加到您的configure方法中： 

from("seda:singleInvoicesChannel").filter(new LowEnoughAmountPredicate()).to("seda:filteredInvoicesChannel");

4.路由发票

到目前为止，我们已经拆分并过滤了一些发票。 现在是时候更仔细地检查每个发票的内容并决定是从当前国家（本地）还是从另一个国家（外国）发行的发票了。 Apache Camel允许使用Java DSL中的choice()方法来定义基于内容的路由器 。 我们甚至可以直接在Java DSL中访问消息的主体并执行一些简单的评估。 将以下代码添加到您的configure方法中（并注意我们如何使用${body.isForeign}标准表达式来访问body）： 

from("seda:filteredInvoicesChannel").choice().when().simple("${body.isForeign}").to("seda:foreignInvoicesChannel").otherwise().to("seda:localInvoicesChannel");

我们将在本教程的第二部分中继续开发此应用程序。

参考： Apache Camel –在vrtoonjava博客上从JCG合作伙伴 Michal Vrtiak 从头开始开发应用程序（第1部分/第2部分） 。

翻译自: https://www.javacodegeeks.com/2013/10/apache-camel-developing-application-from-the-scratch-part-1-2.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/366467.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Bourbon: 让你的sass更简洁

Bourbon: 让你的sass更简洁

Bourbon是什么 bourbon是一个轻量级的Sass mixin和函数库&#xff0c;可以帮助我们快速开发样式. 官方文档 以下用webpack3.10.0( vue)为示例简述Bourbon的使用 安装配置 npm install bourbon -S 把bourbon添加到node-sass的includePaths中// webpack.config.js module.expor…
阅读更多...
nat的地址映射 华为_华为PAT端口地址映射配置详解（一）

nat的地址映射 华为_华为PAT端口地址映射配置详解（一）

众所周知&#xff0c;PAT,&#xff0c;Port Address Translation&#xff0c;即网络地址转换。PAT有以下作用&#xff1a;1.改变数据包的ip地址和端口号&#xff1b;2.能够大量节约公网IP地址。PAT的类型有以下&#xff1a;1.动态PAT&#xff0c;包括NAPT和Easy IP&#xff1b;…
阅读更多...
删除maven仓库中的lastUpdate文件

删除maven仓库中的lastUpdate文件

windows下打开命令行 进入maven本地仓库目录中 dos命令中执行下方命令.即可完成批量删除 for /r %i in (*.lastUpdated) do del %i 转载于:https://www.cnblogs.com/zlsxddgj/p/9324077.html
阅读更多...
HDUOJ 1428

HDUOJ 1428

漫步校园 Time Limit: 2000/1000 MS (Java/Others) Memory Limit: 65536/32768 K (Java/Others)Total Submission(s): 5161 Accepted Submission(s): 1610 Problem DescriptionLL最近沉迷于AC不能自拔&#xff0c;每天寝室、机房两点一线。由于长时间坐在电脑边&#xff…
阅读更多...
niosii spi 外部_基于Nios_II的DMA传输总结

niosii spi 外部_基于Nios_II的DMA传输总结

最近练了一段时间的DMA传输&#xff0c;现做如下的总结&#xff0c;分享自己获得心得以及遇到的一些问题。在系统运行时&#xff0c;当需要传输大量数据时&#xff0c;可以采用DMA的方式进行传输&#xff0c;以解脱出CPU来处理其他命令。Nios II中的DMA传输有以下三种形式&…
阅读更多...
杭州 GraphQLParty 第五场-GraphQL 基于 SPA 架构的工程实践文字版

杭州 GraphQLParty 第五场-GraphQL 基于 SPA 架构的工程实践文字版

本文为 2018 年 6 月 9 日&#xff0c;宋小菜与 Coding 共同举办的第一届 GraphQLParty &#xff0c;下午第五场国内某大型电商前端开发专家邓若奇的演讲稿&#xff0c;现场反响效果极好&#xff0c;对于想要尝试 GraphQL 和在公司初步实践的团队有很大的借鉴意义。 大家好&…
阅读更多...
java反射机制基础总结

java反射机制基础总结

1反射机制是啥&#xff1f; 反射是运行中的程序检查自己和软件运行环境的能力&#xff0c;它可以根据它发现的进行改变。通俗的讲就是反射可以在运行时根据指定的类名获得类的信息。 2反射机制有啥用&#xff1f; Reflection(反射)是被视为动态语言的关键反射机制使程序在执行期…
阅读更多...
使用sikuli和Arquillian测试HTML5 canvas应用程序

使用sikuli和Arquillian测试HTML5 canvas应用程序

HTML5引入了一个很棒的新元素&#xff0c;可以用来在窗格上绘制任意内容&#xff1a; canvas元素。 数十年来&#xff0c;胖客户端应用程序的标准功能现已引入Web应用程序领域。 Web开发人员不再需要使用专有插件在其应用程序中绘制图像或图表。 但是&#xff0c;在进行测试时…
阅读更多...
浅谈一下我了解的PWA

浅谈一下我了解的PWA

Progressive Web Apps,简称PWA&#xff0c;中文翻译过来就是渐进式网页应用&#xff0c;个人觉得它可以算是Web应用的下一个进化方向之一&#xff0c; 毕竟技术的发展有时候是不可预估的&#xff0c;谁也无法预料技术的走向&#xff0c;但至少它代表了一种可能性&#xff0c;下…
阅读更多...
质性研究工具_质性研究【001】

质性研究工具_质性研究【001】

袁长蓉 复旦大学 博士研究生导师课程 人类是追求意义的物种&#xff0c;会不断地从生活细节当中不断的归纳提炼&#xff0c;形成精神。形成理论抽象的概念&#xff0c;然后再利用这些概念&#xff0c;这些理论反过来&#xff0c;解释生活。 质性研究是由地到天的研究。质性研究…
阅读更多...
python实现文件下载图片视频

python实现文件下载图片视频

最近在学习爬虫&#xff0c;在爬取网站时很多时候是需要将图片或视频下载到本地 今天就来说说如何使用urllib将图片保存到本地 以下代码均为win7 python3.6.* 方法一&#xff08;使用下载函数保存&#xff09; from urllib import request # 要下载的图片链接地址 img_url …
阅读更多...
在JUnit中处理异常的3种方法。 选择哪一个？

在JUnit中处理异常的3种方法。 选择哪一个？

在JUnit中&#xff0c;有3种流行的方式来处理测试代码中的异常&#xff1a; 尝试捕捉习语 使用JUnit规则 带注解 我们应该使用哪一个&#xff1f;何时使用&#xff1f; 尝试捕捉习语 这个习语是最受欢迎的习语之一&#xff0c;因为它已在JUnit 3中使用。 Testpublic void…
阅读更多...
项目开发中发布更新文档备注

项目开发中发布更新文档备注

项目开发中 经常会遇到 某一个团队成员更新了,配置文件但是没有及时沟通导致项目发布后出现异常的情况。 这时就需要一个项目更新发布的规范说明文件,比如每次更新更改了哪些,进行文档备注。 更新的脚本文件也要随更新文档一起给到,配置文件也要将最新的配置信息给到。 转载于:…
阅读更多...
bind函数polyfill源码解析

bind函数polyfill源码解析

准备知识 使用new来调用函数会自动执行下面的操作&#xff1a; 创建一个全新的对象这个新对象会被执行原型连接这个新对象会绑定到函数调用的this如果函数没有返回其他对象&#xff0c;那么new表达式中的函数调用会自动返回这个新对象 注意this绑定规则&#xff0c;new操作具…
阅读更多...
Java方法中的参数太多，第2部分：参数对象

Java方法中的参数太多，第2部分：参数对象

在上一篇文章中 &#xff0c;我研究了与方法和构造函数的长参数列表相关的一些问题。 在那篇文章中&#xff0c;我讨论了用自定义类型替换基元和内置类型以提高可读性和类型安全性。 这种方法使方法或构造函数的众多参数更具可读性&#xff0c;但并没有减少参数的数量。 在本文…
阅读更多...
django内置服务器

django内置服务器

单进程多线程的 多线程用来并发&#xff0c;各个线程之间不会阻塞&#xff0c;每个线程对应一个连接转载于:https://www.cnblogs.com/BlueFire-py/p/10031245.html
阅读更多...
java mysql_Java与mysql的连接

java mysql_Java与mysql的连接

接触编程、计算机一段时间&#xff0c;免不了的就要接触到&#xff0c;各种数据&#xff0c;而各种数据到了深处自然就要接触到数据的存储和调用&#xff0c;之前在我的文章中&#xff0c;已经了解到了IO流在文件中以及在TCP\IP协议中的各种传输&#xff0c;而慢慢的&#xff0…
阅读更多...
Oracle 创建wims用户和表空间

Oracle 创建wims用户和表空间

/*用sys SYSDBA *//*分为四步 *//*第1步&#xff1a;创建临时表空间 */create temporary tablespace xxxxxxx_temp tempfile D:\app\Administrator\oradata\orcl\xxxxxxx_temp.dbf size 50m autoextend on next 50m maxsize 20480m extent management local; /*第2步&#xff1…
阅读更多...
面试常见问题之实现bind函数

面试常见问题之实现bind函数

前言&#xff1a; 原文首发于我的博客&#xff0c;说实话&#xff0c;这半年来在各大社区看别人分享的面试题中 bind 函数已经出现 n 多次了&#xff0c;这次准备详细探究下 首先让我们看看 mdn 对于 bind 函数的描述是什么 语法 fun.bind(thisArg[, arg1[, arg2[, ...]]]) 参…
阅读更多...
WIN10 开启右键 命令提示符

WIN10 开启右键 命令提示符

PowerShell强行加入右键菜单也罢了&#xff0c;命令提示符还默认禁用&#xff0c;可谓巨硬又一次智障操作。通过操作注册表可以解除这个封印&#xff1a; 移除 HKEY_CLASSES_ROOT\Directory\Background\shell\cmd 键中的 HideBasedOnVelocityId 然后刷新注册表&#xff0c;可能…
阅读更多...
最新文章

Copyright @ 2022~2023