apache camel
Apache Camel是著名的企业集成模式的开源实现。 Camel是一个路由和中介引擎,可帮助开发人员以各种特定于域的语言(DSL)(例如Java,Spring / XML,scala等)创建路由和中介规则。
骆驼用途广泛
Camel使用URI来支持大量的传输和消息传递模型,例如HTTP,JMS,JBI,Mina,SCA,CXF,它还与外部组件和数据格式很好地兼容。 要了解Camel的多功能性,您可以在下面的链接中浏览其支持的组件和URI列表。 http://camel.apache.org/components.html
骆驼易于使用
骆驼允许我们使用同一组API来创建路由并在各个组件之间传递消息。 这使得它非常容易使用
单元测试骆驼轻而易举
单元测试对于编写任何质量代码至关重要。 骆驼使软件开发的基础变得非常容易。 它提供了许多现成的组件,例如CamelContextSupport,camel-guice,camel-test-blueprint,可轻松测试代码。 在以后的文章中会更多。
骆驼的术语/类/接口
端点是交换消息的地方。 它可能是指地址,POJO,电子邮件地址,Web服务uri,队列uri,文件等。在骆驼中,终结点是由实现的终结点接口实现的。 端点被称为路由的东西包装。
CamelContext是所有骆驼应用程序的核心,它代表Camel运行时系统。
- 创建camelcontext。
- 添加端点或组件。
- 添加路由以连接端点。
- 调用camelcontext.start()-这将启动所有负责在端点中接收,发送和处理消息的骆驼内部线程。
- 最后,在交换和处理所有消息时调用camelcontext.stop()。 这将优雅地停止所有骆驼内部线程和端点。
这是围绕CamelContext对象的薄包装,它负责将交换或消息发送到端点。
组件实际上是一个端点工厂。 由于骆驼支持许多不同种类的资源,因此这些资源中的每一个都有不同种类的端点。 在实际情况下,应用程序不要直接使用组件创建端点。 相反,CamelContext决定实例化哪个组件,然后使用该组件实例创建端点。 因此,在应用程序中,我们将拥有。 CamelContext.getEndpoint(“ pop3://john.smith@mailserv.example.com?password = myPassword”); 现在,在这种情况下,pop3是组件的名称。 CamelContext将所有组件名称与组件类映射,并使用其实例化实例的名称。 一旦拥有了组件的句柄,它就会通过调用实例化端点。 Component.createInstance()方法。
消息表示单个具体消息,即请求,答复或异常。 所有具体的消息类都会影响消息接口,例如JmsMessage类。
交换是消息的容器。 当消费者在路由过程中收到消息时创建。
处理器接口表示处理消息的类。 它包含单个方法public void process(Exchange交换)引发异常。应用程序开发人员可以实现此接口,以便在消费者收到消息时对消息执行业务逻辑。
路由是通过过滤器或路由器通过任意类型的决策,将消息从源逐步移动到目的地。 它们是借助DSL(特定于域的语言)进行配置的。 Java DSL是通过实现routebuilder接口创建的。 它具有一个称为configure()的方法,该方法定义了消息的整个路由。 也可以使用spring通过xml文件配置路由。
骆驼代码的一个小例子。
让我们以一个小例子来说明一下Camel可以做什么。 在此示例中,我们将文件夹中存在的文件组移动到另一个文件夹。 在此过程中,我们将执行以下操作
- 签出Camel的依赖项。
- 创建一个简单的RouterBuilder。
- 在spring文件中注册CamelContext。
- 在CamelContext Bean中注入routerbuilder
- 通过启动Camelcontext来执行该类,并在执行完成后最终将其停止。
1.依赖关系 –在pom.xml中添加以下依赖关系
<dependency><groupId>org.apache.camel</groupId><artifactId>camel-core</artifactId><version>${camel-version}</version></dependency><dependency><groupId>org.apache.camel</groupId><artifactId>camel-spring</artifactId><version>${camel-version}</version></dependency><dependency><groupId>org.apache.camel</groupId><artifactId>camel-aws</artifactId><version>${camel-version}</version></dependency>
2.创建RouterBuilder –可以通过扩展org.apache.camel.builder.RouterBuilder类并覆盖configure()方法来创建RouterBuilder。 这是一个例子
import org.apache.camel.builder.RouteBuilder;/*** Created by IntelliJ IDEA.* User: Niraj Singh* Date: 7/28/13* Time: 10:29 AM* To change this template use File | Settings | File Templates.*/
public class MyFirstRouterBuilder extends RouteBuilder {@Overridepublic void configure() throws Exception {try{from( "file:d:/vids").to("file:d:/temp");}catch(Exception e){}}
}
- From()是源端点,包含骆驼将要轮询的文件或目录的uri。
- to()代表目标端点,并包含目标文件或目录的名称。
- 文件组件uri的格式为“ file:// nameOfFileOrDirectory ”。
3.在Spring中注册CamelContext并在Spring中注入RouterBuilder。
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"><camelContext id="sqsContext" xmlns="http://camel.apache.org/schema/spring"><routeBuilder ref="myFirstRouter" /></camelContext><bean id="myFirstRouter" class="com.aranin.aws.sqs.MyFirstRouterBuilder"/></beans>
4.启动骆驼上下文并执行代码,然后停止骆驼上下文。
import org.apache.camel.CamelContext;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;/*** Created by IntelliJ IDEA.* User: Niraj Singh* Date: 4/16/13* Time: 11:21 AM* To change this template use File | Settings | File Templates.*/
public class CamelHello {public static void main(String args[]) throws Exception {try {ApplicationContext springcontext = new FileSystemXmlApplicationContext("D:/samayik/awsdemo/src/main/resources/hellocamel.xml");CamelContext context = springcontext.getBean("firstCamelContext", CamelContext.class);context.start();Thread.sleep(10000);context.stop();} catch ( Exception e ) {System.out.println(e);}}
}
如果您运行此类,则首先我们从spring config文件中加载camelcontext。 在其中注入路由器生成器。 上下文启动后,然后将源目录中的所有文件复制到目标目录。 复制完所有文件后,尝试将新文件复制到源目录,在这种情况下,上下文运行10000 ms之前,该文件也将复制到目标文件。
我没有更多关于骆驼的高级教程。 也许您会发现它们很有用。 参考部分列出了这些链接。
参考资料
- http://camel.apache.org/
- http://camel.apache.org/enterprise-integration-patterns.html
- http://architects.dzone.com/articles/enterprise-integration
- http://weblog4j.com/2013/05/14/amazon-sqs-listening-to-sqs-using-apache-camel-the-spring-dsl-way/
- http://weblog4j.com/2013/04/17/amazon-sqs-listening-to-amazon-sqs-queue-using-apache-came l /
就这些了。 尽管没有人会发表评论,但是我还是要坚持不懈,如果您喜欢本教程,仍然请大家排一两行。
温暖的问候
尼拉吉
翻译自: https://www.javacodegeeks.com/2013/08/introduction-to-apache-camel.html
apache camel