Apache Camel的Java编程入门指南
ApacheCamel是一个非常实用的规则引擎库，能够用来处理来自于不同源的事件和信息。你可以在使用不同的协议比如VM，HTTP，FTP，JMS甚至是文件系统中来传递消息，并且让你的操作逻辑和传递逻辑保持分离，这能够让你更专注于消息的内容。
在这篇文章中，我将提供一个Java语言（非Groovy）的ApacheCamel入门演示。
首先创建一个Maven项目的pom.xml。
<?xmlversion="1.0"encoding="UTF-8"?>
<projectxmlns="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/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>camel-spring-demo</groupId>
<artifactId>camel-spring-demo</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<camel.version>2.11.1</camel.version>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
<version>${camel.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.5</version>
</dependency>
</dependencies>
</project>
在这里我们只用到了camel-core.jar包，实际上它提供了许多你可能用到的实用组件。出于日志记录的目的，我使用了slf4j-simple来作为日志记录的实现，从而我们可以从控制台上看到输出。
接下来我们只需要构造一个路由类。路由就好比是Camel中怎样将消息从一端传递到另一端的一个指令定义。我们将会创建src/main/java/camelcoredemo/TimerRouteBuilder.java文件，每隔一秒向处理器发送一个消息，简单打印出来。
packagecamelcoredemo;
importorg.slf4j.*;
importorg.apache.camel.*;
importorg.apache.camel.builder.*;
publicclassTimerRouteBuilderextendsRouteBuilder{
staticLoggerLOG=LoggerFactory.getLogger(TimerRouteBuilder.class);
publicvoidconfigure(){
from("timer://timer1?period=1000")
.process(newProcessor(){
publicvoidprocess(Exchangemsg){
LOG.info("Processing{}",msg);
}
});
}
}
以上就是这个示例的全部所需，现在编译运行。
bash>mvncompile bash>mvnexec:java-Dexec.mainClass=org.apache.camel.main.Main-Dexec.args='-rcamelcoredemo.TimerRouteBuilder'
注意，这里我们并没有编写Java类的main入口，我们只是将RouteBuilder的类名当作参数简单传递给org.apache.camel.main.Main,然后它将自动加载路由。
控制CamelContext
当启动Camel后，它会创建一个CamelContext对象，该对象拥有了很多关于如何运行Camel的信息，还包含我们所创建的Route的定义。现在如果你想通过CamelContext获得更多的控制，那么你需要编写自己的主类代码。我在这举个简单的例子。
packagecamelcoredemo;
importorg.slf4j.*;
importorg.apache.camel.*;
importorg.apache.camel.impl.*;
importorg.apache.camel.builder.*;
publicclassTimerMain{
staticLoggerLOG=LoggerFactory.getLogger(TimerMain.class);
publicstaticvoidmain(String[]args)throwsException{
newTimerMain().run();
}
voidrun()throwsException{
finalCamelContextcamelContext=newDefaultCamelContext();
camelContext.addRoutes(createRouteBuilder());
camelContext.setTracing(true);
camelContext.start();
Runtime.getRuntime().addShutdownHook(newThread(){
publicvoidrun(){
try{
camelContext.stop();
}catch(Exceptione){
thrownewRuntimeException(e);
}
}
});
waitForStop();
}
RouteBuildercreateRouteBuilder(){
returnnewTimerRouteBuilder();
}
voidwaitForStop(){
while(true){
try{
Thread.sleep(Long.MAX_VALUE);
}catch(InterruptedExceptione){
break;
}
}
}
}
可以看到，我们在createRouteBuilder()方法中重用了已有的TimerRouteBuilder类。现在我们的主类对在什么时候创建、启动、停止CamelContext有了完全的控制。context(camelContext)对象允许你全局性地控制如何配置Camel，而不是在Route级。它的JavaDoc链接给出了所有setter方法，你可以研究下它都可以做些什么。
注意到一点，我们也需要在我们的主类中提供少量设置代码。首先我们需要处理优雅关闭的问题，所以我们增加了一个Java关闭回调函数去调用context的stop()方法。其次在context已经启动后，我们需要增加一个线程阻塞。如果在启动后你不阻塞你的主线程，那么它会在启动后就简单的退出了，那就没啥用了。你会把Camel一直作为一个服务(就像一个服务器)运行，直至你按下CTRL+C键去终止该进程。
改善启动CamelContext的主类
如果你不想像上面例子一样过多的处理主类设置代码，那么你可以简单地继承由camel-core提供的org.apache.camel.main.Main类作为代替。通过利用这个类，你不仅可以让你的context自动设置，还可以获得所有附加的命令行特性，比如控制进程运行多久，启用追踪，加载自定义route类等等。
重构了下上一个例子，代码如下：
packagecamelcoredemo;
importorg.slf4j.*;
importorg.apache.camel.builder.*;
importorg.apache.camel.main.Main;
publicclassTimerMain2extendsMain{
staticLoggerLOG=LoggerFactory.getLogger(TimerMain2.class);
publicstaticvoidmain(String[]args)throwsException{
TimerMain2main=newTimerMain2();
main.enableHangupSupport();
main.addRouteBuilder(createRouteBuilder());
main.run(args);
}
staticRouteBuildercreateRouteBuilder(){
returnnewTimerRouteBuilder();
}
}
现在TimerMain2类的代码比之前的更少了，你可以试试看，它应该和之前的功能一样。
bash>mvncompile bash>mvnexec:java-Dexec.mainClass=camelcoredemo.TimerMain2-Dexec.args='-t'
注意到我们给出-t选项后，会转储Route追踪。使用-h会看到所有可用的选项。
用Camel的注册机制添加bean
在之前的TimerRouteBuilder例子中，我们已经在代码中创建了一个匿名Processor。现在如果你想将几个不同的Processor放在一起，那么使用Camel的注册机制添加bean的方式将能更好的减少代码混乱。Camel允许你通过将processing当作bean注入到它的registryspace，然后你只要把它们当作bean组件来进行调用。如下是我的重构代码:
packagecamelcoredemo;
importorg.slf4j.*;
importorg.apache.camel.*;
importorg.apache.camel.builder.*;
importorg.apache.camel.main.Main;
publicclassTimerBeansMainextendsMain{
staticLoggerLOG=LoggerFactory.getLogger(TimerBeansMain.class);
publicstaticvoidmain(String[]args)throwsException{
TimerBeansMainmain=newTimerBeansMain();
main.enableHangupSupport();
main.bind("processByBean1",newBean1());
main.bind("processAgainByBean2",newBean2());
main.addRouteBuilder(createRouteBuilder());
main.run(args);
}
staticRouteBuildercreateRouteBuilder(){
returnnewRouteBuilder(){
publicvoidconfigure(){
from("timer://timer1?period=1000")
.to("bean:processByBean1")
.to("bean:processAgainByBean2");
}
};
}
//Processorbeans
staticclassBean1implementsProcessor{
publicvoidprocess(Exchangemsg){
LOG.info("Firstprocess{}",msg);
}
}
staticclassBean2implementsProcessor{
publicvoidprocess(Exchangemsg){
LOG.info("Secondprocess{}",msg);
}
}
}
现在Route类更简洁明了，同时处理代码也被重构到了独立的类中。当你需要编写很复杂的Route来实现业务逻辑时，这种方式能够帮助你更好的组织和测试你的代码。它能够让你构建像”乐高“积木那样可复用的POJObean。Camel的registryspace同样可用于其他很多用途，比如你可以自定义许多具有附加功能的endpoint组件或者注册一些信息，更或者替换线程池实现策略之内的事情。
上述Route示例是用所谓的JavaDSL来构成的，它的可读性较高，你可以用IDE提供的支持查看所有可用于Route的方法。
我希望这篇文章能够帮助你跳过Camel的摸索阶段。