Mule消息（message）的结构

Mule消息（message）的结构

Mule官方原文链接

本文所阐述的Mule消息的是指流程图中的消息而非批处理作业中的消息。批处理中的消息是被拆分成更小单位的记录（record）进行处理的，更多内容请见批处理的说明。

Mule消息（message）是应用中通过一个或者多个流程图进行处理的数据。它由两个主要的组成部分：

• 消息头（header），包含了消息的元数据。

• 消息负载（payload），包含了业务相关的数据。

Mule消息本身封装在Mule消息对象中。Mule对象可以带有变量，附件或者异常负载。使用或操作附件及异常负载的情况较少，所以这里不对这两者进行详细说明。

image

如果你对消息结构仍然有疑问，可以通过DataSense Explorer进行查看。

属性（Properties）和变量（Variables）

消息头中的元数据含有与消息重要信息相关的属性（Properties）。而消息对象中的变量（Variables）则带有消息相关数据。

属性和变量使用相同的格式：每个独立的属性或变量都有名称(name)和值(value)。通过名称(name)在Mule中对属性进行引用，在值(value)中保存着属性的实际信息。名称(name)好比是开门的钥匙，而值(value)是门后放着的物品。

消息中的属性和变量有特定的作用域来定义其在消息生命周期中的作用范围。当消息穿传输壁垒时（转入另一流程图或者传往其他的应用），属性中的元数据会随着消息继续传递，以促使处理继续并防止错误发生。

属性有两个主要的作用域：传入（inbound）与传出（outbound）

• 传入属性是不可更改的，由消息源自动生成，无法被使用者设值或更新。包含了由消息源生成的元数据，用以防止后续处理导致数据格式混乱或处理失当。传入属性只在当前流程图中有效；当消息离开流程图时，本流程图的传入属性生命周期结束。

image

• 传出属性是可变更的。可在流程图中创建，并且当消息由一个流程图的传出节点往其他流程图的传入节点进行传输时，会自动复制到其他流程图的传入属性中。传出属性包含着与传入属性类似的元数据，但是传出属性是在消息进入到流程图以后才会被设置的。传出属性可以由Mule自动设置，用户也可以通过往流程图中手动添加一个或多个转换器元素来进行设置。注意：当消息通过流程图引用而非通过连接器传入到新流程图中的时候，传出属性依然是传出属性、并不会被自动复制到传入属性。

image

变量是用户定义的关于消息的元数据。变量有三种作用域：

• Flow变量，只在其存在的流程图中有效。

• Session变量，在同一应用中的所有流程图中有效。

• Record变量，只在批处理操作中存在。

变量是消息存储信息的临时片段，是用于应用的处理过程，不应跟随消息进行传送。所以变量通常是人为设置，而属性则通常由系统设置和调用。不过Mule并没有对如何使用属性和变量做强制。

设置并使用属性与变量

Mule包含了三种消息处理器用以设置，复制或删除流程图中消息的传出属性和变量。使用时，Mule会相应的添加，复制或移除消息头部或对象中的元数据。（另外还有用作设置或删除批处理record变量的消息处理器。这里不做详细介绍）

需要用到属性与变量的可能场合有：想要往消息里增加一个HTTP头的属性，想在流程图中实现查找某用户关联的账户号码，或者你想往你的消息里添加一个保存账户号码元数据的变量。下表对三种消息处理器进行说明：属性转换器，变量转换器和Session变量转换器。

	属性	变量	Session变量
使用	使用属性转换器在消息的传出域设置、移除或复制属性	使用变量转换器来流程图作用域内设置或移除流程图变量	使用Session变量转换器在消息的整个生命周期中设置或者移除变量，可跨越多个流程图、应用甚至服务器
持久性	一旦消息抵达传出节点，传出域中的所有属性都会随消息一起被发送。其格式基于传出节点的传输协议（比如对于HTTP传出节点，就是会作为HTTP头被发送）	通过变量转换器设置的变量只持久与当前流程图，无法跨越传输壁垒	通过Session变量转换器设置的Session变量持久存在于消息的整个生命周期，可忽略传输壁垒。<br /><br />注意只有使用支持session的传输才能使session穿越传输壁垒。

