MULE ESB环境搭建和例子(通过装插件的方式)

环境搭建和例子：

Download mule standaloe from web site:

1.    http://www.mulesoft.org/download-mule-esb-community-edition

2.    Unzip to a path(such as:
D:\mulesl312)

 

Installing Mule IDE in Eclipse

3.    Start Eclipse, and set up a workspace foryour installation of Mule if you haven't already. (Make sure your workspacedoes not have a space in the directory path)

4.    In the workbench view, choose Help >Install New Software.

5.    Press the Add button next to the Work withtext box, enter
http://dist.muleforge.org/mule-ide/updates/3.4/ and press
Enter. The Mule IDE now appears in your list ofavailable software.

6.    Select the Mule IDE check box and click
Next,and after Eclipse processes for a moment, click Next again.

7.    Review the Mule IDE license, select theoption to accept the license, and then click
Finish.

8.    Click
Yes to restart Eclipse.

9.    Set Mule Distributions in eclipse:

 

 

 

 

You are now ready to configure the Muledistribution as described in the next section.

Config MULE_HOME and add bin to path:

10.  MULE_HOME: D:\mulesl312

11.  Path:%Path%; %MULE_HOME%\bin

 

Create a new Mule project:

 

 

How to Import  a  existing project to Mule project and run it:

there is some ecamples in example folder of MULE,wecanimport 
them

We neeed to add Mule classpath lib to the project

 

Then we can run the project on Muleruntime like as:

 

So server starts:

NFO  2011-06-22 11:38:01,125 [main]org.mule.module.management.agent.JmxAgent: Registered Endpoint Service withname:Mule.04cd6ac8-9c81-11e0-95b7-8bd1ea0dc252:type=Endpoint,service="HelloWorld",connector=connector.http.mule.default,name="endpoint.http.localhost.8888"

INFO  2011-06-22 11:38:01,125 [main]org.mule.module.management.agent.JmxAgent: Registered Connector Service withnameMule.04cd6ac8-9c81-11e0-95b7-8bd1ea0dc252:type=Connector,name="connector.servlet.mule.default.1"

INFO  2011-06-22 11:38:01,125 [main]org.mule.module.management.agent.JmxAgent: Registered Connector Service withnameMule.04cd6ac8-9c81-11e0-95b7-8bd1ea0dc252:type=Connector,name="connector.stdio.mule.default.1"

INFO  2011-06-22 11:38:01,125 [main] org.mule.module.management.agent.JmxAgent:Registered Connector Service with nameMule.04cd6ac8-9c81-11e0-95b7-8bd1ea0dc252:type=Connector,name="connector.VM.mule.default.1"

INFO  2011-06-22 11:38:01,125 [main]org.mule.module.management.agent.JmxAgent: Registered Connector Service withnameMule.04cd6ac8-9c81-11e0-95b7-8bd1ea0dc252:type=Connector,name="connector.http.mule.default.1"

INFO  2011-06-22 11:38:01,140 [main]org.mule.DefaultMuleContext:

**********************************************************************

* Mule ESB and IntegrationPlatform                                 *

* Version: 3.1.2 Build:21975                                       *

* MuleSoft, Inc.                                                    *

* For more information go tohttp://www.mulesoft.org                
*

*                                                                   *

* Server started: 11-6-22 上午11:38                               
*

* Server ID:04cd6ac8-9c81-11e0-95b7-8bd1ea0dc252                   
*

* JDK: 1.6.0_10-rc2 (mixedmode, sharing)                           *

* OS encoding: UTF-8, Muleencoding: UTF-8                          *

* OS: Windows XP - Service Pack3 (5.1, x86)                        
*

* Host: PC-201103071221(192.168.40.61)                  
           *

* Mode: Development                                                 *

*                                                                   *

* Agents Running:                                                   *

*   JMX Agent                                                        *

**********************************************************************

访问URL

 

mule-config.xml:

 <inbound-endpoint
address="http://localhost:8888"
transformer-refs="HttpRequestToNameString"exchange-pattern="request-response">

  <not-filter>

  <wildcard-filter
pattern="/favicon.ico"/>

        </not-filter>

   </inbound-endpoint>

 

//所有的转换器都在此，就我理解所有的转换过程其实都要自己写，可以自己定义通用的转换器重用并扩展。

