技术开发 频道

开源消息框架Mule配置基础

  Mule组件

  本节定义组成Mule消息框架的不同组件,并介绍如何用XML来配置这些组件,这里的讨论针对的是Mule 2.x版本。

  服务组件

  服务是Mule用于实施集成解决方案的主要元素,一个服务组件是一段实现了某些业务功能的代码,如图3所示。Mule的一个主要优点是服务组件可以是简单的没有预先存在外部接口的POJO(Plain Old Java Objects,简单Java对象),在Mule 1.x等早期版本中,服务组件被称为通用消息对象(universal message objects,UMO)。

 

  

图- 3 服务组件

  Mule为任何服务器组件提供了可插拔的连接性,使用特定的Mule配置设置,定义服务的特定行为,把外部消息转换成服务组件函数的调用,并控制它的生命周期,配置这个转换的是一个XML文件(默认是mule-config.xml),这个文件指定了消息流,应该指向服务组件。

  Mule消息

  Mule中的消息完全是一个数据包,它可以在一个特定通道上或端点上应用程序之间发送,一个消息也相当于一个由外部事件触发的事件,如收到队列中的数据或一个文件被拷贝到某个目录中,你可以使用Mule客户端编程产生Mule消息。

  服务端点

  端点的功能相当于网关,或者说是连接服务组件到外部消息的通道,它可以位于本地也可以位于网络上,如图4所示,Mule可以被配置为在端点上拦截消息,如果需要,然后将消息进行转换,转换后再传递给服务组件。

  

图- 4 入站(Inbound)和出站(Outbound)端点

  服务可以使用不同的传输器来接收和发送消息,对服务将要使用的每种传输器,你可以使用一个独立的端点。

  消息路由

  消息路由控制组件如何接收消息,以及在处理后应该发送到何处去,入站路由控制服务如何处理入站消息(如,有选择地允许那些符合特定标准的消息),出站路由控制服务处理完消息后该将其发往何处(如,将其发送到接收者的列表,或将消息拆分,然后发送到不同的端点),如图5所示。

  

图- 5 入站和出站路由

  路由是和过滤器结合工作的,过滤器指定限制条件,只有符合条件的消息才能被路由到服务,并包括一个表达式从当前消息中提取信息。

  传输器和连接器

  传输器实质上就是数据运输工具,它使用特定的协议在应用程序之间运输消息,如图6所示。Mule支持多个标准的传输器(JMS,HTTP等),并可以通过扩展org.mule.transport.AbstractConnector创建自定义传输器。

  

图- 6 Mule提供的传输器

  连接器表示特定传输器的配置,例如,JMS使用一个队列或一个主题来接收或发送数据,HTTP连接器使用一个端口来交换数据,具体的队列,主题和端口在连接器内部指定,连接器可以全局指定(为整个Mule应用程序)或在服务级本地指定。

  转换器

  数据转换是一种让迥然不同的组件之间可以相互理解对方的消息的技术,消息经历转换弥补了两个组件的数据表现之间的差异,Mule翻译器(也叫做转换器)是Java类,如图7所示。

 

 图- 7 转换器翻译消息

  转换的例子包括从一种XML消息转换成另一种XML格式,或将XML消息转换成Java对象,转换器用于将转换接收到的数据,然后以特定协议发送出去,如JMS传输器使用的ObjectToJMSMessage转换器。

  Mule配置了大量的转换器,并允许你通过扩展AbstractTransformer创建专用的转换器。

  服务可能被限制到本地网络或只能使用本地或私有的传输器,私有传输器不被外部应用程序支持,通过提供一个能够通过转换器转换和通过端点访问服务组件的消息框架,Mule为常见的intranet/Internet消息交换提供了一个组件服务。

  使用Mule客户端

  Mule客户端是一个为Java客户端从Mule服务器或其它应用程序接收或发送消息的简易接口,一般说来,消息是由外部事件触发的,如队列上接收到一个消息,或一个文件被拷贝到某个目录下。

  通过在单元测试或负载测试中引入消息,Mule客户端可以帮助测试消息流,如果你在相同的类加载器中使用Mule客户端(如一个Web应用程序或单独的Mule),客户端将会访问服务器配置,例如,如果在你的服务器配置文件中定义了以下端点:

 

<http:endpoint host="192.168.0.1" port="80" path="/services" name="serviceEndpoint"/>

 

  那么这个端点就可以被Mule客户端访问:

 

MuleClient client = new MuleClient();
client.dispatch(
"serviceEndpoint", dataObject, null);

 

  如果你以独立模式运行Mule客户端,你要使用它自己的Mule XML文件进行配置:

MuleClient client = new MuleClient();
client.dispatch(
"serviceEndpoint", dataObject, null);
0
相关文章