例：下面的流程图在消息中设置了#[server.dateTime]（服务器当前时间）作为传出属性。

image

使用MEL表达式取服务器当前时间戳作为Value

image

为了取得流程图中已设置的或者应用中不同流程图中的属性或变量，可以使用MEL表达式。

类型	描述
传出属性	设置、删除或复制属性转换器</br >MEL Example:#[message.outboundProperties]
传入属性	指定传入属性</br >MEL Example:#[message.inboundProperties]
Session变量	设置或删除Session属性转换器</br >MEL Example:#[sessionVars]
变量	设置或删除变量转换器，或者复制变量</br >MEL Example:#[flowVars]

例如，如果你想要通过你先前设置的消息头中时间戳来对消息进行路由，你可以结合选择（choice）路由组件配合MEL表达式通过检查message.outboundProperties中的时间戳达成目标。在下面列出的代码片段中，MEL表达式会计算表达式获取属性值（即消息头中事先设置的时间戳）。

MEL Expression:

#[message.outboundProperties.timeStamp]

Example:

<choice doc:name="Choice">
<when expression="#[message.outboundProperties.timeStamp]">
    <logger level="INFO" doc:name="Logger"/>
</when>
<otherwise>
...
</otherwise>

</choice>

类似的，你可以通过MEL用“sessionVars”映射取得事先设置的session变量。比如，你设置了一个叫做SVname的session变量，你可以通过MEL表达式#[sessionVars['SVname']]来取得该变量。如果你设置的是变量而非session变量，把“sessionVars”换成“flowVars”即可。

消息负载（Payload）

消息负载是Mule消息中最重要的部分，Mule应用的首要任务就是处理其中的数据。消息头或者消息对象中的元数据的作用更多的是关于如何进行系统间通信或者是关于安全控制，而消息的核心，被传输的业务数据，才是我们创建消息的出发点。

流程图中的负载在传输过程中并不需要保持完全一致。Mule流程图中的各种消息处理器可以对负载进行设值、增强或格式转换。MEL表达式同样可以为从负载中提取信息提供帮助。

设置消息负载

使用Set Payload消息处理器可以彻底替换消息负载的内容。输入字符串或者MEL表达式就可以为Mule设置新的负载。下面的例子就将传入的消息负载替换成了字符串“Hello, my friend!”

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsdhttp://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsdhttp://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/schema/mule/ee/tracking/current/mule-tracking-ee.xsd">

<http:listener-config name="HTTP_Listener_Configuration" host="localhost" port="8081" doc:name="HTTP Listener Configuration"/>

<flow name="setting_propertiesFlow3" doc:name="setting_propertiesFlow3">
     <http:listener config-ref="HTTP_Listener_Configuration" path="replace" doc:name="HTTP"/>
    <set-payload value=""#['Hello, my friend!']"" doc:name="Set Payload"/>
</flow>

</mule>

增强消息负载

某些情况下，你可能需要调用外部资源后根据外部资源的响应来增强消息负载，而不是整个的替换。你可以通过使用Message Enricher作用域（或者称作包裹体）将一个或多个消息处理器封装起来。在获取所需的信息后，Mule会将这些信息添加或者增强到原先的消息负载中。

查看Mule消息

在Stuido中，你可以可视化的查看到流程图中任意某处的Mule消息结构。你只需要选择流程图中的元素然后点击DataSense图标既可。

image

DataSense explorer会被打开，同时显示进入该元素的消息的结构以及离开该元素的消息的结构。这样就可以查看该元素相关的变量和属性以及负载的内部结构。

![](http://wordpress-maxdu.oss-cn-shanghai.aliyuncs.com/docs.mulesoft.com/images/2018-02-11_113836.jpg">

Mule消息依赖于传入请求，Studio无法获知最起始的消息结构所以也无法显示。如果你知道起始的消息结构，你可以将其输入到传入连接器的Metadata页签。这样DataSense Explorer就可以显示在此之后的相应消息结构。

更多内容可查看使用DataSense Explorer

更多内容

• NEXT STEP: 了解消息状态
• 学习如何通过DataSense Explorer预览消息
• 更多关于变量转换器和Session变量转换器的内容
• 更多关于属性转换器的内容
• 更多关于设值和增强消息负载的内容
• 更多关于Record变量的内容