//public class ChatStringToString extends
AbstractTransformer 父类

    <custom-transformer
name="StringToNameString"
class="org.mule.example.hello.StringToNameString"/>

    <custom-transformer
name="NameStringToChatString"
class="org.mule.example.hello.NameStringToChatString"/>

    <custom-transformer
name="ChatStringToString"
class="org.mule.example.hello.ChatStringToString"/>

    <custom-transformer
name="HttpRequestToNameString"
class="org.mule.example.hello.HttpRequestToNameString"/>

    <custom-transformer
name="ExceptionToString"
class="org.mule.example.hello.ExceptionToString"/>

    <custom-transformer
name="HttpRequestToParameter"
class="org.mule.transport.servlet.transformers.HttpRequestToParameter"/>

    <custom-transformer
name="ObjectToString"
class="org.mule.transformer.simple.ObjectToString"/>

 

 

 

 

 

 

 

 

理论和模型：

 

1.
简介

Mule ESB是一个基于Java的轻量级企业服务总线和集成平台，允许开发人员快速便利地连接多个应用，并支持应用间的数据交换。Mule
ESB支持集成现有系统而无论其底层采用何种技术，如JMS、Web Services、JDBC、HTTP以及其他技术。

2.
整体结构

图整体结构

从上图可见，Mule通过Transports/Connectors与外围的异构系统连接，提供Routing（路由）、Transaction
Management（事务管理）、Transformation（转换）、Message Broker（消息代理）、Transportation
Management（传输管理）、Security（安全）等核心模块。Mule可以单独使用，也可以架设在常用的应用服务器上。

图架构简图

外围系统的服务请求通过Mule ESB的Transport接入，Mule通过Transformer进行数据的格式转换，然后经过Inbound
Router进行消息过滤（内部通过配置filter实现）后交给Mule的Component进行业务逻辑处理，处理后的结果通过Outbound
Router确定传递给哪个接收方，然后通过Transformer进行数据格式转换，通过Transport连接至接收方，传递信息。

此图描述的是Mule中的一个典型场景的处理过程，涵盖了Mule中的各个关键组件。其中某些处理步骤不是必须的，如Inbound
Router、Transformer。后续可以看到一些其他场景的处理。

3.
功能

a.
服务中介

·        将业务逻辑和消息发送分离

·        屏蔽服务的消息格式和协议

·        提供任意位置的服务调用

·        提供协议桥接

b.
数据转换

·        在应用间交换不同格式的信息 

·        操作消息的负载内容，包括加密、压缩和编码转换

·        在异构的传输协议的数据类型间格式化消息

c.
消息路由

·        基于消息内容和复杂规则路由消息

·        消息的过滤、聚合以及重新排列序号

d.
服务创建和托管

·        暴露端点、EJB、Spring Bean以及POJO作为服务

·        作为轻量级的服务容器进行服务托管

Mule ESB中有一些基本的概念，理解这些基本概念后才能理解Mule的内部机制。从中也可以看到Mule解决问题的基本思路。

 

4.
基本概念

4.1 Model

Model表示托管各个服务的运行时环境。

图 Model

4.2 Service

Service是用来处理服务请求的基本单位，它调用各个组件进行服务请求的处理。

图 Service

4.3 Transport

Transport管理消息的接收和发送，数据转换的过程也是在Transport中通过调用Transformer完成的。

图 Transport

4.3.1 Connector

Connector用于管控特定协议的使用，如HTTP Connector、JMS Connector等。

4.3.2 End-Point

Endpoint用于表示一种协议的特定使用方式，如listening/polling、从中读取、向指定地址写入等，定义了发送和接收消息的通道。Endpoint控制的是底层的实体在Connector中如何被使用。

Endpoint定义于Inbound和Outbound Router中。

4.4 Transformer

Transformer用于转换消息的内容。

图 Transformer

4.5 Router

Router使用Filter基于消息中的属性信息进行消息的分发。

图 Router

Router在Service中的位置决定了Router的性质（inbound、outbound和response）和担任的角色（pass-through、aggregator等）。

4.6 Component

Component是Service的核心部件，是Service的业务逻辑的实现。

图 Component: implicit bridge component

