使用Mule ESB与Groovy编排RESTful服务【转】很适合我们当前的架构

http://www.infoq.com/cn/articles/restful-services-mule 

在过去几年中,REST风格的软件架构获得了越来越多的认可,这主要是因为它减少了系统对动件的需求、同时使系统耦合性更低,弹性更好。 
目前越来越多的REST资源出现在企业应用中,因此对这些资源进行编排就显得非常重要了。比方说,典型的业务活动就包含了资源的创建,然后是资源的查找及其他资源的创建等。 

本质上来说,与RESTful服务的交互是相当简单的:需要构造并发送适当的请求(请求头和请求体),然后分析返回的响应(响应头和响应体)。完成这个处 理并不需要什么特别的工具或是框架,只要有一个好用的HTTP客户端程序库就足够了。除此之外,由于RESTful交互过程中所涉及到的不同实体是由所谓 的微格式定义的,因此能够轻松解析或是输出这些实体的能力就显得非常重要了。 

编排与多个资源的交互是个棘手的问题。我们需要定义编排、处理错误并不断尝试,同时系统必须能够在压力下表现良好。作为一个集成框架,Mule提供了我们所需的一切。 

来考虑一个例子吧,某商业系统对新订单的处理需要如下编排: 

通过向服务发送一个XML实体来创建一个新订单。 
寻找新创建的订单资源并从中提取出确认信息。 
根据确认信息并通过邮件网关向客户发送一条确认消息。 
我们将在本文详细分析上面每一步的交互过程,同时还会介绍为了获得上述交互所需的Mule动件和Groovy特性。 

总体的编排包含了一系列通过特定路由、过滤器以及内存消息队列(aka VM队列)连接起来的Mule服务。 最近InfoQ上的这篇文章介绍了Mule中的消息路由,大家不妨移步一观。 

Mule对REST的支持 
Mule提供了一种简单而又强大的方式与RESfFul服务交互,那就是Mule RESTPack。 

Mule RESTPack提供了一整套连接器与完整的指南以帮助用户创建新的RESTful应用。在本文撰写之际,该软件包提供了三种传送器,分别基于三种流行的REST框架:Abdera、Jersey及Restlet。这样我们就可以轻松公开新的资源,但如何集成现有的REST资源呢? 

好消息是Mule标准的脚本模块所提供的Groovy支持有助于Mule HTTP传送器的使用,这样我们就可以成功与RESTful服务交互了。 
向Mule发送POST请求 
首先来看看第一个交互。HTTP向特定的资源发送一个XML实体来创建订单,如以下程序片段所示: 

POST /orders HTTP 1.1 
... 
Java代码  收藏代码
  1. <order xmlns='urn:acme:order:3:1'>  
  2.    <customerId>123456</customerId>  
  3.    <productId>P987C</productId>  
  4.    <quantity>2</quantity>  
  5. </order>  

如果成功服务器的响应如下: 

201 Created 
Location: http://acme.com/order/O13579 
... 
<order id='O13579' /> 
在Mule中,我们可以通过一个简单的HTTP输出端点(outbound endpoint)实现该交互。注意到交互本身是通过向订单创建服务发送一个包含请求值(客户与产品ID、数量)的映射而触发的。该服务如下所示: 

Java代码  收藏代码
  1. <service name="OrderCreationService">   
  2.   <inbound>   
  3.     <inbound-endpoint ref="OrderCreationQueue" />   
  4.   </inbound>   
  5.   <outbound>   
  6.     <chaining-router>   
  7.         <http:outbound-endpoint synchronous="true"   
  8.               responseTimeout="15" method="POST"   
  9.               host="${acme.order.hostname}"   
  10.               port="${acme.order.port}" path="orders"   
  11.               user="${acme.order.username}"   
  12.               password="${acme.order.password}"   
  13.               contentType="application/vnd.acme+xml" encoding="UTF-8">   
  14.               <transformers>   
  15.                 <transformer ref="OrderMapToMicroformat" />   
  16.               </transformers>   
  17.               <response-transformers>   
  18.                   <message-properties-transformer>   
  19.                         <add-message-property key="OrderPlaced"   
  20.                             value="#[groovy:message.getStringProperty('http.status','ERR')=='201']" />   
  21.                         <add-message-property   
  22.                             key="OrderResourceLocation"   
  23.                             value="#[groovy:message.getStringProperty('Location','')]" />   
  24.                   </message-properties-transformer>   
  25.                   <object-to-string-transformer />   
  26.               </response-transformers>   
  27.          </http:outbound-endpoint>   
  28.          <outbound-endpoint ref="OrderCreationResultQueue" />   
  29.    </chaining-router>       
  30.   </outbound>   
  31. </service>  

