Camel In Action 读书笔记 (４)

时间 2019-11-10

标签 camel action 读书笔记繁體版

原文原文链接

第三章主要讲数据类型转换。 数据类型转换有两种形式的转换： Data format transformation ------  数据格式的转换，好比：csv文件转换成xml. Data type transformation    ------  数据类型的转换，好比：String转换成TextMessage. Camel提供的消息转换有如下几种方式： <table border="0" cellspacing="0" cellpadding="2" width="550"><tbody> <tr> <td valign="top" width="181">Transformation</td> <td valign="top" width="367">Description</td> </tr> <tr> <td valign="top" width="181">在路由中转换</td> <td valign="top" width="367">经过MessageTranslator 或者EnricherEIPS转换</td> </tr> <tr> <td valign="top" width="181">经过components转换</td> <td valign="top" width="367">好比XSLT组件用来转换XML.</td> </tr> <tr> <td valign="top" width="181">经过data formats转换</td> <td valign="top" width="367"> </td> </tr> <tr> <td valign="top" width="181">经过模板转换</td> <td valign="top" width="367">好比Apache Velocity</td> </tr> <tr> <td valign="top" width="181"> Camel’s typeconverter mechanism  转换</td> <td valign="top" width="367">序列化，反序列化</td> </tr> </tbody></table> 具体以下： <h3>Using the Message Translator EIP</h3> <a href="http://static.oschina.net/uploads/img/201306/08160631_wb37.png"><img style="border-bottom: 0px; border-left: 0px; display: inline; border-top: 0px; border-right: 0px" title="image" border="0" alt="image" src="http://static.oschina.net/uploads/img/201306/08160632_DDu8.png" width="461" height="113" /></a> Camel提供了三种方式： ■ Using a Processor Processor 接口提供了方法：public void process(Exchange exchange) throws Exception; ■ Using beans 经过自定义bean转换 ■ Using <transform> transform是DSL中的一个方法， from("direct:start") .transform(body().regexReplaceAll("\n", " ")) .to("mock:result");   <h3>Using the Content Enricher EIP</h3> Enricher EIP是说作消息转换时，消息自己数据时不够的还须要请求另外一个资源以下图： <a href="http://static.oschina.net/uploads/img/201306/08160632_uXNZ.png"><img style="border-bottom: 0px; border-left: 0px; display: inline; border-top: 0px; border-right: 0px" title="image" border="0" alt="image" src="http://static.oschina.net/uploads/img/201306/08160632_weHR.png" width="490" height="152" /></a> Enricher EIP 有两种模式： pollEnrich -- 做为一个消费者来获取第三方消息来转换消息好比 JMS，文件系统。 enrich      -- 做为一个生产者数据发送到第三方接受返回来转换消息。好比 HTTP，WebService。 这两种模式都要实现AggregationStrategy接口。 from("quartz://report?cron=0+0+6+*+*+?") .to("<a href="http://riders.com/orders/cmd=received")">http://riders.com/orders/cmd=received")</a> .process(new OrderToCSVProcessor()) .pollEnrich("ftp://riders.com/orders/?username=rider&password=secret", new AggregationStrategy() { public Exchange aggregate(Exchange oldExchange, Exchange newExchange) { if (newExchange == null) { return oldExchange; } String http = oldExchange.getIn() .getBody(String.class); String ftp = newExchange.getIn() .getBody(String.class); String body = http + "\n" + ftp; oldExchange.getIn().setBody(body); return oldExchange; } }) .to("file://riders/orders"); <h3>Transforming XML</h3> XML的转换主要有两种形式： 1.XSLT格式化 from("file://rider/inbox") .to("xslt://camelinaction/transform.xsl") .to("activemq:queue:transformed") 2.XML与JAVA对象的序列化和反序列化 提供了两个方法：marshal/unmarshal a)XSTREAM的形式 <route> <from uri="direct:foo"/> <marshal><xstream/></marshal> <to uri="activemq:queue:foo"/> </route> b)JAXB的形式 <camelContext id="camel" xmlns="<a href="http://camel.apache.org/schema/spring"">http://camel.apache.org/schema/spring"</a>> <dataFormats> <jaxb id="jaxb" contextPath="camelinaction"/> </dataFormats> <route> <from uri="direct:order"/> <marshal ref="jaxb"/> <to uri="activemq:queue:order"/> </route> <route> <from uri="activemq:queue:order"/> <unmarshal ref="jaxb"/> <to uri="direct:doSomething"/> </route> </camelContext> 注：Camel 还提供了csv和json的数据格式化，若有兴趣请看原文。 <h3>Writing your own data format</h3> 咱们能够自定义数据格式化，实现接口： org.apache.camel.spi.DataFormat 最后讲下 <h3>Using Camel type converters</h3> 咱们常常取消息时会用 String custom = exchange.getIn().getBody(String.class); 这就是type converters的一种形式，TypeConverter 须要注册到TypeConverterRegistry 中去。 TypeConverter还有以下的使用方法： from("file://riders/inbox") .convertBodyTo(String.class) .to("activemq:queue:inbox"); 咱们也能够自定义type converter，经过注解的形式@Converter。spring