日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

Apache Camel是一個非常實用的規(guī)則引擎庫，能夠用來處理來自于不同源的事件和信息。你可以在使用不同的協(xié)議比如VM，HTTP，FTP，JMS甚至是文件系統(tǒng)中來傳遞消息，并且讓你的操作邏輯和傳遞邏輯保持分離，這能夠讓你更專注于消息的內容。

在這篇文章中，我將提供一個Java語言（非Groovy）的Apache Camel入門演示。

首先創(chuàng)建一個Maven項目的pom.xml。

 
 
 

  
  
  
 
  
  
  

  
  
  
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"> 
  
  
  
 
  
  
  
4.0.0 
  
  
  
camel-spring-demo 
  
  
  
camel-spring-demo 
  
  
  
1.0-SNAPSHOT 
  
  
  
jar 
  
  
  
 
  
  
  
 
  
  
  
UTF-8 
  
  
  
2.11.1 
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
org.apache.camel 
  
  
  
camel-core 
  
  
  
${camel.version} 
  
  
  
 
  
  
  
 
  
  
  
org.slf4j 
  
  
  
slf4j-simple 
  
  
  
1.7.5 
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
 
 
 
 

在這里我們只用到了camel-core.jar包，實際上它提供了許多你可能用到的實用組件。出于日志記錄的目的，我使用了slf4j-simple來作為日志記錄的實現，從而我們可以從控制臺上看到輸出。

接下來我們只需要構造一個路由類。路由就好比是Camel中怎樣將消息從一端傳遞到另一端的一個指令定義。我們將會創(chuàng)建src/main/java /camelcoredemo/TimerRouteBuilder.java文件，每隔一秒向處理器發(fā)送一個消息，簡單打印出來。

 
 
 

  
  
  
package camelcoredemo;  
  
  
  
 
  
  
  
import org.slf4j.*;  
  
  
  
import org.apache.camel.*;  
  
  
  
import org.apache.camel.builder.*;  
  
  
  
 
  
  
  
public class TimerRouteBuilder extends RouteBuilder {  
  
  
  
static Logger LOG = LoggerFactory.getLogger(TimerRouteBuilder.class);  
  
  
  
public void configure() {  
  
  
  
from("timer://timer1?period=1000")  
  
  
  
.process(new Processor() {  
  
  
  
public void process(Exchange msg) {  
  
  
  
LOG.info("Processing {}", msg);  
  
  
  
}  
  
  
  
});  
  
  
  
}  
  
  
  
} 
 
 
 

以上就是這個示例的全部所需，現在編譯運行。

 
 
 

  
  
  
bash> mvn compile  
  
  
  
bash> mvn exec:java -Dexec.mainClass=org.apache.camel.main.Main -Dexec.args='-r camelcoredemo.TimerRouteBuilder' 
 
 
 

注意，這里我們并沒有編寫Java類的main入口，我們只是將RouteBuilder的類名當作參數簡單傳遞給 org.apache.camel.main.Main,然后它將自動加載路由。

控制CamelContext

當啟動Camel后，它會創(chuàng)建一個CamelContext對象，該對象擁有了很多關于如何運行Camel的信息，還包含我們所創(chuàng)建的Route的定義?，F在如果你想通過CamelContext獲得更多的控制，那么你需要編寫自己的主類代碼。我在這舉個簡單的例子。

 
 
 

  
  
  
package camelcoredemo;  
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
import org.slf4j.*;  
  
  
  
import org.apache.camel.*;  
  
  
  
import org.apache.camel.impl.*;  
  
  
  
import org.apache.camel.builder.*;  
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
public class TimerMain {  
  
  
  
static Logger LOG = LoggerFactory.getLogger(TimerMain.class);  
  
  
  
public static void main(String[] args) throws Exception {  
  
  
  
new TimerMain().run();  
  
  
  
}  
  
  
  
void run() throws Exception {  
  
  
  
final CamelContext camelContext = new DefaultCamelContext();  
  
  
  
camelContext.addRoutes(createRouteBuilder());  
  
  
  
camelContext.setTracing(true);  
  
  
  
camelContext.start();  
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
Runtime.getRuntime().addShutdownHook(new Thread() {  
  
  
  
public void run() {  
  
  
  
try {  
  
  
  
camelContext.stop();  
  
  
  
} catch (Exception e) {  
  
  
  
throw new RuntimeException(e);  
  
  
  
}  
  
  
  
}  
  
  
  
});  
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
 
  
  
  
waitForStop();  
  
  
  
}  
  
  
  
RouteBuilder createRouteBuilder() {  
  
  
  
return new TimerRouteBuilder();  
  
  
  
}  
  
  
  
void waitForStop() {  
  
  
  
while (true) {  
  
  
  
try {  
  
  
  
Thread.sleep(Long.MAX_VALUE);  
  
  
  
} catch (InterruptedException e) {  
  
  
  
break;  
  
  
  
}  
  
  
  
}  
  
  
  
}  
  
  
  
} 
 
 
 

可以看到，我們在createRouteBuilder()方法中重用了已有的TimerRouteBuilder類?，F在我們的主類對在什么時候創(chuàng)建、啟動、停止CamelContext有了完全的控制。context(camelContext)對象允許你全局性地控制如何配置Camel，而不是在 Route級。它的JavaDoc鏈接給出了所有setter方法，你可以研究下它都可以做些什么。