这全是XML,我们来仔细分析一下: 

名为OrderCreationQueue的管道(可以是VM队列或是JMS队列)接收消息。 
接收到的消息被直接传递到另一个路由,该路由会将HTTP POST的结果发送到下一个服务,该服务通过名为OrderCreationResultQueue(异步的VM队列)的管道对调用结果进行分析。 
通过标准的输出端点在Groovy转换器上执行该HTTP POST请求: 
请求订单的微格式是通过一个特定的传送器创建的,下一节将对其进行详细介绍。 
通过一小段脚本将结果代码抽取出来并与期望值进行比对。进行比较的目的在于将后面的服务与纯的HTTP隔离开来:我们所创建的boolean类型的属性OrderPlaced是独立的,其名称与进行的编排密切相关。 
类似的,在更具上下文含义的OrderResourceLocation名字下复制Location头。注意,该头 有可能丢失(在失败的情况下),在这种情况下,我们将其值默认设为空字符串以避免将null属性加到消息中。 
我们使用了一个对象——字符串转换器来“分离”HTTP响应(以流的形式返回)。多亏有了这个转换器,流得到了完全的处理,其内容也通过使用与 HTTP交换相关的编码转换为字符串。当流关闭时,HTTP连接得到了释放;我们不想一直开着它,等待后面的服务从 OrderCreationResultQueue中拿出响应消息。 
Groovy MarkupBuilder的好处 

OrderMapToMicroformat转换器完成了服务中的重头戏,而它是由Groovy的MarkupBuilder实现的。MarkupBuilder API提供了一种自然的方式生成兼容于特定微格式的XML实体: 

Java代码  收藏代码
  1. <scripting:transformer name="OrderMapToMicroformat">   
  2.    <scripting:script engine="groovy"> <![CDATA[   
  3.         def writer = new StringWriter()   
  4.         def xml = new groovy.xml.MarkupBuilder(writer)   
  5.         xml.order(xmlns: 'urn:acme:order:3:1') {   
  6.           customerId(payload.clientId)   
  7.           productId(payload.productCode)   
  8.           quantity(payload.quantity)   
  9.         }   
  10.         result = writer.toString() ]]>   
  11.     </scripting:script>   
  12. </scripting:transformer>  

注意map payload中的值是如何用于组装XML元素的:这里解决了一些不匹配的命名约定(比如将clientId转换为customerId)。 

如你所期望的那样,该转换器产生了如下输入: 

Java代码  收藏代码
  1. <order xmlns='urn:acme:order:3:1'>   
  2.    <customerId>123456</customerId>   
  3.    <productId>P987C</productId>   
  4.    <quantity>2</quantity>   
  5. </order>   

除了正确的内容类型外都是订单的RESTful服务用于创建新资源所需的内容。 

分析 

现在我们来看一下负责异步分析订单创建结果并决定是否需要进一步进行编排的服务: 

Java代码  收藏代码
  1. <service name="OrderCreationResultProcessor">   
  2.   <inbound>   
  3.     <inbound-endpoint ref="OrderCreationResultQueue" />   
  4.      <selective-consumer-router>   
  5.         <message-property-filter pattern="OrderPlaced=true" />   
  6.      </selective-consumer-router>   
  7.      <logging-catch-all-strategy />   
  8.   </inbound>   
  9.   <outbound>   
  10.     <pass-through-router>   
  11.       <outbound-endpoint ref="SuccessfulOrderQueue" />   
  12.     </pass-through-router>   
  13.   </outbound>   
  14. </service>   

