Apache Camel提供了和Spring的集成,通过Spring容器(ApplicationContext)来管理Camel的CamelContext,这样的话,就不需要写代码来控制CamelContext的初始化,启动和停止了.Camel会随着Spring的启动而启动起来.
本文将Apache Camel框架入门示例(http://blog.csdn.net/kkdelta/article/details/7231640)中的例子集成到Spring中,下面简单介绍一下集成的基本步骤.
1,新建一个Eclipse工程,将Spring3的jar包,和Camel的jar包配置到工程的classpath.
2,Route类要继承RouteBuilde,如下
- public class FileProcessWithCamelSpring extends RouteBuilder {
- @Override
- public void configure() throws Exception {
- FileConvertProcessor processor = new FileConvertProcessor();
- from("file:d:/temp/inbox?delay=30000").process(processor).to("file:d:/temp/outbox");
- }
- }
3,Processor仍然和和入门示例的代码相同.
- public class FileConvertProcessor implements Processor{
- @Override
- public void process(Exchange exchange) throws Exception {
- try {
- InputStream body = exchange.getIn().getBody(InputStream.class);
- BufferedReader in = new BufferedReader(new InputStreamReader(body));
- StringBuffer strbf = new StringBuffer("");
- String str = null;
- str = in.readLine();
- while (str != null) {
- System.out.println(str);
- strbf.append(str + " ");
- str = in.readLine();
- }
- exchange.getOut().setHeader(Exchange.FILE_NAME, "converted.txt");
-
- exchange.getOut().setBody(strbf.toString());
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
4,创建一个Spring的配置文件如下:注意要将camel的xmlns加入文件中
- <?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:camel="http://camel.apache.org/schema/spring"
- xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"
- default-autowire="byName" default-init-method="init">
- <camelContext id="testCamelContext" xmlns="http://camel.apache.org/schema/spring">
- <package>com.test.camel</package>
- </camelContext>
- </beans>
5,启动Spring容器,Camel会自动启动,不用像入门示例那样CamelContext context = new DefaultCamelContext(), context.addRoutes(..); context.start();
ApplicationContext ac = new ClassPathXmlApplicationContext("config/cameltest.xml");
while (true) {
Thread.sleep(2000);
}
可见,Camel可以很容易的和Spring集成.
Camel还提供了"Spring DSL"来在XML中配置Route规则,不需要用JAVA类(如上面的FileProcessWithCamelSpring )来实现route.
- <?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:camel="http://camel.apache.org/schema/spring"
- xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"
- default-autowire="byName" default-init-method="init">
- <bean id="fileConverter" class="com.test.camel.FileConvertProcessor"/>
- <camelContext id="testCamelContext" xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="file:d:/temp/inbox?delay=30000"/>
- <process ref="fileConverter"/>
- <to uri="file:d:/temp/outbox"/>
- </route>
- </camelContext>
- </beans>
与第五步一样启动Spring容器,Camel会每隔30秒轮询一下看d:/temp/inbox是否有文件,有的话则进行处理.
分享到:
相关推荐
使用 Apache Camel 和 Spring 集成的企业集成模式。 用于使用框架演示 EIP 的域是自行车商店。...6弹簧集成Spring Integration 不支持 CSV 文件,因此我们为此使用 Spring Batch。 一次读取一个交货单记录,将其转
是一个功能强大的开源集成框架,基于流行的Enterprise Integration Patterns和功能强大的bean集成。 介绍 Camel支持创建Enterprise Integration Patterns,以通过基于Spring或Blueprint的Xml Configuration文件,...
该项目演示了 Apache Camel 在 Spring Boot 和 Docker 中的集成功能。 Camel 上下文通过 Camel Spring Boot 组件在 Spring Boot 框架内初始化,它具有两个主要功能:通过 REST 向 Docker 进行代理查询,以及将 ...
是基于已知的Enterprise Integration Patterns和功能强大的bean集成的功能强大的开源集成框架。 介绍 该项目为Apache Camel提供Spring Boot支持。 创建/删除启动器 要为zoot组件创建启动器,请运行以下命令: ./...
是一个强大的开源集成框架,基于流行的Enterprise Integration Patterns和功能强大的bean集成。 介绍 Camel支持创建Enterprise Integration Patterns,以通过基于Spring或Blueprint的Xml Configuration文件,或者...
Apache Camel——主要应用框架,负责所有组件的集成; Spring DSL用于路由配置; Apache CXF作为 WS 实现; ActiveMQ - JMS 代理; Ehcache - Camel 缓存实现; Maven 的生命周期支持; 单元测试( jUnit启动...
中介批处理路由包含用于将批处理原型的中介处理器与 Apache Camel 集成的包装器。调解服务包含消息传递原型使用的中介处理器的 Web 服务包装器。性能监视器包含用于监视、测量和控制消息传递系统的反馈控制框架。...
您会看到Shiro与Spring,Grails,Wicket,Tapestry,Mule,Apache Camel,Vaadin等框架无缝集成。 受支持 Apache Shiro是Apache Software Foundation(Apache软件基金会)的一部分,事实证明该组织的运作符合其社区...
阿帕奇骆驼 是一个强大的开源集成框架,它基于具有强大Bean集成的已知企业集成模式。介绍Camel允许您创建企业集成模式,以通过基于Spring或Blueprint的Xml配置文件或基于Scala DSL,以基于Java的特定于域的语言(或...
Apache Camel — ActiveMQ / RabbitMQ,TCP / HTTP,IMAP / POP3 / SMTP,计时器,ElasticSearch,Spring集成 身份验证和安全性-类型,授权,最佳做法 密码学-编码,加密,散列,混淆算法框架,用法,最佳实践 ...
等成熟的企业集成框架是过度的。 在比我聪明很多的人看来,你应该永远为复杂的问题寻求简单的解决方案,而不是为简单的问题寻求复杂的解决方案。 当这些框架使超级复杂的事情变得更简单而不是简单的用例变得复杂时,...
jun_springcloud: 基础篇:企业级开发组件功能列表(jun_plugin) 【fastdfs-client-java】 【jun_activiti】 【jun_ajax】 【jun_aliyun_sms】 【jun_cron】 【jun_dao_hibernate】 【jun_datasource】 【jun_...