Camel In Action 读书笔记 (3)

时间 2019-11-10

标签 camel action 读书笔记繁體版

原文原文链接

在第二章开始讲Camel的路由配置以及路由经常使用模式。 <h3>Camel的路由配置有三种方式：</h3> 1.java DSL （纯java方式）建立RouteBuilder <a href="http://static.oschina.net/uploads/img/201306/02141322_TlsL.png"><img style="background-image: none; border-right-width: 0px; padding-left: 0px; padding-right: 0px; display: inline; border-top-width: 0px; border-bottom-width: 0px; border-left-width: 0px; padding-top: 0px" title="image" border="0" alt="image" src="http://static.oschina.net/uploads/img/201306/02141325_BcWq.png" width="414" height="224" /></a> 2.Spring DSL（纯spring方式） <a href="http://static.oschina.net/uploads/img/201306/02141326_P36Q.png"><img style="background-image: none; border-right-width: 0px; padding-left: 0px; padding-right: 0px; display: inline; border-top-width: 0px; border-bottom-width: 0px; border-left-width: 0px; padding-top: 0px" title="image" border="0" alt="image" src="http://static.oschina.net/uploads/img/201306/02141327_epoH.png" width="439" height="123" /></a> 3.定义bean的形式（Java+Spring） <a href="http://static.oschina.net/uploads/img/201306/02141327_AfZO.png"><img style="background-image: none; border-right-width: 0px; padding-left: 0px; padding-right: 0px; display: inline; border-top-width: 0px; border-bottom-width: 0px; border-left-width: 0px; padding-top: 0px" title="image" border="0" alt="image" src="http://static.oschina.net/uploads/img/201306/02141328_Cb1c.png" width="434" height="73" /></a> <h3>路由经常使用模式</h3> <h4>1.Using a content-based router（基于内容的路由）</h4> <a href="http://static.oschina.net/uploads/img/201306/02141329_WHi6.png"><img style="background-image: none; border-bottom: 0px; border-left: 0px; padding-left: 0px; padding-right: 0px; display: inline; border-top: 0px; border-right: 0px; padding-top: 0px" title="image" border="0" alt="image" src="http://static.oschina.net/uploads/img/201306/02141331_q8JC.png" width="547" height="254" /></a> 如上图：路由到下一个节点时须要根据文件类型来判断是xmlOrders仍是csvOrdersks能够经过choice…..when的形式来定义 headerCamel的表达式经常使用的有constant,simple,header,body. from("jms:incomingOrders")       .choice()                                   .when(header("CamelFileName")     .endsWith(".xml"))                   .to("jms:xmlOrders")         .when(header("CamelFileName")     .endsWith(".csv"))                   .to("jms:csvOrders");      <h4>2.Using message filters（消息过滤）</h4> <a href="http://static.oschina.net/uploads/img/201306/02141331_5dM8.png"><img style="background-image: none; border-bottom: 0px; border-left: 0px; padding-left: 0px; padding-right: 0px; display: inline; border-top: 0px; border-right: 0px; padding-top: 0px" title="image" border="0" alt="image" src="http://static.oschina.net/uploads/img/201306/02141333_pQrg.png" width="496" height="159" /></a> 如上图：若是消息(xml)order节点包含test属性则自动过滤掉。经过filter处理，若是是xml形式的消息可用xpath来解析消息 <route>   <from uri="jms:xmlOrders"/>   <filter>     <xpath>/order[not(@test)]</xpath>     <process ref="orderLogger"/>   </filter> </route> <h4>3.Using multicasting（多点广播）</h4> <a href="http://static.oschina.net/uploads/img/201306/02141334_DNiE.png"><img style="background-image: none; border-bottom: 0px; border-left: 0px; padding-left: 0px; padding-right: 0px; display: inline; border-top: 0px; border-right: 0px; padding-top: 0px" title="image" border="0" alt="image" src="http://static.oschina.net/uploads/img/201306/02141335_FVRt.png" width="483" height="164" /></a> 如上图，xmlOrders收到的消息要同时发送到accounting和production两个队列中去。经过multicast()来实现。 ExecutorService executor = Executors.newFixedThreadPool(16); from("jms:xmlOrders")    .multicast().parallelProcessing().executorService(executor)     .to("jms:accounting", "jms:production"); 注：能够不指定线程池，系统默认会建立一个线程池大小为10： from("jms:xmlOrders")     .multicast().parallelProcessing()     .to("jms:accounting", "jms:production"); <h4>4.Using recipient lists（收件人列表模式）</h4> <a href="http://static.oschina.net/uploads/img/201306/02141336_P3Wu.png"><img style="background-image: none; border-bottom: 0px; border-left: 0px; padding-left: 0px; padding-right: 0px; display: inline; border-top: 0px; border-right: 0px; padding-top: 0px" title="image" border="0" alt="image" src="http://static.oschina.net/uploads/img/201306/02141336_hjv7.png" width="457" height="200" /></a> 如上图，根据收件人列表来决定发送到哪些消息队列中去。 from("jms:xmlOrders") .setHeader("customer", xpath("/order/@customer")) .process(new Processor() {     public void process(Exchange exchange) throws Exception {         String recipients = "jms:accounting";         String customer =             exchange.getIn().getHeader("customer", String.class);         if (customer.equals("honda")) {             recipients += ",jms:production";         }         exchange.getIn().setHeader("recipients", recipients);     } }) .recipientList(header("recipients")); recipientList也支持注解的形式： from("jms:xmlOrders").bean(RecipientListBean.class); public class RecipientListBean {     @RecipientList     public String[] route(@XPath("/order/@customer") String customer) {         if (isGoldCustomer(customer)) {             return new String[] {"jms:accounting", "jms:production"};         } else {             return new String[] {"jms:accounting"};         }     }     private boolean isGoldCustomer(String customer) {         return customer.equals("honda");     } } <h4>6.Using the wireTap method（消息监听，复制）</h4> <a href="http://static.oschina.net/uploads/img/201306/02141337_3IY8.png"><img style="background-image: none; border-bottom: 0px; border-left: 0px; padding-left: 0px; padding-right: 0px; display: inline; border-top: 0px; border-right: 0px; padding-top: 0px" title="image" border="0" alt="image" src="http://static.oschina.net/uploads/img/201306/02141338_SxxA.png" width="408" height="196" /></a> 如上图，在消息送到目的地的过程当中对消息复制一份送到Tapdestination. from("jms:incomingOrders") .wireTap("jms:orderAudit") .choice()     .when(header("CamelFileName").endsWith(".xml"))         .to("jms:xmlOrders")     .when(header("CamelFileName").regex("^.*(csv|csl)$"))         .to("jms:csvOrders")     .otherwise()         .to("jms:badOrders");java