- 浏览: 294847 次
- 性别:
- 来自: 深圳
文章分类
- 全部博客 (133)
- boss好文 (10)
- 数据模型 (2)
- together (1)
- oracle (10)
- 健康生活 (4)
- js好东东 (8)
- 工作流 (1)
- 常见java问题 (7)
- BOSS开发随想 (0)
- rose相关 (1)
- 股市看图 (4)
- java基础 (12)
- jbpm (1)
- 集群(负载均衡) (4)
- spring教程 (2)
- maven入门 (5)
- 项目管理 (14)
- 常用软件 (3)
- mysql (4)
- j2ee性能调优 (2)
- jfreechart相关 (1)
- 需求工具 (2)
- maven基础讲解 (3)
- AXURE下载 (2)
- db2 (2)
- svn (1)
- 日常操作技巧 (3)
- SOA (16)
- jetty (2)
- jetspeed (0)
- camel (0)
- 安卓开发 (4)
- ESB (4)
- 物流 (2)
- 软件需求的3个层次 (1)
- WMS (1)
- eclipse (1)
- 安卓源代码 (2)
- jar (0)
最新评论
-
seeYourEye:
prt1979 写道怎么在点“open project”后,选 ...
PL/SQL Developer插件之SVN -
prt1979:
怎么在点“open project”后,选择文件夹后一直弹出“ ...
PL/SQL Developer插件之SVN -
houlianxue:
LateCHI 写道东西不错。可以正常打开目录。但是进行svn ...
PL/SQL Developer插件之SVN -
LateCHI:
东西不错。可以正常打开目录。但是进行svn操作的时候提示 un ...
PL/SQL Developer插件之SVN -
w.tany:
很多地方少个# 号
<s:property>的用法
一、Hello World (主要演示了两个service component链式合作处理一条消息和消息格式转换
1、示例翻译:
展示了如何配置多个service components——它们与一个请求交互(就是说二者合作以链式方式先后处理一个请求消息,处理的方式是添加消息的内容),以及如何管理事件转换(所谓事件就是消息,这里的事件转换是指消息格式的转换,比如从stdio标准输入中输入的字符串转换为一个java bean对象以及不同java bean之间的转换)。这个例子还使用了属性文件来配置i18n国际化的消息文字。还有演示了出站过滤路由。
使用了两个类也就是两个service component组件来先后处理消息,第一个是Greeter 类,它的greet()方法 使用LocalMessage 来从上面提到的属性文件获取greeting问候语,然后把问候语"Hello"加到你在控制台输入的名字之前(这样它就第一次修改了消息的内容)。第二个是ChitChatter类,它的chat方法 把", how are you?"加到消息内容之后(这样它又一次修改了消息内容):
流程是这样的:命令行接受用户输入 -> StdinToNameString转换器将字符串格式的消息转换为NameString类型的java bean -> 消息交给Greeter组件处理:把"Hello"加到了消息内容之前 -> 处理之后的消息被发往chitchatter队列 -> ChitChatUMO服务组件)StdinToNameString转换器在之前就定义好了:
注意: Mule是依靠反射获知Greeter内部各个方法需要的传参类型,然后再根据目前消息格式调用正确的消息处理方法。Greeter处理完消息后、mule把消息分发到了端点:vm://chitchatter:名为chitchatter的in-memory queue内存队列。ChitChatUMO服务组件正在监听这个队列(也就是说chitchatter队列是 GreeterUMO的输出、ChitChatUMO的输入,这样来使得两个服务组件先后处理一条消息)
ChitChatUMO服务组件又配置了两个转换器:NameStringToChatString、ChatStringToString。ChitChatter组件类的输入参数为 ChatString 类型,所以NameStringToChatString转换器将消息格式从NameString转为 ChatString、然后再调用 ChitChatter组件(流程:GreeterUMO -> vm://chitchatter -> NameStringToChatString -> ChitChatter -> ChatStringToString -> System.out)
注意Java bean是不含有任何路由逻辑的, Mule配置文件将它们组织到一起,任何已有的pojo、web services都可以照此办理并在它们之间传输消息。
二、Stock Quote (演示了如何调用ASPX web service、使用XSLT转换、反序列化StockQuote Java bean以及使用REST和SOAP调用服务。例子需要访问互联网上的公共.NET服务、主要是咱也不知道人家都有哪些股票代码有数据。源码就不看了)
1、示例翻译:通过System.in接收股票代码、调用StockQuote服务、通过XSLT转换器将返回结果转换格式、通过XmlToObject转换器再将结果转换为StockQuote类型、随后将股票报价打印到System.out
(例子用到了类似spring的属性占位符特性来从配置文件取得一些信息、配置多个转换器并“串联”起来、其中还用到xslt转换器)
配置当中还用到所谓的REST service component , 它使用了REST服务包装器代理了一个REST服务、这样使得该service服务看上去似乎是本地的component组件一般(和CXF的web服务包装器差不多),REST服务包装器有一些配置属性:serviceUrl就是 访问REST服务的url、payloadParameterName是传参名 ,本例中只有一个参数"symbol"——股票代码、httpMethod是方法名 ——GET或POST。
我随便传了个代码过去返回了无数据的xml:
Web Service版和REST版原理类似,只是服务配置是不同的。Web Service版显式配置了outbound pass-through路由,它将输入从一个endpoint直接传输到outbound Axis endpoint,不作任何改变或处理。另外outbound endpoint向Stock Quote service股票报价服务请求时是带参数的。
三、Error Handler (演示了如何使用Spring beans作为service component以及向多个出站endpoint发布消息,使用了文件监控inbound+邮件outbound)
示例包含两个services: ExceptionManager 异常管理器 和 BusinessErrorManager业务错误管理器。
BusinessErrorManager是个简单的service,它通过JMS接收业务异常消息并将消息记录到控制台,以此模仿真实的异常处理应用。
ExceptionManager接收异常消息并根据异常消息的类型进行某些处理动作。例如如果收到致命异常则会向系统管理员发送邮件;收到标准系统异常则写入本地文件log,例子演示的不是异常处理、演示的是:
(1)所有的service components都是以spring bean的形式在一个mule配置文件当中配置的。
(2)error manager拥有多个outbound endpoints出站端点,例子演示了消息如何发布到不同端点。
(3)消息是Java对象形式,并且需要在XML形式之间互相转换。例子演示了链接多个转换器。
四、Loan Broker (基于Enterprise Integration Patterns book 一 EIP书中的例子 ,mule不鸟JBI和SCA,唯遵SEDA和EIP,有个性)
Loan Broker贷款中介(也叫loan agent service)是mule的主要演示例子,顾名思义,就是客户向银行申请贷款的故事。先看一下背景知识:
以往的贷款请求流程如下图
1) 客户customer 向不同的银行bank 发起请求搜寻最优利率。
2) 每家银行都要向客户询问社保号码ss、贷款数量以及期限。
3) 每家银行都要对该客户做信用背景调查:通常是咨询征信所credit bureau (通过征信中介credit agency ),最后银行才能根据这些信息发放贷款。
4) 客户接收到所有银行的反馈以后,从中选择一家最好的,比如说利率最低
加贷款中介以后,这个处理流程可以更加自动化、允许客户在线获取更多银行的实时反馈,耗时要比一家一家询问少得多:
1) 接收到客户请求以后,loan broker贷款中介从征信所获取该客户的信用信息。
2) 替该客户向贷方服务lender service 列出的所有银行发出贷款请求(例子中这个服务啥也没做只是个意思)
3) 将反馈的贷款额度信息打包发送回用户供选择(例子中就是选择返回利率最低的那家银行)
这其中的角色包括
1、贷款中介服务http/rest(接收客户的http贷款请求,包含社保号、贷款额、期限并负责相应放贷信息)。
2、征信所服务EJB(由贷款中介公司管理的EJB外部服务,做信用检查的,暴露一个名为creditAgency的EJB的getCreaditProfile方法)
3、征信所网关(例子中的网关做的事情都是:在JMS消息总线和 外部应用或服务/征信所服务应用 之间整理请求)
4、贷方服务VM(根据客户的资信评分等信息选择请贷的银行,本地pojo组件,决定请求哪几家银行)
5、贷方网关(在消息总线到贷方服务应用之间整理请求)
6、银行网关(向多家银行分发贷款请求)
7、还有几家银行bank(soap协议的消息服务、为了简化、所有银行暴露同样的ws接口。当然你也可以配置不同接口的多家银行)。
都算是应用,以往的应用之间通讯是点对点,客户自己去一家一家调用银行服务、所有银行都一遍一遍地调用征信所。而loanBroker就相当于我们的ESB,加入loanBroker以后就不再是点对点而是点对面,ESB就是面、覆盖了征信所、所有银行及各个网关的一个门面(这么看ESB蛮像一个fasade的嘛),这个门面替应用摆平一切,你只要说我要贷款!、其他的如你的资信评级、你都要请求谁、你的请求还需要依赖什么都包办,有事您只管说句话就得。
例子涉及异步的请求/响应处理模型;对JMS、http/rest、vm、soap、EJB各种协议的调用;把bank暴露为ws。总线中的消息用LoanQuoteRequest 代表,本例中这是个javaBean格式,但是实际中往往是个xml格式(用了ESB,我发现对消息这个东东来说格式是五花八门的:javabean pojo、xml、http参数、stdio、soap甚至json...)
loan broker的示例包含ESB和ESN两种布局的版本,含义参见Mule Topologies的5种拓扑布局:
ESB、ESN企业服务网、对等网(这不又成了点对点了么,不推荐)、C/S以hub为中心的辐射方式(可能性能有问题,不推荐)、管道方式(服务编排?)
1、示例翻译:
Loan Broker ESB基于当前的Loan Broker示例 但是实现了一个完整的ESB架构,该例子演示了如何使用HTTP/REST、 Web Services、EJB、JMS,他是根据典型ESB实现来配置的。
Loan Broker ESB使用了JMS消息总线以提供在不同组件和应用间的公共消息通道:
组件:
1、Loan Broker Service贷款中介服务 :接收贷款请求(信息包括SS社保号码、贷款额度、期限)并负责收集放贷反馈向客户反馈。
2、Credit Agency Service征信所服务 :外部服务提供者、它对客户的授信进行检验以确保合理的放贷额度。
3、Credit Agency Gateway征信所网关 :在消息总线和征信所应用之间整理请求。
4、Lender Service贷方服务 :基于客户的资信评分,放贷额度和期限,由贷方服务选择请求贷款的银行。
5、Lender Gateway贷方网关 :从消息总线到贷方应用之间整理请求。
6、Banking Gateway银行网关 :基于贷方列表、向一家或多家银行分发贷款请求。
总体流程:
1,客户应用向LoanBroker 贷款中介服务 发出 CustomerQuoteRequest消息 。
2,LoanBroker 贷款中介服务 创建一个 LoanQuoteRequest 消息,这是总线通用消息格式。
3,Mule通过JMS向Credit Agency Gateway 征信所网关 发送该消息。
4,网关整理请求、调用CreditAgency EJB组件,RelectionMessageBuilder自动将CreditProfile附加到LoanQuoteRequest 消息上 。
5,Mule通过JMS向Lender Gateway贷方网关 发送该消息.
6,贷方网关 使用VM传输调用贷方服务 .
7,Mule通过JMS向Banking Gateway银行网关 发送该消息.
8,Banking Gateway银行网关 通过Axis实现的SOAP调用银行服务.
9,每家银行都把自己的贷款报价附加到请求中并通过应答地址ReplyTo 发回LoanBroker 贷款中介服务 。应答地址是由Banking Gateway银行网关 提供的.
10,LoanBroker 贷款中介服务 的ResponseRouter响应路由接收对应答地址 的响应,它选择最低利率并返回客户。
本例中,消息总线上的通用消息格式是java bean格式。一般情况下如JMS规范要求总线内的通用消息是xml格式,但是mule允许你使用任何数据格式,两种格式各有优缺,xml的文本消息允许你方便的直接实施xslt转换器之类,bean方式在component中更便于编码处理,两种方式也都方便用路由器去根据消息内容做路由判断。我们先来定义这个消息bean:LoanQuoteRequest(org.mule.example.loanbroker.messages.LoanBrokerQuoteRequest):
客户的初始请求触发整个事件处理流,客户使用浏览器以htt协议请求mule rest服务,这个服务当然得向外暴露,暴露的方式就是配置贷款中介端点 (CustomerRequestsREST)
这句话的配置含义:
1、内嵌Jetty servlet引擎
2、mule启动jetty在8888端口上监听rest请求
3、把rest servlet绑定到/loanbroker上下文
来自客户的初始rest请求格式为:
贷款中介端点 以http参数形式接收下来,需要转换为CustomerQuoteRequest对象,所以增加了一个自定义转换器:
这个转换器要用在贷款中介端点 上,在贷款中介服务的入站inbound配置上、入站端点endpoint引用了贷款中介端点(CustomerRequestsREST)、同时也引用了这个转换器。也就是说从贷款中介端点 上接收的rest请求都直接用这个转换器予以转换:
1、示例翻译:
展示了如何配置多个service components——它们与一个请求交互(就是说二者合作以链式方式先后处理一个请求消息,处理的方式是添加消息的内容),以及如何管理事件转换(所谓事件就是消息,这里的事件转换是指消息格式的转换,比如从stdio标准输入中输入的字符串转换为一个java bean对象以及不同java bean之间的转换)。这个例子还使用了属性文件来配置i18n国际化的消息文字。还有演示了出站过滤路由。
使用了两个类也就是两个service component组件来先后处理消息,第一个是Greeter 类,它的greet()方法 使用LocalMessage 来从上面提到的属性文件获取greeting问候语,然后把问候语"Hello"加到你在控制台输入的名字之前(这样它就第一次修改了消息的内容)。第二个是ChitChatter类,它的chat方法 把", how are you?"加到消息内容之后(这样它又一次修改了消息内容):
<service name="GreeterUMO"> <inbound> <stdio:inbound-endpoint system="IN" transformer-refs="StdinToNameString"/> </inbound> <component class="org.mule.example.hello.Greeter"/> <outbound> <filtering-router> <vm:outbound-endpoint path="chitchatter"/> <payload-type-filter expectedType="org.mule.example.hello.NameString"/> </filtering-router> </outbound> </service>
流程是这样的:命令行接受用户输入 -> StdinToNameString转换器将字符串格式的消息转换为NameString类型的java bean -> 消息交给Greeter组件处理:把"Hello"加到了消息内容之前 -> 处理之后的消息被发往chitchatter队列 -> ChitChatUMO服务组件)StdinToNameString转换器在之前就定义好了:
<custom-transformer name="StdinToNameString" class="org.mule.example.hello.StdinToNameString"/>
注意: Mule是依靠反射获知Greeter内部各个方法需要的传参类型,然后再根据目前消息格式调用正确的消息处理方法。Greeter处理完消息后、mule把消息分发到了端点:vm://chitchatter:名为chitchatter的in-memory queue内存队列。ChitChatUMO服务组件正在监听这个队列(也就是说chitchatter队列是 GreeterUMO的输出、ChitChatUMO的输入,这样来使得两个服务组件先后处理一条消息)
<service name="ChitChatUMO"> <inbound> <vm:inbound-endpoint path="chitchatter" transformer-refs="NameStringToChatString"/> </inbound> <component class="org.mule.example.hello.ChitChatter"/> <outbound> <pass-through-router> <stdio:outbound-endpoint system="OUT" transformer-refs="ChatStringToString" /> </pass-through-router> </outbound> </service>
ChitChatUMO服务组件又配置了两个转换器:NameStringToChatString、ChatStringToString。ChitChatter组件类的输入参数为 ChatString 类型,所以NameStringToChatString转换器将消息格式从NameString转为 ChatString、然后再调用 ChitChatter组件(流程:GreeterUMO -> vm://chitchatter -> NameStringToChatString -> ChitChatter -> ChatStringToString -> System.out)
注意Java bean是不含有任何路由逻辑的, Mule配置文件将它们组织到一起,任何已有的pojo、web services都可以照此办理并在它们之间传输消息。
二、Stock Quote (演示了如何调用ASPX web service、使用XSLT转换、反序列化StockQuote Java bean以及使用REST和SOAP调用服务。例子需要访问互联网上的公共.NET服务、主要是咱也不知道人家都有哪些股票代码有数据。源码就不看了)
1、示例翻译:通过System.in接收股票代码、调用StockQuote服务、通过XSLT转换器将返回结果转换格式、通过XmlToObject转换器再将结果转换为StockQuote类型、随后将股票报价打印到System.out
(例子用到了类似spring的属性占位符特性来从配置文件取得一些信息、配置多个转换器并“串联”起来、其中还用到xslt转换器)
<model name="Sample-Rest"> <service name="HTTPPostSample"> <inbound> <vm:inbound-endpoint path="stockquote" responseTransformer-refs="ToString XmlDecoder Xslt XmlToObject"/> </inbound> <http:rest-service-component serviceUrl="http://www.webservicex.net/stockquote.asmx/GetQuote" httpMethod="POST"> <http:payloadParameterName value="symbol"/> </http:rest-service-component> </service> </model>
配置当中还用到所谓的REST service component , 它使用了REST服务包装器代理了一个REST服务、这样使得该service服务看上去似乎是本地的component组件一般(和CXF的web服务包装器差不多),REST服务包装器有一些配置属性:serviceUrl就是 访问REST服务的url、payloadParameterName是传参名 ,本例中只有一个参数"symbol"——股票代码、httpMethod是方法名 ——GET或POST。
我随便传了个代码过去返回了无数据的xml:
<string> <StockQuotes><Stock><Symbol>002339</Symbol><Last>0.00</Last><Date>N/A</Date><Time>N/A</Time><Change>N/A</Change><Open>N/A</Open><High>N/A</High><Low>N/A</Low><Volume>N/A</Volume><MktCap>N/A</MktCap><PreviousClose>N/A</PreviousClose><PercentageChange>N/A</PercentageChange><AnnRange>N/A - N/A</AnnRange><Earns>N/A</Earns><P-E>N/A</P-E><Name>002339</Name></Stock></StockQuotes> </string>
Web Service版和REST版原理类似,只是服务配置是不同的。Web Service版显式配置了outbound pass-through路由,它将输入从一个endpoint直接传输到outbound Axis endpoint,不作任何改变或处理。另外outbound endpoint向Stock Quote service股票报价服务请求时是带参数的。
<model name="Sample-SOAP"> <service name="serviceProxy"> <inbound> <vm:inbound-endpoint path="stockquote" responseTransformer-refs="ToString XmlDecoder Xslt XmlToObject"/> </inbound> <outbound> <pass-through-router> <axis:outbound-endpoint address="http://www.webservicex.net/stockquote.asmx?method=GetQuote" responseTransformer-refs="XmlDecoder Xslt XmlToObject" soapAction="[methodNamespace][method]"> <axis:soap-method method="qname{GetQuote:http://www.webserviceX.NET/}"> <axis:soap-parameter parameter="symbol" type="string" mode="IN"/> <axis:soap-parameter parameter="GetQuoteResult" type="string" mode="OUT"/> </axis:soap-method> </axis:outbound-endpoint> </pass-through-router> </outbound> </service> </model>
三、Error Handler (演示了如何使用Spring beans作为service component以及向多个出站endpoint发布消息,使用了文件监控inbound+邮件outbound)
示例包含两个services: ExceptionManager 异常管理器 和 BusinessErrorManager业务错误管理器。
BusinessErrorManager是个简单的service,它通过JMS接收业务异常消息并将消息记录到控制台,以此模仿真实的异常处理应用。
ExceptionManager接收异常消息并根据异常消息的类型进行某些处理动作。例如如果收到致命异常则会向系统管理员发送邮件;收到标准系统异常则写入本地文件log,例子演示的不是异常处理、演示的是:
(1)所有的service components都是以spring bean的形式在一个mule配置文件当中配置的。
(2)error manager拥有多个outbound endpoints出站端点,例子演示了消息如何发布到不同端点。
(3)消息是Java对象形式,并且需要在XML形式之间互相转换。例子演示了链接多个转换器。
<spring:bean id="errorManager" class="org.mule.example.errorhandler.ErrorManager"> <spring:property name="handlers"> <spring:list> <spring:ref local="fatalHandler"/> <spring:ref local="defaultHandler"/> <spring:ref local="businessHandler"/> </spring:list> </spring:property> </spring:bean> <model name="errorhandler-test"> <service name="Error Manager"> <inbound> <inbound-endpoint address="file://./test-data/in" transformer-refs="XMLToExceptionBean ExceptionBeanToErrorMessage"> <file:filename-wildcard-filter pattern="*.xml"/> </inbound-endpoint> </inbound> <pooled-component> <prototype-object class="org.mule.example.errorhandler.ErrorManager"> <properties> <spring:entry key="handlers"> <spring:list> <spring:ref local="fatalHandler"/> <spring:ref local="defaultHandler"/> <spring:ref local="businessHandler"/> </spring:list> </spring:entry> </properties> </prototype-object> </pooled-component> <outbound> <filtering-router> <file:outbound-endpoint path="test-data/exceptions" outputPattern="Exception-[UUID].xml" transformer-refs="ErrorMessageToExceptionBean ExceptionBeanToXML"/> <!-- Check ErrorMessage.getThrowable() exception type --> <expression-filter evaluator="groovy" expression="payload.throwable instanceof org.mule.api.DefaultMuleException"/> </filtering-router> <filtering-router> <smtp:outbound-endpoint user="${smtp.username}" password="${smtp.password}" host="${smtp.host}" port="${smtp.port}" to="${email.toAddress}" from="${email.fromAddress}" subject="${email.subject}" transformer-refs="ErrorMessageToExceptionBean ExceptionBeanToXML StringToEmailMessage"/> <!-- Check ErrorMessage.getThrowable() exception type --> <expression-filter evaluator="groovy" expression="payload.throwable instanceof org.mule.api.lifecycle.FatalException"/> </filtering-router> <filtering-router> <outbound-endpoint address="jms://exception.queue" transformer-refs="ErrorMessageToExceptionBean ExceptionBeanToXML ObjectToJMSMessage"/> <!-- Check ErrorMessage.getThrowable() exception type --> <expression-filter evaluator="groovy" expression="payload.throwable instanceof org.mule.example.errorhandler.exceptions.BusinessException"/> </filtering-router> <custom-catch-all-strategy class="org.mule.routing.LoggingCatchAllStrategy"/> </outbound> </service>
四、Loan Broker (基于Enterprise Integration Patterns book 一 EIP书中的例子 ,mule不鸟JBI和SCA,唯遵SEDA和EIP,有个性)
Loan Broker贷款中介(也叫loan agent service)是mule的主要演示例子,顾名思义,就是客户向银行申请贷款的故事。先看一下背景知识:
以往的贷款请求流程如下图
1) 客户customer 向不同的银行bank 发起请求搜寻最优利率。
2) 每家银行都要向客户询问社保号码ss、贷款数量以及期限。
3) 每家银行都要对该客户做信用背景调查:通常是咨询征信所credit bureau (通过征信中介credit agency ),最后银行才能根据这些信息发放贷款。
4) 客户接收到所有银行的反馈以后,从中选择一家最好的,比如说利率最低
加贷款中介以后,这个处理流程可以更加自动化、允许客户在线获取更多银行的实时反馈,耗时要比一家一家询问少得多:
1) 接收到客户请求以后,loan broker贷款中介从征信所获取该客户的信用信息。
2) 替该客户向贷方服务lender service 列出的所有银行发出贷款请求(例子中这个服务啥也没做只是个意思)
3) 将反馈的贷款额度信息打包发送回用户供选择(例子中就是选择返回利率最低的那家银行)
这其中的角色包括
1、贷款中介服务http/rest(接收客户的http贷款请求,包含社保号、贷款额、期限并负责相应放贷信息)。
2、征信所服务EJB(由贷款中介公司管理的EJB外部服务,做信用检查的,暴露一个名为creditAgency的EJB的getCreaditProfile方法)
3、征信所网关(例子中的网关做的事情都是:在JMS消息总线和 外部应用或服务/征信所服务应用 之间整理请求)
4、贷方服务VM(根据客户的资信评分等信息选择请贷的银行,本地pojo组件,决定请求哪几家银行)
5、贷方网关(在消息总线到贷方服务应用之间整理请求)
6、银行网关(向多家银行分发贷款请求)
7、还有几家银行bank(soap协议的消息服务、为了简化、所有银行暴露同样的ws接口。当然你也可以配置不同接口的多家银行)。
都算是应用,以往的应用之间通讯是点对点,客户自己去一家一家调用银行服务、所有银行都一遍一遍地调用征信所。而loanBroker就相当于我们的ESB,加入loanBroker以后就不再是点对点而是点对面,ESB就是面、覆盖了征信所、所有银行及各个网关的一个门面(这么看ESB蛮像一个fasade的嘛),这个门面替应用摆平一切,你只要说我要贷款!、其他的如你的资信评级、你都要请求谁、你的请求还需要依赖什么都包办,有事您只管说句话就得。
例子涉及异步的请求/响应处理模型;对JMS、http/rest、vm、soap、EJB各种协议的调用;把bank暴露为ws。总线中的消息用LoanQuoteRequest 代表,本例中这是个javaBean格式,但是实际中往往是个xml格式(用了ESB,我发现对消息这个东东来说格式是五花八门的:javabean pojo、xml、http参数、stdio、soap甚至json...)
loan broker的示例包含ESB和ESN两种布局的版本,含义参见Mule Topologies的5种拓扑布局:
ESB、ESN企业服务网、对等网(这不又成了点对点了么,不推荐)、C/S以hub为中心的辐射方式(可能性能有问题,不推荐)、管道方式(服务编排?)
1、示例翻译:
Loan Broker ESB基于当前的Loan Broker示例 但是实现了一个完整的ESB架构,该例子演示了如何使用HTTP/REST、 Web Services、EJB、JMS,他是根据典型ESB实现来配置的。
Loan Broker ESB使用了JMS消息总线以提供在不同组件和应用间的公共消息通道:
组件:
1、Loan Broker Service贷款中介服务 :接收贷款请求(信息包括SS社保号码、贷款额度、期限)并负责收集放贷反馈向客户反馈。
2、Credit Agency Service征信所服务 :外部服务提供者、它对客户的授信进行检验以确保合理的放贷额度。
3、Credit Agency Gateway征信所网关 :在消息总线和征信所应用之间整理请求。
4、Lender Service贷方服务 :基于客户的资信评分,放贷额度和期限,由贷方服务选择请求贷款的银行。
5、Lender Gateway贷方网关 :从消息总线到贷方应用之间整理请求。
6、Banking Gateway银行网关 :基于贷方列表、向一家或多家银行分发贷款请求。
总体流程:
1,客户应用向LoanBroker 贷款中介服务 发出 CustomerQuoteRequest消息 。
2,LoanBroker 贷款中介服务 创建一个 LoanQuoteRequest 消息,这是总线通用消息格式。
3,Mule通过JMS向Credit Agency Gateway 征信所网关 发送该消息。
4,网关整理请求、调用CreditAgency EJB组件,RelectionMessageBuilder自动将CreditProfile附加到LoanQuoteRequest 消息上 。
5,Mule通过JMS向Lender Gateway贷方网关 发送该消息.
6,贷方网关 使用VM传输调用贷方服务 .
7,Mule通过JMS向Banking Gateway银行网关 发送该消息.
8,Banking Gateway银行网关 通过Axis实现的SOAP调用银行服务.
9,每家银行都把自己的贷款报价附加到请求中并通过应答地址ReplyTo 发回LoanBroker 贷款中介服务 。应答地址是由Banking Gateway银行网关 提供的.
10,LoanBroker 贷款中介服务 的ResponseRouter响应路由接收对应答地址 的响应,它选择最低利率并返回客户。
本例中,消息总线上的通用消息格式是java bean格式。一般情况下如JMS规范要求总线内的通用消息是xml格式,但是mule允许你使用任何数据格式,两种格式各有优缺,xml的文本消息允许你方便的直接实施xslt转换器之类,bean方式在component中更便于编码处理,两种方式也都方便用路由器去根据消息内容做路由判断。我们先来定义这个消息bean:LoanQuoteRequest(org.mule.example.loanbroker.messages.LoanBrokerQuoteRequest):
public class LoanBrokerQuoteRequest implements Serializable//由于需要在jms通道传输所以需要实现序列化 { /** * Serial version */ private static final long serialVersionUID = 46866005259682607L; /** The customer request * The request contains Customer info and loan amount and duration */ private CustomerQuoteRequest customerRequest; /** credit profile for the customer */ private CreditProfile creditProfile; /** A list of lenders for this request */ private Bank[] lenders; /** A loan quote from a bank */ private LoanQuote loanQuote; //get/set方法 }
客户的初始请求触发整个事件处理流,客户使用浏览器以htt协议请求mule rest服务,这个服务当然得向外暴露,暴露的方式就是配置贷款中介端点 (CustomerRequestsREST)
<endpoint name="CustomerRequestsREST" address="jetty:rest://localhost:8888/loanbroker" />
这句话的配置含义:
1、内嵌Jetty servlet引擎
2、mule启动jetty在8888端口上监听rest请求
3、把rest servlet绑定到/loanbroker上下文
来自客户的初始rest请求格式为:
http://localhost:8888/loanbroker/?name=Ross+Mason&ssn=1234& loanAmount=10000&loanDuration=24
贷款中介端点 以http参数形式接收下来,需要转换为CustomerQuoteRequest对象,所以增加了一个自定义转换器:
<custom-transformer name="RestRequestToCustomerRequest" class="org.mule.example.loanbroker.transformers.RestRequestToCustomerRequest" />
这个转换器要用在贷款中介端点 上,在贷款中介服务的入站inbound配置上、入站端点endpoint引用了贷款中介端点(CustomerRequestsREST)、同时也引用了这个转换器。也就是说从贷款中介端点 上接收的rest请求都直接用这个转换器予以转换:
<service name="LoanBroker"><!--贷款中介服务--> <description> The LoanBroker service is our 'entry' service that accepts requests from the outside world </description> <inbound> <inbound-endpoint ref="CustomerRequestsREST" transformer-refs="RestRequestToCustomerRequest" />
发表评论
-
BPEL或ESB:应该使用哪一个?
2012-03-13 17:09 1209在设计 SOA 解决方案时 ... -
ESB 案例解析和项目实施经验分享,第 3 部分: ESB 项目需求分析和方案设计浅谈
2012-02-15 14:50 1777选自:http://www.ibm.com/developer ... -
ESB 案例解析和项目实施经验分享,第 2 部分: 刚柔相济,构建企业联邦 ESB
2012-02-15 14:37 1866摘自:http://www.ibm.com/developer ... -
ESB案例分析:第 1 部分: 借助 ESB 整合航空公司商务体系,提升客户服务水平
2012-02-15 14:14 1941摘自:http://www.ibm.com/developer ... -
ESB架构之企业实施案例
2012-02-14 17:33 1417本文是摘抄自: http://www.webspherechi ... -
关于mule的网站
2011-11-07 10:17 1306关于mule的网站 1,http://note.sdo.com ... -
muleStudio发布到指定目录下
2011-11-04 15:14 1130在mule studio中右键项目名称,选择EXPORT,在弹 ... -
mule配置基础
2011-11-03 10:26 8850Mule是开源的企业集成消息框架,,它的配置需要使用大量的XM ... -
mule配置常用节点
2011-11-03 09:09 12551 Mule-config.xml 示例模型: <mul ... -
mule & seda 学习四
2011-11-03 09:10 989从前,从前 程序跑的太慢,对mule有点误解 jaxb解析 ... -
mule & seda的学习三
2011-11-03 09:10 1242以竣工服务为例 package com.tydic.mule ... -
mule & seda 学习二
2011-11-03 09:11 1190mule的jdbc,配置seda以及vm的初步认识 java ... -
mule & seda的学习之一
2011-11-02 17:18 1307mule:轻量级的ESB消息框架,可以和spring集成,支持 ... -
一个不错的MULE主文件
2011-11-02 17:06 1978mule & seda 的使用每分钟处理5000单,发 ... -
Mule 官方例子研究
2011-10-28 14:26 1921Mule 官方例子研究 一、 ...
相关推荐
本文将深入分析两个 Mule 的示例:Echo 和 HelloWorld,以理解其核心概念和工作原理。 首先,Echo 示例展示了如何在 Mule 中创建一个组件,该组件能够支持多种协议。在 Mule 中,组件是处理特定任务的基本单元,...
通过分析和运行这些示例,你可以深入理解Mule的工作方式,掌握如何创建和部署自己的Mule应用。记住,实践是学习Mule的最佳途径,尝试修改和扩展示例,以适应你的特定需求和场景。这将帮助你成为一个熟练的Mule开发者...
#### 五、MuleStudio 实战案例分析 - **Echo 示例**:演示如何创建一个简单的 Echo 服务,该服务会返回接收到的消息。 - **OrderDiscounter 示例**:模拟一个订单折扣服务,处理订单数据并计算折扣。 - **Order...
8. **实时流处理**:利用Mule ESB处理实时数据流,如日志分析或实时监控。 通过这个源码库,读者可以实际操作这些示例,加深对Mule ESB工作原理的理解,学习如何解决实际问题,从而提升在企业集成项目中的技能。...
标题所提到的"Mule in action"表明了本书着重于Mule的实际应用,这意味着书中不仅包含理论知识,还会有大量的实战案例、代码示例和最佳实践。而描述中提到的“社区成熟,文档丰富”,则表明了Mule ESB背后有着活跃的...
8. **Testing and Debugging**:书中还会涵盖如何对Mule应用程序进行测试和调试,包括单元测试、集成测试和日志分析。 9. **Deployment**:了解如何将Mule应用程序部署到不同的环境中,如本地服务器、云环境或Any...
- 连接器在实际应用中的案例分析 - **第4章:使用Mule进行数据转换** - 数据转换的重要性及应用场景 - Mule提供的转换工具和API - 如何使用Mule实现复杂的数据转换需求 - 数据转换策略和技术细节 - **第5章:...
- 分析Mule应用程序中的消息处理流程。 - 提供了详细的统计信息,有助于优化应用程序性能。 19. **定义SLA和服务级别警报** - 设置服务级别协议(SLA),以确保服务质量和可用性。 - 可以定义特定条件下的警报...
本书不仅详细讲解了Mule ESB的基础知识和核心概念,还提供了大量实用的案例分析,帮助读者更好地理解如何在实际项目中应用Mule。例如: - **跨系统集成案例:** - 介绍如何使用Mule ESB连接不同的企业级系统,如...
这一部分提供了一个实际的 Mule 配置文件示例,展示了如何组合上述所有元素来构建一个完整的 Mule 应用程序。 #### 第二章:路由器及其路由模式 **路由模式 (Routing Patterns)** 路由模式是设计集成解决方案时...
9. **源码分析**:分析提供的源码,了解每个部分的作用,如服务端点、处理逻辑、数据转换等,加深对Mule2.2工作原理的理解。 通过深入研究这个Mule2.2 BookStore实例,不仅可以掌握Mule的基本用法,还能了解到如何...
通过分析和运行这个示例,你可以学习如何配置和测试Mule应用,以及如何处理各种集成场景。 例如,它可能展示了一个从HTTP接收请求,通过DataWeave转换数据,然后通过JDBC连接器写入数据库的基本流程。这样的例子有...
5. **案例分析**:通过具体示例,展示如何使用iBatis组件执行CRUD(创建、读取、更新、删除)操作。这将帮助理解实际开发中的应用方法。 6. **源码解析**:深入到Mule iBatis组件的源码,了解其内部工作原理,这有...
压缩包中的"Mule ESB Cookbook.pdf"很可能是书籍的电子版,包含了完整的章节和案例分析,读者可以通过阅读来学习Mule ESB的相关知识。而"9781782164401_code.zip"可能包含与书中的各个示例配套的源代码,这些代码...
- **XML配置示例**: ```xml ``` - **流程中引用**: ```xml ``` 2. **配置WebService Consumer** - **选择WebService Consumer组件**:在Mule Studio的Connector组件中找到WebService Consumer组件...
为了更好地理解Mule的配置,下面提供了一些示例: #### HTTP Transport 配置示例 ```xml [message.payload]" level="INFO"/> ``` 此配置创建了一个监听8081端口的HTTP服务,并定义了一个处理HTTP请求的流程...
附带的源码是书中示例的实现,读者可以下载并跟随书中步骤操作,这将极大地增强学习体验,加深对Mule ESB工作原理的理解。源码的分析和实践将帮助读者掌握实际开发中的技巧和最佳实践。 Mule ESB的强大之处在于其...