注意到一點，我們也需要在我們的主類中提供少量設置代碼。首先我們需要處理優(yōu)雅關閉的問題，所以我們增加了一個Java關閉回調函數去調用context 的stop()方法。其次在context已經啟動后，我們需要增加一個線程阻塞。如果在啟動后你不阻塞你的主線程，那么它會在啟動后就簡單的退出了，那就沒啥用了。你會把Camel一直作為一個服務(就像一個服務器)運行，直至你按下CTRL+C鍵去終止該進程。

#p#

改善啟動CamelContext的主類

如果你不想像上面例子一樣過多的處理主類設置代碼，那么你可以簡單地繼承由camel-core提供的 org.apache.camel.main.Main類作為代替。通過利用這個類，你不僅可以讓你的context自動設置，還可以獲得所有附加的命令行特性，比如控制進程運行多久，啟用追蹤，加載自定義route類等等。

重構了下上一個例子，代碼如下：

 
 
 

  
  
  
package camelcoredemo;  
  
  
  
 
  
  
  
import org.slf4j.*;  
  
  
  
import org.apache.camel.builder.*;  
  
  
  
import org.apache.camel.main.Main;  
  
  
  
 
  
  
  
public class TimerMain2 extends Main {  
  
  
  
static Logger LOG = LoggerFactory.getLogger(TimerMain2.class);  
  
  
  
public static void main(String[] args) throws Exception {  
  
  
  
TimerMain2 main = new TimerMain2();  
  
  
  
main.enableHangupSupport();  
  
  
  
main.addRouteBuilder(createRouteBuilder());  
  
  
  
main.run(args);  
  
  
  
}  
  
  
  
static RouteBuilder createRouteBuilder() {  
  
  
  
return new TimerRouteBuilder();  
  
  
  
}  
  
  
  
} 
 
 
 

現在TimerMain2類的代碼比之前的更少了，你可以試試看，它應該和之前的功能一樣。

 
 
 

  
  
  
bash> mvn compile  
  
  
  
bash> mvn exec:java -Dexec.mainClass=camelcoredemo.TimerMain2 -Dexec.args='-t' 
 
 
 

注意到我們給出-t選項后，會轉儲Route追蹤。使用-h會看到所有可用的選項。

用Camel的注冊機制添加bean

在之前的TimerRouteBuilder例子中，我們已經在代碼中創(chuàng)建了一個匿名Processor。現在如果你想將幾個不同的Processor放在一起，那么使用Camel的注冊機制添加bean的方式將能更好的減少代碼混亂。Camel允許你通過將processing當作bean注入到它的 registry space，然后你只要把它們當作bean組件來進行調用。如下是我的重構代碼:

 
 
 

  
  
  
package camelcoredemo;  
  
  
  
 
  
  
  
import org.slf4j.*;  
  
  
  
import org.apache.camel.*;  
  
  
  
import org.apache.camel.builder.*;  
  
  
  
import org.apache.camel.main.Main;  
  
  
  
 
  
  
  
public class TimerBeansMain extends Main {  
  
  
  
static Logger LOG = LoggerFactory.getLogger(TimerBeansMain.class);  
  
  
  
public static void main(String[] args) throws Exception {  
  
  
  
TimerBeansMain main = new TimerBeansMain();  
  
  
  
main.enableHangupSupport();  
  
  
  
main.bind("processByBean1", new Bean1());  
  
  
  
main.bind("processAgainByBean2", new Bean2());  
  
  
  
main.addRouteBuilder(createRouteBuilder());  
  
  
  
main.run(args);  
  
  
  
}  
  
  
  
static RouteBuilder createRouteBuilder() {  
  
  
  
return new RouteBuilder() {  
  
  
  
public void configure() {  
  
  
  
from("timer://timer1?period=1000")  
  
  
  
.to("bean:processByBean1")  
  
  
  
.to("bean:processAgainByBean2");  
  
  
  
}  
  
  
  
};  
  
  
  
}  
  
  
  
 
  
  
  
// Processor beans  
  
  
  
static class Bean1 implements Processor {  
  
  
  
public void process(Exchange msg) {  
  
  
  
LOG.info("First process {}", msg);  
  
  
  
}  
  
  
  
}  
  
  
  
static class Bean2 implements Processor {  
  
  
  
public void process(Exchange msg) {  
  
  
  
LOG.info("Second process {}", msg);  
  
  
  
}  
  
  
  
}  
  
  
  
} 
 
 
 

現在Route類更簡潔明了，同時處理代碼也被重構到了獨立的類中。當你需要編寫很復雜的Route來實現業(yè)務邏輯時，這種方式能夠幫助你更好的組織和測試你的代碼。它能夠讓你構建像”樂高“積木那樣可復用的POJO bean。Camel的registry space同樣可用于其他很多用途，比如你可以自定義許多具有附加功能的endpoint組件或者注冊一些信息，更或者替換線程池實現策略之內的事情。

上述Route示例是用所謂的Java DSL來構成的，它的可讀性較高，你可以用IDE提供的支持查看所有可用于Route的方法。

我希望這篇文章能夠幫助你跳過Camel的摸索階段。除了已經提到的事件組件之外，camel還提供了如下組件：

• bean component
• browse component
• dataset component
• direct component
• file component
• log component
• mock component
• properties component
• seda component
• test component
• timer component
• stub component
• validator component
• vm component
• xslt component

Have fun!

英文原文：Getting Started with Apache Camel using Java

譯文鏈接：http://www.oschina.net/translate/getting-started-with-apache-camel-using

當前標題：針對Java開發(fā)者的ApacheCamel入門指南
文章URL：http://m.5511xx.com/article/copdphd.html