EnjoyingSoft之Mule ESB基础系列第三篇:Mule message structure - Mule message结构

Posted enjoyingsoft

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了EnjoyingSoft之Mule ESB基础系列第三篇:Mule message structure - Mule message结构相关的知识,希望对你有一定的参考价值。

目录

Mule ESB是一个使用Java语言编写的开源企业服务总线,企业服务总线英文Enterprise Service Bus,简称ESB。其相关源代码也托管在GitHub上,可以在https://github.com/mulesoft/mule这里找到相关的Source Code。

MuleESB在众多开源的ESB中处于领先者的地位,已拥有超过数百万的下载量,以及来自世界各地数十万个开发人员。MuleSoft公司也作为开源软件中的独角兽,2017年在纽交所成功上市。我们作为MuleSoft的重要合作伙伴也参与其中,在六年多的时间里,使用Mule ESB社区版实施,或者Mule ESB企业版实施,构建众多Mule ESB开发案例,帮助国内众多的企业成功上线企业集成项目。

我们使用Mule ESB开发的过程中,体会到它优秀的架构设计和高效的开发速度。同时也深感Mule ESB书籍,Mule ESB中文文档资料非常稀少,所以使用8篇文章来写Mule ESB的基础系列教程,讲解Mule ESB功能和开发。

1. 探索Mule Message结构

很多开发者在开始使用Mule开发,很大原因是因为Mule的图形化开发环境非常友好,同时Mule Esb Transport也非常多,但对Mule最重要的Mule message概念并不特别熟悉。本篇重点讲解Mule的Message。

上一篇教程中已经说到,Flow的结构和构成元素,在Flow中流动的就是Mule Message。

技术分享图片

Mule Message是一个数据结构,也有相对应的Java Class。它包括几部分Payload,Property,Attachment。如下图所示:

技术分享图片

如何理解这幅图,大致可以和HTTP协议类比。

  • Property

    Mule Message的Property又分成Inbound Properties和Outbound Properties。这一点类似于HTTP协议的请求头和响应头。

  • Payload

    Mule的Payload是一个对象,类型是不固定的。可能是Stream,也可能是Hashmap,也可能是XML字符串。这一点类似于HTTP协议的请求正文,或者说是请求体。

  • Attachment

    Mule的Attachment就是消息的附件,这一点类似于HTTP协议中的multipartform-data请求。

技术分享图片

2. Mule Message的Payload

Payload翻译成中文是负荷,负载的意思。它是Mule Message的主要部分,也是Mule处理的主要对象。我们后续说的数据转换就是对Payload的转换。注意Mule Message的Payload是有可能为空的,比如接收到一个Http Get请求,Http Get请求的请求体是空的,所以这个时候Mule Message的Payload是空的。

3. Mule Message的Property

Mule Message的Property是一个键值对,有name和对应的value。Mule Message有两种类型的Property,Inbound Properties和Outbound Properties。Inbound Properties或者Outbound Properties可以有多个Property,也就是多个键值对。

Inbound Properties是不可变的,是由Message Source产生的。就类似于Http的请求参数,是由用户的数据请求,经过Java的Servlet,或者Asp.Net等框架封装成Http Request对象。

Outbound Properties是可变的,我们在Mule的Flow中新增或者改变这些属性。注意,比如转换器,有些Mule Processor会自动增加有些属性。

4. Mule Message的Attachment

Attachment,正如字面上意思,可以理解成消息的附件。想象一封邮件,有邮件发送人等头信息,也有邮件正文,同样还有邮件附件。和Property一样,Attachment也有两种类型,Inbound Attachment和Outbound Attachment。我们通常将一些大的对象作为附件传输。

5. Mule的Variable

Variable也就是变量,有几种类型的变量,或者说几种不同范围的变量,如下:Flow Variable,Session Variable,Record Variable。Flow Variable在一个Flow是有效的,Session Variable是可以跨Flow的,Record Variable则是处理数据列表时会用到。

这里不详细讲述。从使用上说,有些类似于Java里面的局部变量,Session变量,但不完全一致。后续实战文章会分析这一点。

6. 使用Java操作Mule Message

程序员来说,千言万语不如代码,如何使用Java操作Mule Message呢?通过Java代码我们可以清楚的看到Mule Message的结构,成员变量和方法等。

public void explorMessage(MuleMessage message) {
    // 获取InboundProperty
    String requestPath = message.getInboundProperty("http.request.path");
    // 设定OutboundProperty
    message.setOutboundProperty("content-type", "application/json");
    // 获取Payload
    Object payload = message.getPayload();
    // 获取InboundAttachment
    DataHandler fileAttachment = message.getInboundAttachment("fileName");
    // 获取flow变量
    message.getProperty("flowVarTest", PropertyScope.INVOCATION);
}

下图是Mule Message的类图,类图中只列表了重要的方法和属性。

技术分享图片

本文同步发文于EnjoyingSoft之Mule ESB基础系列第三篇:Mule message structure - Mule message结构

访问EnjoyingSoft 网站,获取更多Mule ESB 实施,Mule ESB 社区版 实施,Mule ESB实施,Mule ESB社区版实施帮助。

欢迎转载,但必须保留原文和此段声明,且在文章页面明显位置给出原文链接,否则保留追究法律责任的权利。

以上是关于EnjoyingSoft之Mule ESB基础系列第三篇:Mule message structure - Mule message结构的主要内容,如果未能解决你的问题,请参考以下文章

Mule ESB 连接到 RabbitMQ

Mule ESB-3.Build a webservice proxy

Mule ESB-3.Build a webservice proxy

如何使用 Mule ESB、Mule Studio 读取 CSV 文件并将数据插入 PostgreSQL

Mule ESB HornetQ JMS 消息未传递

Mule ESB 客户端超时