`

mule示例分析

    博客分类:
  • SOA
阅读更多
一、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?"加到消息内容之后(这样它又一次修改了消息内容):
<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" /> 






  • 大小: 35.5 KB
  • 大小: 19.3 KB
  • 大小: 5 KB
  • 大小: 5.2 KB
  • 大小: 29 KB
  • 大小: 54.4 KB
分享到:
评论

相关推荐

    mule例子分析

    本文将深入分析两个 Mule 的示例:Echo 和 HelloWorld,以理解其核心概念和工作原理。 首先,Echo 示例展示了如何在 Mule 中创建一个组件,该组件能够支持多种协议。在 Mule 中,组件是处理特定任务的基本单元,...

    mule 具体例子(代码)

    通过分析和运行这些示例,你可以深入理解Mule的工作方式,掌握如何创建和部署自己的Mule应用。记住,实践是学习Mule的最佳途径,尝试修改和扩展示例,以适应你的特定需求和场景。这将帮助你成为一个熟练的Mule开发者...

    MuleStudio用户手册.doc

    #### 五、MuleStudio 实战案例分析 - **Echo 示例**:演示如何创建一个简单的 Echo 服务,该服务会返回接收到的消息。 - **OrderDiscounter 示例**:模拟一个订单折扣服务,处理订单数据并计算折扣。 - **Order...

    mule esb cookbook 随书源码

    8. **实时流处理**:利用Mule ESB处理实时数据流,如日志分析或实时监控。 通过这个源码库,读者可以实际操作这些示例,加深对Mule ESB工作原理的理解,学习如何解决实际问题,从而提升在企业集成项目中的技能。...

    mule in action mule 实战

    标题所提到的"Mule in action"表明了本书着重于Mule的实际应用,这意味着书中不仅包含理论知识,还会有大量的实战案例、代码示例和最佳实践。而描述中提到的“社区成熟,文档丰富”,则表明了Mule ESB背后有着活跃的...

    mule esb cookbook 的所有例子代码

    8. **Testing and Debugging**:书中还会涵盖如何对Mule应用程序进行测试和调试,包括单元测试、集成测试和日志分析。 9. **Deployment**:了解如何将Mule应用程序部署到不同的环境中,如本地服务器、云环境或Any...

    mule in action 第二版英文正式版

    - 连接器在实际应用中的案例分析 - **第4章:使用Mule进行数据转换** - 数据转换的重要性及应用场景 - Mule提供的转换工具和API - 如何使用Mule实现复杂的数据转换需求 - 数据转换策略和技术细节 - **第5章:...

    Mule MMC监控管理平台

    - 分析Mule应用程序中的消息处理流程。 - 提供了详细的统计信息,有助于优化应用程序性能。 19. **定义SLA和服务级别警报** - 设置服务级别协议(SLA),以确保服务质量和可用性。 - 可以定义特定条件下的警报...

    Mule in Action 2014

    本书不仅详细讲解了Mule ESB的基础知识和核心概念,还提供了大量实用的案例分析,帮助读者更好地理解如何在实际项目中应用Mule。例如: - **跨系统集成案例:** - 介绍如何使用Mule ESB连接不同的企业级系统,如...

    Mule 2 A Developer's Guide

    这一部分提供了一个实际的 Mule 配置文件示例,展示了如何组合上述所有元素来构建一个完整的 Mule 应用程序。 #### 第二章:路由器及其路由模式 **路由模式 (Routing Patterns)** 路由模式是设计集成解决方案时...

    Mule2.2 BookStore例子学习

    9. **源码分析**:分析提供的源码,了解每个部分的作用,如服务端点、处理逻辑、数据转换等,加深对Mule2.2工作原理的理解。 通过深入研究这个Mule2.2 BookStore实例,不仅可以掌握Mule的基本用法,还能了解到如何...

    mule学习2

    通过分析和运行这个示例,你可以学习如何配置和测试Mule应用,以及如何处理各种集成场景。 例如,它可能展示了一个从HTTP接收请求,通过DataWeave转换数据,然后通过JDBC连接器写入数据库的基本流程。这样的例子有...

    mule进阶之ibatis component

    5. **案例分析**:通过具体示例,展示如何使用iBatis组件执行CRUD(创建、读取、更新、删除)操作。这将帮助理解实际开发中的应用方法。 6. **源码解析**:深入到Mule iBatis组件的源码,了解其内部工作原理,这有...

    mule esb cookbook

    压缩包中的"Mule ESB Cookbook.pdf"很可能是书籍的电子版,包含了完整的章节和案例分析,读者可以通过阅读来学习Mule ESB的相关知识。而"9781782164401_code.zip"可能包含与书中的各个示例配套的源代码,这些代码...

    Mule ESB WebService Consumer 结合 DataMapper的使用

    - **XML配置示例**: ```xml ``` - **流程中引用**: ```xml ``` 2. **配置WebService Consumer** - **选择WebService Consumer组件**:在Mule Studio的Connector组件中找到WebService Consumer组件...

    mule-2.1.1-users-guide

    为了更好地理解Mule的配置,下面提供了一些示例: #### HTTP Transport 配置示例 ```xml [message.payload]" level="INFO"/&gt; ``` 此配置创建了一个监听8081端口的HTTP服务,并定义了一个处理HTTP请求的流程...

    Manning.Mule.in.Action.2nd.Edition.Feb.2014 及 源码

    附带的源码是书中示例的实现,读者可以下载并跟随书中步骤操作,这将极大地增强学习体验,加深对Mule ESB工作原理的理解。源码的分析和实践将帮助读者掌握实际开发中的技巧和最佳实践。 Mule ESB的强大之处在于其...

Global site tag (gtag.js) - Google Analytics