我们使用的选择性消费者(selective consumer)所接收的消息中一定要包含订单成功处理的头信息。如果该头信息为true,那就通过一个名为SuccessfulOrderQueue 的内存队列将该消息路由给第三个(也是最终的)服务,该服务会处理订单成功创建的消息。注意在这个例子中我们只是简单地将错误消息以日志的方式记录下来, 但在实际应用中需要将错误消息发送给专门的队列以进行后续的分析或是及时的反馈。 

向Mule发送GET请求 
组成该编排的最后一个服务负责HTTP GET处理,它会获得新创建的订单,订单中包含了额外的值以形成一个合法的消息供email网关使用。如下是个示例交互: 

GET /order/O13579 HTTP 1.1 
200 OK 
Content-Type: application/vnd.acme+xml 
... 
Java代码  收藏代码
  1. <order xmlns='urn:acme:order:3:1'>   
  2.   <customerId>123456</customerId>   
  3.   <productId>P987C</productId>   
  4.   <quantity>2</quantity>   
  5.   <customerEmail>foo@bar.baz</customerEmail>   
  6.   <estimatedShipping>2009-31-12T00:00:00Z</estimatedShipping>  
  7. </order>  

好消息是Mule的HTTP传送包含了一个名为rest-servicecomponent的组件,该组件简化了服务与REST资源的交互。幸好有了这样一个组件,我们就无需将GET操作的结果发给随后的服务了,相反可以在单独的服务中完成一切。除此以外,它还支持在配置中使用表达式,这样就能实现与动态构建的URL之间的连通了。 

Java代码  收藏代码
  1. <service name="SuccessfulOrderProcessor">   
  2. <inbound>   
  3.   <inbound-endpoint ref="SuccessfulOrderQueue" />   
  4. </inbound>   
  5. <http:rest-service-component httpMethod="GET"   
  6.    serviceUrl="#[header:OrderResourceLocation]" />   
  7. <outbound>   
  8.   <pass-through-router>   
  9.     <outbound-endpoint ref="EmailGatewayQueue">   
  10.       <transformers>   
  11.        <object-to-string-transformer />   
  12.        <transformer ref="OrderMicroformatToEmailMap" />   
  13.       </transformers>   
  14.     </outbound-endpoint>   
  15.   </pass-through-router>   
  16. </outbound>   
  17. </service>  

