Apache Camel

Apache Camel框架入门示例分类：Camel2012-02-03 15:42 8527人阅读评论(6) 收藏举报apache框架exceptionexchangefilewebserviceApache Camel是Apache基金会下的一个开源项目,它是一个基于规则路由和处理的引擎，提供企业集成模式的Java对象的实现，通过应用程序接口或称为陈述式的Java领域特定语言(DSL)来配置路由和处理的规则。

其核心的思想就是从一个from源头得到数据,通过processor处理,再发到一个to目的的.这个from和to可以是我们在项目集成中经常碰到的类型:一个FTP文件夹中的文件,一个MQ的queue,一个HTTP request/response,一个webservice等等.Camel可以很容易集成到standalone的应用,在容器中运行的Web应用,以及和Spring一起集成.下面用一个示例,介绍怎么开发一个最简单的Camel应用.1,从/download.html下载Jar包.在本文写作的时候最新版本是2.9. 本文用的是2.7,从2.7开始要求需要JRE1.6的环境.下载的zip包含了Camel各种特性要用到的jar包.在本文入门示例用到的Jar包只需要:camel-core-2.7.5.jar,commons-management-1.0.jar,slf4j-api-1.6.1.jar.2,新建一个Eclipse工程,将上面列出的jar包设定到工程的Classpath.新建一个如下的类:运行后完成的工作是将d:/temp/inbox/下的所有文件移到d:/temp/outbox [java]view plaincopy1.public class FileMoveWithCamel {2.public static void main(String args[]) throws Exception {3. CamelContext context = new DefaultCamelContext();4. context.addRoutes(new RouteBuilder() {5.public void configure() {6.//from("file:d:/temp/inbox?noop=true").to("file:d:/temp/outbox");7. from("file:d:/temp/inbox/?delay=30000").to("file:d:/temp/outbox");8. }9. });10. context.start();11.boolean loop =true;12.while(loop){13. Thread.sleep(25000);14. }15. context.stop();16. }17.}上面的例子体现了一个最简单的路由功能,比如d:/temp/inbox/是某一个系统FTP到Camel 所在的系统的一个接收目录.d:/temp/outbox为Camel要发送的另一个系统的接收目录.from/to可以是如下别的形式,读者是否可以看出Camel是可以用于系统集成中做路由,流程控制一个非常好的框架了呢?from("file:d:/temp/inbox/?delay=30000").to("jms:queue:order");//delay=30000是每隔30秒轮询一次文件夹中是否有文件.3,再给出一个从from到to有中间流程process处理的例子:[java]view plaincopy1.public class FileProcessWithCamel {2.public static void main(String args[]) throws Exception {3. CamelContext context = new DefaultCamelContext();4. context.addRoutes(new RouteBuilder() {5.6.public void configure() {7. FileConvertProcessor processor = new FileConvertProcessor();8. from("file:d:/temp/inbox?noop=true").process(processor).to("file:d:/temp/outbox");9. }10. });11.12. context.start();13.boolean loop =true;14.while(loop){15. Thread.sleep(25000);16. }17. context.stop();18. }19.}这里的处理只是简单的把接收到的文件多行转成一行[java]view plaincopy1.public class FileConvertProcessor implements Processor{2.@Override3.public void process(Exchange exchange) throws Exception {4.try {5. InputStream body = exchange.getIn().getBody(InputStream.class);6. BufferedReader in = new BufferedReader(new InputStreamReader(body));7. StringBuffer strbf = new StringBuffer("");8. String str = null;9. str = in.readLine();10.while (str != null) {11. System.out.println(str);12. strbf.append(str + " ");13. str = in.readLine();14. }15. exchange.getOut().setHeader(Exchange.FILE_NAME, "converted.txt");16.// set the output to the file17. exchange.getOut().setBody(strbf.toString());18. } catch (IOException e) {19. e.printStackTrace();20. }21. }22.}在Eclipse里运行的时候,Camel默认不会把log信息打印到控制台,这样出错的话，异常是看不到的,需要把log4j配置到项目中.[java]view plaincopy1.log4j.appender.stdout = org.apache.log4j.ConsoleAppender2.log4j.appender.stdout.Target = System.outyout = org.apache.log4j.PatternLayoutyout.ConversionPattern = %-5p %d [%t] %c: %m%n5.log4j.rootLogger = debug,s~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~Apache Camel 框架集成SpringApache Camel提供了和Spring的集成,通过Spring容器(ApplicationContext)来管理Camel 的CamelContext,这样的话,就不需要写代码来控制CamelContext的初始化,启动和停止了.Camel会随着Spring的启动而启动起来.本文将Apache Camel 框架入门示例(/kkdelta/article/details/7231640)中的例子集成到Spring 中,下面简单介绍一下集成的基本步骤.1,新建一个Eclipse 工程,将Spring3的jar 包,和Camel 的jar 包配置到工程的classpath. 2,Route 类要继承RouteBuilde,如下1 public class FileProcessWithCamelSpring extends RouteBuilder {2 @Override3 public void configure() throws Exception {4 FileConvertProcessor processor = new FileConvertProcessor();5 from("file:d:/temp/inbox?delay=30000").process(processor).to ("file:d:/temp/outbox");6}7 }3,Processor 仍然和和入门示例的代码相同. 01 public class FileConvertProcessor implements Processor{02 @Override03 public void process(Exchange exchange) throws Exception { 04 try {05 InputStream body = exchange.getIn().getBody(InputStream.class);06 BufferedReader in = new BufferedReader(new InputStreamReader(body));07 StringBuffer strbf = new StringBuffer("");08 String str = null;09 str = in.readLine();10 while (str != null) {11 System.out.println(str);12 strbf.append(str + " ");13 str = in.readLine();14 }15 exchange.getOut().setHeader(Exchange.FILE_NAME, "conve rted.txt");16 // set the output to the file17 exchange.getOut().setBody(strbf.toString());18 } catch (IOException e) {19 e.printStackTrace();20 }21 }2223 }4,创建一个Spring的配置文件如下:注意要将camel的xmlns加入文件中01 <?xml version="1.0" encoding="UTF-8"?>02 <beans xmlns="/schema/beans"03 xmlns:xsi="/2001/XMLSchema-instance"04 xmlns:camel="/schema/spring"0 5 xsi:schemaLocation="/schema/bean s /schema/beans/spring-beans-3.0.xsd0 6 /schema/spring/schema/spring/camel-spring.xsd"07 default-autowire="byName" default-init-method="init">0 8 <camelContext id="testCamelContext" xmlns="http://camel.apache. org/schema/spring">09 <package>com.test.camel</package>10 </camelContext>11 </beans>5,启动Spring容器,Camel会自动启动,不用像入门示例那样CamelContext context = new DefaultCamelContext(), context.addRoutes(..); context.start();ApplicationContext ac = newClassPathXmlApplicationContext("config/cameltest.xml");while (true) {Thread.sleep(2000);}可见,Camel可以很容易的和Spring集成.Camel还提供了"Spring DSL"来在XML中配置Route规则,不需要用JAVA类(如上面的FileProcessWithCamelSpring )来实现route.查看源码打印?01 <?xml version="1.0" encoding="UTF-8"?>02 <beans xmlns="/schema/beans"03 xmlns:xsi="/2001/XMLSchema-instance"04 xmlns:camel="/schema/spring"0 5 xsi:schemaLocation="/schema/bean s /schema/beans/spring-beans-3.0.xsd0 6 /schema/spring/schema/spring/camel-spring.xsd"07 default-autowire="byName" default-init-method="init">0 8 <bean id="fileConverter" class="com.test.camel.FileConvertProc essor"/>0 9 <camelContext id="testCamelContext" xmlns="http://camel.apache. org/schema/spring">10 <route>11 <from uri="file:d:/temp/inbox?delay=30000"/>12 <process ref="fileConverter"/>13 <to uri="file:d:/temp/outbox"/>14 </route>15 </camelContext>1617 </beans>与第五步一样启动Spring容器,Camel会每隔30秒轮询一下看d:/temp/inbox是否有文件,有的话则进行处理.WWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWW WWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWApache Camel框架之FTP路由您的评价: 收藏该经验在做项目集成类型的项目的时候,经常会有这样的需求,用户或者别的系统将文件传到一个FTP server,然后系统从FTP server取文件进行相应的处理.本文简单的介绍和示例一个用Camel实现这样的需求:监听FTPserver是否有文件,取到文件做相应处理传到另外一个系统.1,搭建一个FTP server,从/projects/filezilla/files/ 下载FileZilla安装,设置一个用户yorker/123456.可以参照这个网址/filezilla-server.htm2,在Camel里实现路由:查看源码打印?01 CamelContext context = new DefaultCamelContext();02 context.addRoutes(new RouteBuilder() {03 public void configure() {0 4 from("ftp://localhost/inbox?username=yorker&password=12345 6").to(05 "file:d:/temp/outbox");06 }07 });08 context.start();09 boolean loop = true;10 while (loop) {11 Thread.sleep(25000);12 }1314 context.stop();这里主要是为了示例Camel对FTP的支持,没有加入processor的处理,downstream system 也仅仅是用放到本地文件夹做示例.不过真正做项目的时候,在to里可以是别的类型,如JMS 的queue,别的系统的FTB inbound文件夹,Web service等等.如何在流程的中间加入processor 处理可以参见/kkdelta/article/details/7231640WWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWApache Camel 框架之JMS 路由您的评价: 收藏该经验继上次Camel 如何在做项目集成类型的项目中用于从FTP 取文件和传文件之后,我们在系统集成中经常遇到的另一个应用就是将数据通过JMS 传到消息中间件的queue 里,或者从消息中间件的queue 里取消息.本文简单的介绍和示例一个用Camel 实现这样的需求:监听某一个文件夹是否有文件,取到文件后发送到另外一个系统监听的queue.1,因为要用JMS,这里介绍一个open source 的activeMQ,可以从/download.html 下载,下载后解压,bin 目录有一个activemq.bat 文件,在命令行里运行activemq 启动activeMQ,如果能从从浏览器里访问http://localhost:8161/admin/则activeMQ 成功启动了.2,在Camel 里实现上图所示的路由:JAVA 项目里需要将activeMQ 的jar 包配置到classpath 下,Java 代码如下:01 private static String user = ActiveMQConnection.DEFAULT_USER; 02 private static String password = ActiveMQConnection.DEFAULT_PASSWORD;03 private static String url = ActiveMQConnection.DEFAULT_BROKER_URL; 0405 public static void main(String args[]) throws Exception { 06 CamelContext context = new DefaultCamelContext(); 07 ConnectionFactory connectionFactory =08 new ActiveMQConnectionFactory(user, password, url); 09 context.addComponent("jms",10 JmsComponent.jmsComponentAutoAcknowledge(connectionFactory ));11 System.out.println(url + " " + user + password); 12 context.addRoutes(new RouteBuilder() {13 public void configure() {14 from("file:d:/temp/inbox").to(15 "jms:queue:TOOL.DEFAULT");16 }17 });18 context.start();19 boolean loop = true;20 while (loop) {21 Thread.sleep(25000);22 }2324 context.stop();25 }Camel 会在路由的时候将文件的内容以binary message 发到activeMQ 的名为'TOOL.DEFAULT'的queue .用下面的代码可以从Camel 发送的queue 里取到消息.查看源码打印?01 private static String user = ActiveMQConnection.DEFAULT_USER; 02 private static String password = ActiveMQConnection.DEFAULT_PASSWORD;03 private static String url = ActiveMQConnection.DEFAULT_BROKER_URL; 04 private static boolean transacted;05 private static int ackMode = Session.AUTO_ACKNOWLEDGE;0607 public static void main(String[] args) throws Exception {08 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user, password, url);09 Connection connection = connectionFactory.createConnection(); 10 connection.start();11 Session session = connection.createSession(transacted, ackMode); 12 Destination destination = session.createQueue("TOOL.DEFAULT"); 13 MessageConsumer consumer = session.createConsumer(destination); 14 Message message = consumer.receive(1000);1516 System.out.println("Received: " + message);17 BytesMessage bytesMsg = (BytesMessage) message;18 byte[] bytes = new byte[(int) bytesMsg.getBodyLength()]; 19 bytesMsg.readBytes(bytes);20 System.out.println("contents: " + new String(bytes)); 21 }CCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCCApache Camel 框架之HTTP 路由您的评价: 收藏该经验继介绍完Camel 如何处理FTP,JMS 接口之后,今天介绍一下系统集成的时候经常遇到的另一个接口,HTTP,一个示例需求如下图所示:本文给出一个简单的代码示例如何用Camel 来实现这样一个应用:1,在一个JAVA 类里配置如下路由:这里只示例了HTTP 的部分,其他功能实现可以参见Apache Camel 框架系列的其他博客.01 public class HttpPollWithQuartzCamel {02 public static void main(String args[]) throws Exception { 03 CamelContext context = new DefaultCamelContext();04 context.addRoutes(new RouteBuilder() {05 public void configure() {06 from("quartz://report?cron=10 * * * * ?&stateful=true")07 .to("http://localhost:8080/prjWeb/test.camelreq") 08 .to("file:d:/temp/outbox?fileName=http.csv"); 09 );10 }11 });12 context.start();13 boolean loop = true;14 while (loop) {15 Thread.sleep(25000);16 }17 context.stop();18 }19 }对上面代码的简单解释: from("quartz://report?cron=10 * * * * ?&stateful=true"),配置一个quartz Job,每隔10秒发送一个HTTP request,将收到的内容保存为文件.这里的http url 可以是任何可以访问的http url,如果在http 访问时候需要代理可以这么配置:"?proxyHost=&proxyPort=8080"这个例子需要用到quartz,和httpclient 等jar 包,可以从这里下载:/detail/kkdelta/4051072&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&7针对 Java 开发者的 Apache Camel 入门指南您的评价:收藏该经验Apache Camel是一个非常实用的规则引擎库，能够用来处理来自于不同源的事件和信息。