Camel流程框架是Apache下的一个开源项目，是较为成熟的流程框架。在web项目中也可以无缝地集成于Spring当中。
一、简单使用
引入camel相关的jar包：camel-core-2.10.4.jar。
1、经典的入门示例——文件移动
public class FileMoveWithCamel {
public static void main(String[] args) {
try{
CamelContext camelCtx = new DefaultCamelContext();
camelCtx.addRoutes(new RouteBuilder() {
//此示例中，只能转移文件，而无法转移目录
@Override
public void configure() throws Exception {
from("file:f:/tmp/inbox?delay=30000").to("file:f:/tmp/outbox");
}
});
camelCtx.start();
boolean loop = true;
while(loop) {
Thread.sleep(25000);
}
System.out.println("循环完毕");
camelCtx.stop();
} catch(Exception ex) {
ex.printStackTrace();
}
}
其中file:类似于http://，是camel的协议组件。camel支持的组件还包括：bean browse dataset direct file log mock properties seda test timer stub validator vm xlst等。其中常用的有bean和direct以及file
运行上述程序，会发现file:f:/tmp/inbox下的文件被转移到file:f:/tmp/outbox了，并且在file:f:/tmp/inbox会生成一个.camel文件夹存放刚才被转移的文件。
2、入门示例二——带Processor处理
先定义一个处理器，实现org.apache.camel.Processor接口
public class FileConvertProcessor implements Processor {
@Override
public void process(Exchange exchange) throws Exception {
// Object obj = exchange.getIn().getBody(); //如果是getBody()则返回一个Object
//如果是getBody(Class<T>)则返回T类型的实例
InputStream body = exchange.getIn().getBody(InputStream.class);
// System.out.println("进入:" + body);
BufferedReader br = new BufferedReader(new InputStreamReader(body, "UTF-8"));
StringBuilder sb = new StringBuilder("");
String str;
while((str = br.readLine()) != null) {
System.out.println(str);
sb.append(str + " ");
}
exchange.getOut().setHeader(Exchange.FILE_NAME, "converted.txt");
exchange.getOut().setBody(sb.toString());
System.out.println("body:" + exchange.getOut().getBody());
}
加上处理器后处理文件的程序
public class FileProcessWithCamel {
public static void main(String[] args) {
try{
CamelContext camelCtx = new DefaultCamelContext();
camelCtx.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
FileConvertProcessor processor = new FileConvertProcessor();
//noop表示等待、无操作
from("file:f:/tmp/inbox?noop=true").process(processor).to("file:f:/tmp/outbox");
}
});
camelCtx.start();
boolean loop = true;
//死循环表示挂起camel上下文，以便持续监听
while(loop) {
Thread.sleep(25000);
}
camelCtx.stop();
} catch(Exception ex) {
ex.printStackTrace();}
}
}
运行程序后将用一行打印file:f:/tmp/inbox下的文件的多行内容，并在file:f:/tmp/outbox下生成名为converted.txt的文件。该文件的内容即为file:f:/tmp/inbox下的文件的多行内容显示成的一行。
这里要特别注意getIn（setIn）,getOut（setOut）怎么用：先看下面一张图
这张图表明了：假设有流程A->B->C->D->……则A在处理完毕之后给B的话，A必须setOut结果，然后B要取流程中的“上一个”节点（即A）的结果则必须getIn取结果再处理，以此类推……A不能setIn结果，否则B getIn的话会取不到A set的结果。
二、集成在Spring当中
需引入camel-core-2.10.4.jar camel-spring-2.10.4.jar
对已第一部分的第一示例，若在Spring中配置，并设置它随着web项目的启动而启动，则可以这样写：
<?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:drools="http://drools.org/schema/drools-spring"
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.0.xsd
http://drools.org/schema/drools-spring http://anonsvn.jboss.org/repos/labs/labs/jbossrules/trunk/drools-container/drools-spring/src/main/resources/org/drools/container/spring/drools-spring-1.0.0.xsd
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
<bean id="fileConverter" class="com.xxxx.FileConvertProcessor" />
<camelContext id="camel" autoStartup="true" xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="file:f:/tmp/inbox?delay=30000"/>
<process ref="fileConverter"/>
<to uri="file:f:/tmp/outbox"/>
</route>
</camelContext>
</beans>
除此之外，其实更为常见的是一个处理流程往往需要经过很多个bean类。而查看camel direct组件的用法：
In the route below we use the direct component to link the two routes together:
可知bean与bean之间的流程连接用的是direct，这里不妨用fileConverter和fileConverter2两个Processor测试（它们的具体定义省略，都得实现Processor接口），于是：
<bean id="fileConverter" class="com.xxx.FileConvertProcessor" />
<bean id="fileConverter2" class="com.xxx.FileConvertProcessor2" />
<camelContext id="camel" autoStartup="true" xmlns="http://camel.apache.org/schema/spring">
<template id="producerTemplate" />
<threadPool id="pool" threadName="Thread-dataformat"
poolSize="50" maxPoolSize="200" maxQueueSize="250" rejectedPolicy="CallerRuns" />
<route>
<from uri="file:f:/tmp/inbox?delay=30000"/>
<process ref="fileConverter"/>
<to uri="file:f:/tmp/outbox"/>
<to uri="direct://start"/>
</route>
<route>
<from uri="direct://start"/>
<threads executorServiceRef="pool">
<process ref="fileConverter"/>
<to uri="bean://fileConverter2"/>
</threads>
</route>
</camelContext>
注意到上面第二个路由<route />中to的配置被放在一个线程池当中了，这也是比较常见的用法。这里表明流程经过fileConverter处理，流向fileConverter2继续处理。
另外，我们常常需要根据某一条件判断流程的“下一步”应该走向哪里，这时候就要用到类似el表达式的if else判断了。再定义一个fileConverter3，表明根据条件选择——流程在经过fileConverter时，根据配置条件选择“下一步”流向fileConverter2还是fileConverter3（fileConverter2和fileConverter3定义省略，它们都得实现Processor接口）
<bean id="fileConverter" class="com.xxxx.FileConvertProcessor" />
<bean id="fileConverter2" class="com.xxx.FileConvertProcessor2" />
<bean id="fileConverter3" class="com.xxx.FileConvertProcessor3" />
<camelContext id="camel" autoStartup="true" xmlns="http://camel.apache.org/schema/spring">
<template id="producerTemplate" />
<threadPool id="pool" threadName="Thread-dataformat"
poolSize="50" maxPoolSize="200" maxQueueSize="250" rejectedPolicy="CallerRuns" />
<route>
<from uri="file:f:/tmp/inbox?delay=30000"/>
<process ref="fileConverter"/>
<to uri="file:f:/tmp/outbox"/>
<to uri="direct://start"/>
</route>
<route>
<from uri="direct://start"/>
<threads executorServiceRef="pool">
<choice>
<when>
<simple>${body.length} > 40</simple>
<process ref="fileConverter"/>
<to uri="bean://fileConverter2"/>
</when>
<otherwise>
<process ref="fileConverter"/>
<to uri="bean://fileConverter3"/>
</otherwise>
</choice>
</threads>
</route>
</camelContext>
<choice />和<otherwise />即表示选择分支，而<when />下的<simple />标签则用来放判断条件，写法和el表达式的条件判断很类似。
注意Camel流程的开始时，应该在Java代码中用ProducerTemplate.sendBody("direct://xxx",data)开始流程的源头。ProducerTemplate是从配置文件的bean获取(<template id="producerTemplate" />)的，然后ProducerTemplate.start()启动Camel流程。然后在配置文件中通过<from uri="direct://xxx"/>开始接收流程传过来的data数据。
相关推荐
Apache Camel框架 HTTP相关的jar包,httpclient等等.
Apache Camel 框架实现的JMS路由。有图解，很详细。
Apache Camel 开发使用指南中文版
Apache Camel is a Java framework that lets you implement the standard enterprise integration patterns in a few lines of code. With a concise but sophisticated DSL you snap integration logic into your ...
Camel3 Camel6函数等matlab源代码
Camel in action 一书的PDF电子书 和源代码
CAMEL 呼叫流程和信令流程 CAMEL 呼叫流程和信令流程 CAMEL 呼叫流程和信令流程 CAMEL 呼叫流程和信令流程
如：jetty、file、activemq、ftp、http、log、并行、分支、发送邮件、接收邮件、seda队列、timer定时器、netty4、quartz2定时器、zookeeper操作，只是简单案例，方便学习, 适合入门和研究camel。不喜勿喷...
Camel in action 一书的PDF电子书 和源代码 The book is divided into three parts: ■ Part 1—First steps ■ Part 2—Core Camel ■ Part 3—Out in the wild
中文名: Camel 实战 原名: Camel in Action 作者: Claus Ibsen Jonathan Anstey 资源格式: PDF 版本: 英文文字版/更新源代码 出版社: Manning书号: 9781935182368发行时间: 2010年12月 地区: 美国 语言: 英文 简介: ...
用camel-cxf调用webservice和发布一个webservice接口例子，首先启动QueryServiceMain主函数启动webservice接口，然后启动测试类TestWebservice。例子主要是实现java代码实现camel调用webservice接口
此文档主要针对以下四个问题进行详细分析以及解答。 第一：我们要解决的企业应用集成问题。 第二：为什么使用Camel； 第三：Camel可以做什么？ 第四：Camel的核心要素。
camel, Apache camel 镜像 Apache camel 是基于已知企业集成模式的强大开放源代码集成框架，它具有强大的Bean集成。简介flex允许你创建企业集成模式，以基于基于Java的域特定语言( 或者 Fluent API ) 或者基于 Sc
ApacheCamel-JDBC Apache Camel JDBC组件 代码样例Demo
Apache Camel是一个基于规则路由和中介引擎，提供企业集成模式的Java对象(POJO)的实现，通过应用程序接口（或称为陈述式的Java领域特定语言（DSL））来配置路由和中介的规则。领域特定语言意味着Apache Camel支持你...
Apache Camel是一个开源Java框架，专注于使开发人员更容易集成和访问。它通过以下方式实现： •所有广泛使用的EIP的具体实施 •连接各种传输和API •易于使用的域特定语言（DSL）将EIP和传输连接在一起
Apache Camel通过URI的方式来定义需要集成的应用节点信息，用户可以按照业务需求使用DSL快速编写消息路由规则，而无需关注集成协议的细节问题。与传统的企业集成服务总线（ESB）相比，Apache Camel的核心库非常小巧...
jar包，亲测可用
Apache Camel简介以及使用场景
Camel使用URI来简化与所有传输或消息传递模型（包括HTTP，ActiveMQ，JMS，JBI，SCA，MINA或CXF）的集成，并使用可插拔数据格式选项。 Apache Camel是一个小型库，具有最小的依赖关系，可轻松嵌入任何Java应用程序中...