Component可以是Java Class（POJO、Spring
Bean）、Web Service、Script等。

Component可定义自己的生命周期：initialise、start、stop、dispose，不过需要实现Mule的LifeCycle接口。Mule
3.0版本开始提供@PostConstruct和@PreDestroy的注解，对应生命周期的initialise和dispose阶段，不需要实现Mule的LifeCycle接口了。

4.7 Flow（@since 3.0）

Flow是Mule 3.0新引入的，包含一个消息源（Message Source）和多个消息处理器组成的处理器链。

图 Flow

 

根据实际需求着重检查了一下Mule ESB的消息传递方式。Mule支持常用的几种消息传递方式，能够满足要求。

 

5.
消息传递方式

5.1
异步方式

异步方式是一种单向调用，调用者不需要获得响应。

图 Asynchronous

异步方式通过inbound和outbound endpoint的exchange-pattern=”one-way”实现。

使用基本的Stdio Transport验证，通过标准输入传输字符串，将其原样传递给标准输出进行显示。相应配置如下：

 

xml 代码

1.  <service name="echo">    

2.      <inbound>    

3.          <stdio:inbound-endpoint system="IN" exchange-pattern="one-way" />    

4.      </inbound>    

5.          

6.      <component>    

7.          <singleton-object class="demo.mule.umo.StdIo" />    

8.      </component>    

9.          

10.     <outbound>    

11.         <pass-through-router>    

12.             <stdio:outbound-endpoint system="OUT" exchange-pattern="one-way" />    

13.         </pass-through-router>    

14.     </outbound>    

15. </service>    

运行服务，控制台显示结果如下：

 

1.  Please enter: Hello, world!    

2.  INFO  2010-12-07 19:21:18,877 [ConsoleConnector.dispatcher.1]    

3.      org.mule.lifecycle.AbstractLifecycleManager: Initialising:    

4.      'ConsoleConnector.dispatcher.23255376'. Object is: StdioMessageDispatcher    

5.  INFO  2010-12-07 19:21:18,877 [ConsoleConnector.dispatcher.1]    

6.      org.mule.lifecycle.AbstractLifecycleManager: Starting:    

7.      'ConsoleConnector.dispatcher.23255376'. Object is: StdioMessageDispatcher    

8.  Hello, world!    

其中INFO输出是Mule第一次初始化相应Connector打印出来的，之后调用服务不会再次显示。

异步方式适用于简单的消息传递的场景。

5.2
请求-响应方式

请求-响应方式即请求方调用服务后，服务立即处理并返回响应结果，不需将消息再次传递。

图 Request-Response

请求-响应方式通过input endpoint的exchange-pattern=”request-response”实现，相应配置如下：

 

xml 代码

1.  <strong>  

2.      <strong>  

3.          <model name="services">        

4.              <service name="echoService">        

5.                  <inbound>        

6.                      <inbound-endpoint address="http://localhost:7007/services/Echo"        

7.                          exchange-pattern="request-response">        

8.                          <cxf:jaxws-service />        

9.                      </inbound-endpoint>        

10.                 </inbound>        

11.                 <component>        

12.                     <singleton-object class="demo.mule.umo.Echo" />        

13.                 </component>        

14.             </service>        

15.         </model>  

16.     </strong>  

17. </strong>   

上边是通过service配置的，通过flow配置如下：

 

xml 代码

1.  <flow name="EchoFlow">        

2.      <inbound-endpoint address="http://localhost:7007/services/Echo"        

3.          exchange-pattern="request-response" />        

4.      <cxf:jaxws-service serviceClass="demo.mule.umo.Echo" />        

5.      <component>        

6.          <singleton-object class="demo.mule.umo.Echo" />        

7.      </component>        

8.  </flow>    

在浏览器中输入“http://localhost:7007/services/Echo/echo/text/hello,world”，浏览器中会显示“hello,world”的输出信息。

请求-响应方式适用于单次服务调用的场景。

5.3
同步方式

同步方式即请求方调用服务后，component将处理结果发送给另一个外部服务处理，并将处理结果反方向返回。

图 Synchronous

同步方式通过inbound和outbound endpoint的exchange-pattern=”request-response”实现，相应配置如下：

 

xml 代码

1.  <flow name="echo">      