在接收到成功的订单消息后,该服务使用REST服务组件生成一个HTTP GET请求,并将该请求发送给此前存储在OrderResourceLocation属性(aka heade)中的URL。注意到我们是如何通过Mule表达式框架(使用#[...]语法)在组件中注入动态URL的。 

在将GET请求的响应发送给负责与email网关进行通信的服务前,我们对XML订单实体进行了两次转换: 

如上所述,我们“分离”了响应实体。 
使用转换器解析XML实体并构建一个映射以供接下来的服务使用。这一次,又利用到了Groovy的强大功能。 
Groovy's XmlSlurper Happiness 

Groovy的XmlSlurper是解析XML微格式的理想工具,这要归功于其类似DSL的API。 

如下代码展示了OrderMicroformatToEmailMap转换器的实现: 

Java代码  收藏代码
  1. <scripting:transformer name="OrderMicroformatToEmailMap">   
  2.   <scripting:script engine="groovy"><![CDATA[   
  3.     def order = new XmlSlurper().parseText(payload)  
  4.                 .declareNamespace(acme: 'urn:acme:order:3:1')   
  5.     result = [emailId:'OrderConfirmation',   
  6.         emailAddress:order.'acme:customerEmail'.text(),   
  7.         orderId:order.@id.text()]   
  8.    ]]>   
  9.   </scripting:script>   
  10. </scripting:transformer>  

没错,就两行Groovy代码,我们使用了一个命名空间感知的XML解析器和一个map构建器。其好处真是让人难以置信,不过这就是创建map(email网关服务所期望的)所需的全部内容。 

最终的REST 
在本文中,我们遵循着一个事先定义好的编排,新订单资源的URL是唯一的动态元素。开发者可以利用示例中介绍的转换器和表达式来支持更多的动态交互,如果你打算遵从HATEOAS路线,你就能获得一切。如果事实如此,那其他的Mule路由就唾手可得了,比如可以创建幂等接收者的 路由。你也看到了Groovy的强大功能和灵巧性加上Mule的通信能力极大地简化了与RESTful服务的交互。Mule的表达式和少量的Groovy 脚本能够有效地动态定义Mule配置。除此之外,通过使用异步的VM队列将编排的各个步骤链接起来可以在最大负荷下优雅地降级,这要归功于Mule内在的SEDA架构。 

借助于这些强大的工具,集成REST资源变得非常简单了。 

祝你好运! 

大家可以从http://dossot.net/datastore/mule-groovy-rest.tar.gz下载完整的配置和相关的测试资源,这是一个独立的Maven项目。 

查看英文原文:Orchestrating RESTful Services With Mule ESB And Groovy。 
http://www.infoq.com/articles/restful-services-mule

转载于:https://www.cnblogs.com/yecllsl/archive/2011/03/15/1985061.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/462732.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

《领域驱动设计》第二部分:模型驱动设计的构造块 第四章:分离领域 阅读笔记...

内容概述 将领域对象与系统中的其他功能分离 第一小节 介绍了分离领域的技术&#xff1a;Layered Architecture。 第二小节 指出大部分软件系统都会采用分层的架构&#xff0c;但是分层方案有很多种。领域驱动设计只要求领域层存在即可&#xff0c;并且领域模型在领域层中表现不…

Starling框架帮助手册中文版(PDF下载)

什么是Statling&#xff1f;Starling 是一个基于Stage3D&#xff08;这是Flash Player11及Adobe AIR 3中新增的为3D加速功能所提供的API&#xff09;所开发的一个能够使用GPU来加速的2D Flash应用程序的ActionScript3框架。Starling主要是为游戏开发而设计的, 但是它的用途不仅…

在X32与X64下,每种数据类型占用的字节数

在X32与X64下&#xff0c;每种数据类型占用的字节数分别如下&#xff1a; X32 X64 指针 4Byte 8Byte char 1Byte …

一个Setup Factory的Lua脚本

需求是把安装路径中的反斜杠转义成斜杠并写入到配置文件特定的地方去。 读取配置文件 由于配置文件不大 一次性的读入到内存中 local f io.input(SessionVar.Expand("%AppFolder%\\Common\\conf.xml"), "r");local r f:read("*all");io.close()…

20190501-编写一个函数来查找字符串数组中的最长公共前缀。如果不存在公共前缀,返回空字符串...

题目描述 编写一个函数来查找字符串数组中的最长公共前缀。 如果不存在公共前缀&#xff0c;返回空字符串 ""。 示例 1: 输入: ["flower","flow","flight"] 输出: "fl" 示例 2: 输入: ["dog","racecar"…

MySQL幻读及解决方法

这是一篇数据库隔离级别的科普文章&#xff0c;旨在了解数据库中著名的幻读现象&#xff0c;为了专注&#xff0c;对脏读、不可重复读不作讨论。 事务隔离级别 MySQL有四级事务隔离级别: 读未提交 READ-UNCOMMITTED&#xff1a; 存在脏读&#xff0c;不可重复读&#xff0c;幻…

SVN trunk branches tags 的用法 - 摘自网络

Subversion有一个很标准的目录结构&#xff0c;是这样的。比如项目是proj&#xff0c;svn地址为svn://proj/&#xff0c;那么标准的svn布局是svn://proj/|-trunk-branches-tags这是一个标准的布局&#xff0c;trunk为主开发目录&#xff0c;branches为分支开发目录&#xff0c;…

数据结构学习方法

在网上搜集到的数据结构学习方法&#xff0c;请同学们参考。 谈数据结构学习方法&#xff08;转帖&#xff09;我在这里只是谈谈自己的学习体会现在咱们学的的数据结构是C版本的 所以C的一些基础知识应该先看会 尤其是指针那一部分 很多人对指针只是一知半解 由于一直对指针概念…

UIPickerView基本使用

UIPickerView是很常用的一个UI控件&#xff0c;在各种购物平台选择地址时候都是必备的&#xff0c;下面我们来说一下具体的使用 首先UIPickerView的创建&#xff0c;与多数控件一样&#xff0c;分配内存并设置位置尺寸。 重要的的是代理与数据源&#xff0c;设置代理和数据源后…

幻读和不可重复读

MySQL MySQL默认的隔离级别为RR&#xff0c;因此只会出现幻读的情况。 不会出现不可重复读的问题。 幻读 事务在插入已经检查过不存在的记录时&#xff0c;惊奇的发现这些数据已经存在了&#xff0c;之前的检测获取到的数据如同鬼影一般。 例子&#xff1a; 在事务1中&…

优化php效率,提高php性能的一些方法

1、在可以用file_get_contents替代file、fopen、feof、fgets等系列方法的情况下&#xff0c;尽量用 file_get_contents&#xff0c;因为他的效率高得多&#xff01;但是要注意file_get_contents在打开一个URL文件时候的PHP版本问题&#xff1b; 2、尽量的少进行文件操作&#x…

园区网VLAN应用实例

园区环境&#xff1a;一台核心路由器&#xff0c;一台核心交换机&#xff1b;四台汇聚层交换机&#xff1b;四台接入层交换机&#xff08;可根据实际需求和带宽的大小增加接入层的数量&#xff09;——接入层下接入大量的PC机。技术要求&#xff1a;通过VLAN的划分及VTP的设置实…

java 检查进程是否存在

以nginx进程为例子 private final static String NAME_STRING "nginx.exe";//传入进程名称processNamepublic static boolean findProcess() {BufferedReader bufferedReader null;try {Process proc Runtime.getRuntime().exec("tasklist -fi " "…

2021年简单总结

2021年的余额还有不到6小时就要结束了&#xff0c;在这辞旧迎新的时刻&#xff0c;心情是十分复杂的。2021年还是比较艰辛的&#xff0c;不管在工作、生活、家庭、养育小孩或亲戚往来方面&#xff0c;遇到的困难远远地超过了我的预期&#xff0c;但是也收获了很多&#xff0c;包…

3450

/* KMP来做532ms */// include file #include <cstdio> #include <cstdlib> #include <cstring> #include <cmath> #include <cctype> #include <ctime>#include <iostream> #include <sstream> #include <fstream> #in…

GMF 教程 Mindmap 5

2019独角兽企业重金招聘Python工程师标准>>> 这一部分主要实现的是&#xff1a; 使用扩展的Plug-in为我们的Diagram添加一个自定义动作 Creating a Customization Plug-in 尽管可以给生成的代码添加备注generated NOT来避免下次重新生成代码时覆盖我们修改的代码…

invalid use of incomplete type struct 或者是class的解决办法

在写完代码之后进行编译时&#xff0c;提示"invalid use of incomplete type struct" 或者 "invalid use of incomplete type class" 的解决办法&#xff1a; 1、对应的头文件要包含&#xff0c;这个是必须的。 当时因为没有包含头文件&#xff0c;也汇报…

ASP.NETLinkButton的Click事件中获取CommandArgument的值

/// <summary> /// LinkButton的onClick事件 /// </summary> /// <param name"sender"></param> /// <param name"e"></param> protected void linkBtnName_Click(object sender, EventArgs e) { …

Linux的proc文件系统详解

引用自&#xff1a;http://bbs.chinaunix.net/thread-2002769-1-1.html Linux系统上的/proc目录是一种文件系统&#xff0c;即proc文件系统。与其它常见的文件系统不同的是&#xff0c;/proc是一种伪文件系统&#xff08;也即虚拟文件系统&#xff09;&#xff0c;存储的是当前…

Jmeter(四十二)_控制器下遍历一组参数

概述 在接口自动化的过程中&#xff0c;经常遇到需要遍历的参数组。jmeter在中&#xff0c;foreach控制器可以实现遍历参数&#xff0c;但是只能有一个入参。一旦遇到数组&#xff0c;foreach控制器表示我也无能为力。。。 为了解决这个问题&#xff0c;今天教大家一个实现数组…