资讯

历史

科技

环境与自然

成长

游戏

财经

文学与艺术

美食

健康

家居

文化

情感

汽车

三农

军事

旅行

运动

教育

生活

星座命理

Apache Camel 概念及使用场景

创作时间:

作者:

@小白创作中心

Apache Camel 概念及使用场景

引用

CSDN

https://m.blog.csdn.net/Swollow_/article/details/80896038

Apache Camel是一个基于Enterprise Integration Pattern(企业整合模式，简称EIP)的开源框架。它提供了实现EIP模式、多种组件支持、灵活路由规则定义等功能。本文将详细介绍Apache Camel的概念、功能及其应用场景。

Apache Camel概述

Apache Camel主要提供了以下功能：

实现了EIP的大部分模式，如果你要在不同的应用系统之间以不同的方式传递消息，那么你可以从Apache Camel中找到解决方案。
提供了大量Component(组件)，每个组件都是一种消息中间件(或消息服务)的具体实现，每个消息中间件所用的协议都是不同的，因此，你可以通过多种不同的协议来完成消息传输。
允许用户定义灵活的路由规则，从这个角度来说，Apache Camel时一个规则引擎。

Apache Camel的应用场景

1. 消息汇聚

例如，你有来自不同服务器的消息，包括ActiveMQ、RabbitMQ、WebService等，你想把它们都存储到日志文件中，那么可以定义如下规则：

new RouteBuilder() {
    @Override
    public void configure() throws Exception {
        from("amqp:queue:incoming").to("log:com.mycompany.log?level=DEBUG");
        from("rabbitmq://localhost/A/routingKey=B").to("log:com.mycompany.log?level=DEBUG");
        from("jetty:http://localhost:8080/myapp/myservice").to("log:com.mycompany.log?level=DEBUG");
    }
}

其中，from表示从这个endpoint取消息，to表示将消息发往这个endpoint，endpoint是消息地址，包含协议类型以及url。

2. 消息分发

消息分发分为顺序分发和并行分发两种方式。

顺序分发：

例如，有如下规则：

from("amqp:queue:order").to("uri:validateBean", "uri:handleBean", "uri:emailBean");

这个规则是从order队列中取订单信息，然后依次验证订单、处理订单，并发送邮件通知用户。任何一个步骤出错，下一个步骤将不会执行。

并行分发：

如果将以上路由改成：

from("amqp:queue:order").multicast().to("uri:validateBean", "uri:handleBean", "uri:emailBean");

那么消息就会同时发到to所对应的endpoint。

3. 消息转换

例如，想将xml数据转换成json数据，可以使用如下规则：

from("amqp:queue:order").process(new XmlToJsonProcessor()).to("bean:orderHandler");

其中，XmlToJsonProcessor是自定义的类，继承org.apache.camel.Processor，用于将xml数据转换成json。

4. 规则引擎

你可以使用Spring Xml、Groovy这类DSL来定义route，这样无需修改代码，就能达到修改业务逻辑的目的。

例如，上边的规则：

from("amqp:queue:order").to("uri:validateBean", "uri:handleBean", "uri:emailBean");

使用Spring Xml定义如下：

<route>
    <from uri="amqp:queue:order"/>
    <multicast>
        <to uri="uri:validateBean"/>
        <to uri="uri:handleBean"/>
        <to uri="uri:emailBean"/>
    </multicast>
</route>

如果需要在处理完订单后添加日志，可以改称如下规则：

<route>
    <from uri="amqp:queue:order"/>
    <multicast>
        <to uri="uri:validateBean"/>
        <to uri="uri:handleBean"/>
        <to uri="log:com.mycompany.log?level=INFO"/>
        <to uri="uri:emailBean"/>
    </multicast>
</route>

另外，camel提供了大量的内置Processor，用于逻辑运算、过滤等，这样更加容易定义灵活的route，例如：

from("amqp:queue:order").filter(header("foo").isEqualTo("bar")).choice()
    .when(xpath("/person/city = 'London'"))
    .to("file:target/messages/uk")
    .otherwise()
    .to("file:target/messages/others");

这条规则先对订单进行过滤，只处理header中foo的值为bar的订单，然后根据用户的城市进行将订单传给不同的endpoint。