2.      <inbound-endpoint address="http://localhost:7007/services/Echo"      

3.          exchange-pattern="request-response" />      

4.      <cxf:jaxws-service serviceClass="demo.mule.umo.Echo" />      

5.      <component>      

6.          <singleton-object class="demo.mule.umo.StdIo" />      

7.      </component>      

8.      <vm:outbound-endpoint path="vm" exchange-pattern="request-response" />      

9.  </flow>      

10. <flow name="vm">      

11.     <vm:inbound-endpoint path="vm" exchange-pattern="request-response" />      

12.     <component>      

13.         <singleton-object class="demo.mule.umo.Vm" />      

14.     </component>      

15.     <stdio:outbound-endpoint system="OUT" exchange-pattern="one-way" />      

16. </flow>    

同步方式适用于通过Mule调用远程服务的场景。

5.4
异步请求-响应方式

异步请求-响应方式即请求方调用服务后不需要立即获得返回结果，component将请求发送给其他外围系统处理（可能有多个），全部处理完毕后通过指定的异步应答Router返回给请求方。

图 Asynchronous Request-Response

异步请求-响应方式通过在OutBound Endpoint中增加reply-to以及增加async-reply节点实现，响应配置如下：

 

xml 代码

1.  <flow name="echo">      

2.      <inbound-endpoint address="http://localhost:7007/services/Echo"      

3.          exchange-pattern="request-response" />      

4.      <cxf:jaxws-service serviceClass="demo.mule.umo.Echo" />      

5.      <component>      

6.          <singleton-object class="demo.mule.umo.StdIo" />      

7.      </component>      

8.      <vm:outbound-endpoint path="vm" exchange-pattern="request-response" />      

9.  </flow>      

10. <flow name="vm">      

11.     <vm:inbound-endpoint path="vm" exchange-pattern="request-response" />      

12.     <component>      

13.         <singleton-object class="demo.mule.umo.Vm" />      

14.     </component>      

15.     <stdio:outbound-endpoint system="OUT" exchange-pattern="one-way" />      

16. </flow>    

异步请求-响应方式适用于请求需要被多个远程服务并行处理，结果需要汇总处理后返回的场景。

注：上述代码未运行通过，queue1和queue2获得了请求消息并正常处理，但返回至async-reply时抛出异常，暂未定位到问题。

后将collection-async-reply-router改为single-async-reply-router未报异常，代码示例如下：

 

xml 代码

1.  <em><service name="async req-rep">      

2.      <inbound>      

3.          <stdio:inbound-endpoint ref="stdioInEndpoint" />      

4.      </inbound>      

5.      <component class="demo.mule.umo.Echo" />      

6.      <outbound>      

7.          <multicasting-router>      

8.              <vm:outbound-endpoint path="async.queue1" exchange-pattern="one-way" />      

9.              <vm:outbound-endpoint path="async.queue2" exchange-pattern="one-way" />      

10.             <reply-to address="vm://reply" />      

11.         </multicasting-router>      

12.     </outbound>      

13.     <async-reply timeout="5000" failOnTimeout="true">      

14.         <vm:inbound-endpoint path="reply" exchange-pattern="one-way" />      

15.         <single-async-reply-router />      

16.     </async-reply>      

17. </service></em>  

 

 

附加参考图：

 

 

 

 

 

 

时间： 2024-03-05 07:41:19

MULE ESB环境搭建和例子(通过装插件的方式)的相关文章

详解Cocos2dx 3.0正式版本开发环境搭建（Win32/Android）

cocos2d-x 3.0发布有一段时间了,作为一个初学者,我一直觉得cocos2d-x很坑.每个比较大的版本变动,都会有不一样的项目创建方式,每次的跨度都挺大-- 但是凭心而论,3.0RC版本开始 环境搭建.项目创建.编译的方式更加人性化了. 现在我们进入正题,一步一步搭建cocos2dx的开发环境 cocos2d-x很多tools都是需要使用Python的,因此我们需要先安装Python环境 python下载:点这里 这里需要下载Python 2.X版本.曾经以为要下载3.x版本 后来装上发

Mule ESB 学习笔记（11）Web Service Proxy(这里是一个可以正常运行的例子)

