一区二区三区视频,WWW:久久久久久久久久久

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案

針對(duì)Java開發(fā)者的ApacheCamel入門指南

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

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

首先創(chuàng)建一個(gè)Maven項(xiàng)目的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包，實(shí)際上它提供了許多你可能用到的實(shí)用組件。出于日志記錄的目的，我使用了slf4j-simple來(lái)作為日志記錄的實(shí)現(xiàn)，從而我們可以從控制臺(tái)上看到輸出。

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

 
 
 
  
  
  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);  
  
  
  }  
  
  
  });  
  
  
  }  
  
  
  }

以上就是這個(gè)示例的全部所需，現(xiàn)在編譯運(yùn)行。

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

注意，這里我們并沒(méi)有編寫Java類的main入口，我們只是將RouteBuilder的類名當(dāng)作參數(shù)簡(jiǎn)單傳遞給 org.apache.camel.main.Main,然后它將自動(dòng)加載路由。

控制CamelContext

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

 
 
 
  
  
  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;  
  
  
  }  
  
  
  }  
  
  
  }  
  
  
  }

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

注意到一點(diǎn)，我們也需要在我們的主類中提供少量設(shè)置代碼。首先我們需要處理優(yōu)雅關(guān)閉的問(wèn)題，所以我們?cè)黾恿艘粋€(gè)Java關(guān)閉回調(diào)函數(shù)去調(diào)用context 的stop()方法。其次在context已經(jīng)啟動(dòng)后，我們需要增加一個(gè)線程阻塞。如果在啟動(dòng)后你不阻塞你的主線程，那么它會(huì)在啟動(dòng)后就簡(jiǎn)單的退出了，那就沒(méi)啥用了。你會(huì)把Camel一直作為一個(gè)服務(wù)(就像一個(gè)服務(wù)器)運(yùn)行，直至你按下CTRL+C鍵去終止該進(jìn)程。

#p#

改善啟動(dòng)CamelContext的主類

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

重構(gòu)了下上一個(gè)例子，代碼如下：

 
 
 
  
  
  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();  
  
  
  }  
  
  
  }

現(xiàn)在TimerMain2類的代碼比之前的更少了，你可以試試看，它應(yīng)該和之前的功能一樣。

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

注意到我們給出-t選項(xiàng)后，會(huì)轉(zhuǎn)儲(chǔ)Route追蹤。使用-h會(huì)看到所有可用的選項(xiàng)。

用Camel的注冊(cè)機(jī)制添加bean

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

 
 
 
  
  
  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);  
  
  
  }  
  
  
  }  
  
  
  }

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

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

我希望這篇文章能夠幫助你跳過(guò)Camel的摸索階段。除了已經(jīng)提到的事件組件之外，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

文章題目：針對(duì)Java開發(fā)者的ApacheCamel入門指南
文章來(lái)源：http://www.dlmjj.cn/article/copdphd.html

日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

新聞中心

其他資訊