使用了两个类也就是两个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，例子演示的不是异常处理、演示的是：

• 所有的service components都是以spring bean的形式在一个mule配置文件当中配置的。
  
• error manager拥有多个outbound endpoints出站端点，例子演示了消息如何发布到不同端点。
• 消息是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）：

 客户的初始请求触发整个事件处理流，客户使用浏览器以htt协议请求mule rest服务，这个服务当然得向外暴露，暴露的方式就是配置贷款中介端点 (CustomerRequestsREST)

 这句话的配置含义：

 1、内嵌Jetty servlet引擎

 2、mule启动jetty在8888端口上监听rest请求

 3、把rest servlet绑定到/loanbroker上下文
来自客户的初始rest请求格式为：

贷款中介端点 以http参数形式接收下来，需要转换为CustomerQuoteRequest对象，所以增加了一个自定义转换器：


这个转换器要用在贷款中介端点 上，在贷款中介服务的入站inbound配置上、入站端点endpoint引用了贷款中介端点(CustomerRequestsREST)、同时也引用了这个转换器。也就是说从贷款中介端点 上接收的rest请求都直接用这个转换器予以转换：







@import url(http://www.blogjava.net/CuteSoft_Client/CuteEditor/Load.ashx?type=style&file=SyntaxHighlighter.css);@import url(/css/cuteeditor.css);