一.WebSevice Proxy 简介      WebService Proxy 是ESB中最常见的使用场景之一,即通过 ESB 直接转发 WebService Client 的 SOAP 请求,并将 WebServcie Provider 的 SOAP 响应转发给 WebService Client ,此时的ESB就是一个WebService Proxy.   二.WebSevice Proxy 在 Mule 中的产生背景       Mule3.0 新增了一些比较有亮点的新特性 ,其中包

J2ME开发环境搭建 之 EclipseMe

J2ME开发环境搭建 之 EclipseMe   第一节    初识Eclipse Eclipse是一个开发源代码,基于java的可扩展开发平台,它是在OSI(Open Software Initiative 开发源代码计划)认可的通用公共许可证(CPL)版下被授予许可证的集成开发平台(IDE).作为当今最流行的java开发IDE之一,java社群使用Eclipse以及基于Eclipse技术而来的IBM Websphere的开发者已经超过了半数. Eclipse本身只是一个框架和一组响应的服务,

jdk+eclip+android sdk实现Android开发环境搭建

一 相关下载 (1) java JDK下载: 进入该网页: http://java.sun.com/javase/downloads/index.jsp (或者直接点击下载)如下图: 开发环境搭建-jdk环境搭建"> 选择 Download JDK 只下载JDK,无需下载jre. (2)eclipse下载 进入该网页: http://www.eclipse.org/downloads/ (或者直接点击下载:BT下载    HTTP下载) 如下图: 我们选择第一个(即eclipse IDE

windows下JAVA敏捷开发环境搭建步骤教程

  编程开发环境搭建还是挺重要的,第一步是先要搭建环境,有了环境才能开展工作.本文我们来看看windows下JAVA敏捷开发环境搭建步骤. 整个软件项目分为四个环境 开发本地环境.开发环境.测试环境.IDC环境.和传统C++开发不一样的模式是多了第一个开发本地环境.这是为什么呢,因为目前大部分开发人员还是比较熟悉windows下开发.对于mac和linux下直接使用软件并且开发的中国开发者还是少之又少,这套架构就这个现状做出来的.如下是环境搭建架构图: 从环境来说: 一.开发本地环境.开发集成服

Appium+python自动化环境搭建

Appium+python自动化环境搭建 一.环境准备 环境是Windows10版本 64位系统    1.jdk1.6.0 (64位)    2.android-sdk_r24.4.1-windows    3.python:2.7(3.6也可以)    4.appium:1.4.16.1    5.Node.js:node-v4.4.7-x64    6.Appium-Python-Client   二.android的测试开发环境 1.介绍 以下为安卓的测试开发环境安装步骤,请一步一步操作

基于AIR Android应用开发1：环境搭建

基于AIR Android应用开发 --环境搭建 1.  AIR SDK之于Android AIR SDK是一组打包和部署AIR应用程序的工具.它与工具捆绑,所以无需额外的安装.工具负责访问这些文件,不需要有你进行任何管理.AIR SDK有下面这些组件构成. 图0:AIR SDK组件图 n  AIR Develop Tool(ADT) AIR使用Java编写的多用途工具.它需要Java 1.5或更高的版本才能运行,用于为Android设备打包AIR应用程序.它根据指定的目标来创建不同的包: l 

Redux教程1：环境搭建，初写Redux

[序] 如果将React比喻成士兵的话,你的程序还需要一位将军,去管理士兵(的状态),而Redux恰好是一位好将军,简单高效: 相比起React的学习曲线,Redux的稍微平坦一些:本系列教程,将以"红绿灯"为示例贯穿整个demo,希望能让用户快速理解&学习Redux: 强烈推荐 Redux 中文文档,本redux教程所有的材料和思路都来源于此: 这个系列拆分成3篇文章,最后获得的效果图为: (这个是gif图,如果没动画请点击在新窗口打开) 红绿灯初始状态是 绿灯5s,继而循环

android 的NDK在Windwos环境搭建

NDK的Windwos环境搭建Eclipse版本是3.6以上的    一.下载android NDK您可以下载NDK r4  for Windows或NDK r5  for Windows安装包,下载地址:地址:http://developer.android.com/sdk/ndk/index.html   下载后解压缩到你的工作目录,例如:E:\Android\tools\android-ndk-r7,结果如下图:   Android NDK包含build.docs.samples.sour