2. 程式人生 > >EnjoyingSoft之Mule ESB開發教程第六篇：Data Transform - 資料轉換

EnjoyingSoft之Mule ESB開發教程第六篇：Data Transform - 資料轉換

阿新 • • 發佈：2019-08-08

目錄

  • 1. 資料轉換概念
  • 2. 資料智慧感知 - DataSense
  • 3. 簡單資料轉換元件
    • 3.1 Object to JSON
    • 3.2 JSON to XML
    • 3.3 JSON to Object
    • 3.4 XML to JSON
  • 4. 企業版的DataWeave Transformer(視覺化高階資料轉換器)
  • 5. 社群版的InfoMapper(自研的視覺化資料轉換器)

本篇主要介紹在Mule ESB中使用資料轉換。資料轉換是ESB最核心的功能，它消除了異構應用之間的技術差異，讓不同的應用服務協調運作，實現了不同服務之間的通訊。資料轉換或者說訊息轉換，包括了資料結構，資料型別，資料內容的轉換等。

作為開源ESB產品中很成熟的平臺，Mule ESB內建很多的訊息轉換元件，比如Object to JSON，Object to XML，XML to JSON等，同時也支援使用自定義的Transformer來擴充自定義轉換邏輯。

另外Mule ESB企業版更擁有圖形化的訊息轉換元件DataWeave，可以很靈活的進行資料的轉換，包括一對一，一對多，多對一的對映。我們在社群版上也研發了相應的擴充套件元件InfoMapper，做到類似DataWeave的強大功能。

Mule ESB起源於一個社群專案，經過十多年的發展，Mule ESB擁有眾多的企業客戶案例，2017年成功在紐交所上市。我們作為MuleSoft的重要合作伙伴，參與其中，使用Mule ESB企業版實施開發，或者Mule ESB社群版實施開發，幫助國內眾多的行業領先客戶成功上線Mule ESB整合專案。

Mule ESB的原始碼託管在GitHub上，英文文件也非常豐富，Mule ESB的中文教程卻非常少，我們使用8篇Mule ESB的開發教程來幫助大家迅速上手Mule ESB開發。

  • EnjoyingSoft之Mule ESB開發教程第一篇：初識Mule ESB
  • EnjoyingSoft之Mule ESB開發教程第二篇：Mule ESB基本概念
  • EnjoyingSoft之Mule ESB開發教程第三篇：Mule message structure - Mule message結構
  • EnjoyingSoft之Mule ESB開發教程第四篇：Mule Expression Language - MEL表示式
  • EnjoyingSoft之Mule ESB開發教程第五篇：控制訊息的流向-資料路由
  • EnjoyingSoft之Mule ESB開發教程第六篇：Data Transform - 資料轉換
  • EnjoyingSoft之Mule ESB開發教程第七篇：SOAP Web Service的消費和建立
  • EnjoyingSoft之Mule ESB開發教程第八篇：使用API構建Rest Service

1. 資料轉換概念

資料轉換是ESB平臺的核心模組，是解決異構系統通訊的必備元件。舉個例子，訂單系統暴露了一個Web Service，而我們的網上商城生成的訂單是Json或者Flat file格式，將JSON資料或者Flat file文字格式轉換成Web Service的XML格式，這個需求就可以通過ESB來實現。我們在第三篇講解了Mule Message的結構，回憶一下Mule Message的結構。

我們通常說的資料轉換就是對Mule Message中Payload做操作，改變資料型別或者資料結構，資料內容等。在做資料轉換之前，我們需要確定資料的源型別和目標型別，然後選擇合適的資料轉換元件。

2. 資料智慧感知 - DataSense

DataSense是Mule最強大的功能之一，Anypoint Studio會主動獲取元資料型別和結構等資訊，以幫助開發者在應用程式中準確的對映或者使用資料。

DataSense配合企業版的DataWeave視覺化資料轉化元件，或者我們自研的社群版視覺化資料轉化元件InfoMapper，能夠很大的加速應用整合的開發，方便開發者完成資料轉換和對映。本文後半段會介紹DataWeave和InfoMapper的強大之處。

DataSense舉例說明，如果您的應用程式連線到一個天氣預報的Web Service，那麼DataSense會捕獲Web Service使用的資料型別和結構的資訊，這些資訊對開發者非常有用，它會展示這個Web Service期望的的入參是什麼，出參是什麼。

天氣預報WebService中規定的入參和出參如下圖：

Anypoint Studio中的Web Service Consumer元件，會清楚的顯示Expected Data，也就是期望的入引數據格式。如下圖Input頁籤，可以看到需要輸入theCityName的XML資料。

同時Web Service Consumer元件也會展示這個WebService的輸出引數是什麼。如下圖Output頁籤。

3. 簡單資料轉換元件

Mule ESB內建了很多常用的簡單的資料轉換元件，從元件名稱就可以看到元件的適用範圍，源資料型別和目標資料型別。另外Mule ESB也支援自定義Transformer，通過Java或者其他指令碼語言實現複雜的資料轉換邏輯。

3.1 Object to JSON

Object to JSON元件能夠將Java物件轉換成JSON格式，方便其他語言比如C#，Python解析和使用。常見的使用場景就是將Map物件轉換成JSON格式。

Mule UI Config:

Mule XML Config:

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

<mule xmlns:json="http://www.mulesoft.org/schema/mule/json"
    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.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd 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.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd">
    <http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/>
    <flow name="object-to-json-flow">
        <http:listener config-ref="HTTP_Listener_Configuration" path="/" doc:name="HTTP"/>
        <set-payload value="#[[&quot;orderNo&quot;:&quot;OST0001&quot;,&quot;orderAmount&quot;:1000]]" doc:name="Set Map Payload"/>
        <json:object-to-json-transformer doc:name="Object to JSON"/>
    </flow>
</mule>

使用Postman訪問，就可以得到一個標準的JSON資料。

{
    "orderAmount": 1000,
    "orderNo": "OST0001"
}

3.2 JSON to XML

JSON轉換成XML是很常用的轉換操作。JSON和XML都是有層級關係的資料展示結構，JSON和XML具體的區別和使用場景請參考其他文章。這裡需要強調是XML有一個唯一的根節點元素，而JSON根節點元素可能是一個物件，還可能是一個數組。使用Mule完成JSON to XML也很簡單。

Mule UI Config:

Mule XML Config:

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

<mule xmlns:json="http://www.mulesoft.org/schema/mule/json" 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.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd">
    <http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/>
    <flow name="json2xml-flow">
        <http:listener config-ref="HTTP_Listener_Configuration" path="/" doc:name="HTTP"/>
        <json:json-to-xml-transformer doc:name="JSON to XML"/>
    </flow>
</mule>

使用Postman提交Json，Json資料如下:

{
    "customer": {
        "cellPhone": "13912340002",
        "customerNo": "C0002",
        "customerName": "Alibaba"
    }
}

得到轉換之後的結果如下:

<?xml version='1.0'?>
<customer>
    <cellPhone>13912340002</cellPhone>
    <customerNo>C0002</customerNo>
    <customerName>Alibaba</customerName>
</customer>

這裡還是要再次強調一下，這個元件要求Json資料必須只有一個根節點。如果Json資料裡有多個根節點，則資料會丟失。舉例如下:

有多個根節點元素的Json資料:

{
    "cellPhone": "13912340002",
    "customerNo": "C0002",
    "customerName": "Alibaba"
}

轉換後的XML結果如下，可以看到只有第一個根元素被轉換成了XML。

<?xml version='1.0'?>
<cellPhone>13912340002</cellPhone>

3.3 JSON to Object

這個元件會將JSON資料轉成成一個Mule內建的Json物件，org.mule.module.json.JsonData。

Mule UI Config:

Mule XML Config:

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

<mule xmlns:json="http://www.mulesoft.org/schema/mule/json" 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.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd">
    <http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/>
    <flow name="json2object-flow">
        <http:listener config-ref="HTTP_Listener_Configuration" path="/" doc:name="HTTP"/>
        <json:json-to-object-transformer doc:name="JSON to Object"/>
        <logger message="#[message]" level="INFO" doc:name="Logger"/>
    </flow>
</mule>

通過列印的日誌可以看到，轉化後的payload是org.mule.module.json.JsonData。


org.mule.DefaultMuleMessage
{
  id=4b3b1290-b293-11e9-9351-005056c00001
  payload=org.mule.module.json.JsonData
  correlationId=<not set>
  correlationGroup=-1
  correlationSeq=-1
  encoding=UTF-8
  exceptionPayload=<not set>
}

3.4 XML to JSON

正如2.2章節所說，XML和Json的根節點元素存在差異。而XML的根節點元素是唯一的，所以XML to JSON比較簡單。

Mule UI Config:

Mule XML Config:

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

<mule xmlns:json="http://www.mulesoft.org/schema/mule/json" 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.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd">
    <http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8081" doc:name="HTTP Listener Configuration"/>
    <flow name="xml2json-flow">
        <http:listener config-ref="HTTP_Listener_Configuration" path="/" doc:name="HTTP"/>
        <json:xml-to-json-transformer doc:name="XML to JSON"/>
    </flow>
</mule>

使用Postman提交Xml，Xml資料如下:

<?xml version='1.0'?>
<customer>
    <cellPhone>13912340002</cellPhone>
    <customerNo>C0002</customerNo>
    <customerName>Alibaba</customerName>
</customer>

轉化後的JSON資料如下，可以看到這裡的Json是正確的。

{
    "customer": {
        "cellPhone": "13912340002",
        "customerNo": "C0002",
        "customerName": "Alibaba"
    }
}

4. 企業版的DataWeave Transformer(視覺化高階資料轉換器)

DataWeave是Mule企業版提供的視覺化的資料換器，使用這個元件可以通過拖拽的操作完成資料的對映。從下圖可以看到，DataWeave配合DataSense，通過拖拽連線的方式，可以將Http的請求資料轉換成Web Service Consumer期待的Xml資料，非常好用方便。

5. 社群版的InfoMapper(自研的視覺化資料轉換器)

上文提到的DataWeave是Mule企業版才提供的功能，社群版並不提供該元件。我們也可以通過擴充套件元件的方式達到類似的功能，我們自研的視覺化轉換元件InfoMapper，其功能和DataWeave相當。

資料轉換是ESB很常用的功能和使用場景，使用Anypoint Studio中提供的簡單資料轉換元件，或者企業版的DataWeave，社群版我們自研的InfoMapper這些高階轉換元件，配合強大的DataSense，資料轉換是非常輕鬆的事情。

本文同步發文於EnjoyingSoft Blogs

訪問EnjoyingSoft官網 ，獲取更多Mule ESB 社群版 實施幫助。

歡迎轉載，但必須保留原文和此段宣告，且在文章頁面明顯位置給出原文連結，否則保留追究法律責任的權

相關推薦

EnjoyingSoft之Mule ESB開發教程第六篇：Data Transform - 資料轉換

目錄 1. 資料轉換概念 2. 資料智慧感知 - DataSense 3. 簡單資料轉換元件 3.1 Object to JSON 3.2 JSON to XML 3.3 JS

EnjoyingSoft之Mule ESB開發教程第四篇：Mule Expression Language - MEL表示式

目錄 1. MEL的優勢 2. MEL的使用場景 3. MEL的示例 4. MEL的上下文物件 5. MEL的Variable 6. MEL訪問屬性 7. MEL操作符 本篇主要介紹Mule表示式語言，Mule Expression Language，簡稱MEL。MEL是

EnjoyingSoft之Mule ESB開發教程第五篇：控制訊息的流向-資料路由

目錄 1. 使用場景 2. 基於訊息頭的路由 2.1 使用JSON提交訂單的訊息 2.2 使用XML提交訂單的訊息 2.3 使用Choice元件判斷訂單格式

Spring Cloud系列教程 | 第六篇：Spring Cloud Zuul作為API閘道器實現請求路由轉發教程

推薦 Spring Cloud 視訊： Spring Cloud Zuul作為API閘道器實現請求路由轉發教程      當我們的架構實現前後端分離以後，前端和後端之間互動就是通過API閘道器進行，API閘道器兩個職責： 1.設計上的適配層，或稱Facade模

nginx教程第六篇：用HTTP核心模組配置一個靜態Web伺服器(二)

網路連線的設定 下面介紹網路連線的設定配置項： 1. 讀取HTTP頭部的超時時間 語法： client_header_timeout time（ 預設單位： 秒） ; 預設： client_header_timeout 60; 配置塊： http、 serve

EnjoyingSoft之Mule ESB基礎系列第二篇：Mule ESB基本概念

目錄 1. 使用Anypoint Studio開發 2. Mule ESB Application Structure - Mule ESB應用程式結構 3. Mule ESB Application整體構造 4. Mule ESB構造元素 - Flow 5. Mule ESB構造元素

第六篇 ：微信公眾平臺開發實戰Java版之如何自定義微信公眾號選單

我們來了解一下 自定義選單建立介面： 自定義選單查詢介面： 自定義選單刪除介面： 自定義選單介面可實現多種型別按鈕，如下： 1、click：點選推事件 使用者點選click型別按鈕後，微信伺服器會通過訊息介面推送訊息型別為event 的結構給開發者（參考訊息介面指

[043] 微信公眾平臺開發教程第19篇-應用例項之人臉檢測

CSDN2013年度部落格之星評選活動開始，本人有幸入圍參加評選，如果部落格中的文章對你有所幫助，請為柳峰投上寶貴一票，非常感謝！        在筆者的公眾賬號小q機器人（微訊號：xiaoqrobot）中有一個非常好玩的功能"人臉檢測"，它能夠檢測出使用者傳送的圖片中有多少

[042] 微信公眾帳號開發教程第18篇-應用例項之音樂搜尋

引言及內容概要 微信公眾平臺支援向用戶回覆音樂訊息，使用者收到音樂訊息後，點選即可播放音樂。通過音樂訊息，公眾賬號可以實現音樂搜尋（歌曲點播）功能，即使用者輸入想聽的音樂名稱，公眾賬號返回對應的音樂（歌曲）。讀者可以關注xiaoqrobot體驗該功能，操作指南及使用如下所示

Python開發【第六篇】：Python基礎條件和循環

ora back strong als 重復執行 操作 enume 條件表達式 服務 目錄 一、if語句 1、功能 2、語法 單分支，單重條件判斷 多分支，多重條件判斷 if + else 多分支if + elif + else 語句小結 + 案例 三元表達式 二、whil

Django之路第六篇：完善博客

也會 過程 object 通過 打包 但是 項目目錄 添加 實現 博客頁面設計 博客頁面概要 博客主頁面 博客文章內容頁面 博客撰寫頁面 博客主頁面 主頁面內容 文章標題列表，超鏈接 發表博客按鈕（超鏈接） 列表編寫思路 取出數據庫中所有文章

python全棧開發【第六篇】Python字符編碼

原理 如果 多語言 bubuko shift 滿足 避免 穩定性 都是 1.內存和硬盤都是用來存儲的。 CPU：速度快 硬盤：永久保存 2.文本編輯器存取文件的原理（nodepad++,pycharm,word） 　　　打開編輯器就可以啟動一個進程，是在內存中的，所

ES6之路第六篇：數組的擴展

最好 布爾 return lte 效果 不一致 List 集合 define index 擴展運算符 擴展運算符（spread）是三個點（...）。它好比 rest 參數的逆運算，將一個數組轉為用逗號分隔的參數序列。 1 console.log(...[1, 2, 3])

史上最簡單的SpringCloud教程 ｜ 第六篇： 分布式配置中心(Spring Cloud Config)(Finchley版本)

prope shu 由於 ext master strip div 文件配置 rap 在上一篇文章講述zuul的時候，已經提到過，使用配置服務來保存各個服務的配置文件。它就是Spring Cloud Config。 在分布式系統中，由於服務數量巨多，為了方便服務配置文件統

史上最簡單的SpringCloud教程 ｜ 第六篇： 分布式配置中心(Spring Cloud Config)

tex down 代碼 多少 erl ogr 管理 變量 實時 最新Finchley版本：https://www.fangzhipeng.com/springcloud/2018/08/30/sc-f6-config/或者http://blog.csdn.net/fore

NeuChar 平臺使用及開發教程（六）：成為開發者

　　在上一篇《NeuChar 平臺使用及開發教程（五）：使用 NeuChar 的關鍵字回覆服務》中，我們已經學習瞭如何命中關鍵字來反饋特定格式內容的資訊，這是由微信開發者/運營者自己來維護的資訊，那麼如果我們自己有微信開發的經驗，並且想要把這個能力釋放出來，為其他的公眾號，甚至小程式、釘釘等平臺提供服務，我們

史上最簡單的SpringCloud教程 ｜ 第六篇： 分散式配置中心(Spring Cloud Config)

最新Finchley版本： https://www.fangzhipeng.com/springcloud/2018/08/30/sc-f6-config/ 或者 http://blog.csdn.net/forezp/article/details/81041028

史上最簡單的SpringCloud教程 ｜ 第六篇： 分散式配置中心(Spring Cloud Config)(Finchley版本)

在上一篇文章講述zuul的時候，已經提到過，使用配置服務來儲存各個服務的配置檔案。它就是Spring Cloud Config。 在分散式系統中，由於服務數量巨多，為了方便服務配置檔案統一管理，實時更新，所以需要分散式配置中心元件。在Spring Cloud中，有分散式配置中心元件spri

Python開發【第六篇】：模組

模組，用一砣程式碼實現了某個功能的程式碼集合。  類似於函數語言程式設計和麵向過程程式設計，函數語言程式設計則完成一個功能，其他程式碼用來呼叫即可，提供了程式碼的重用性和程式碼間的耦合。而對於一個複雜的功能來，可能需要多個函式才能完成（函式又可以在不同的.py檔案中），n個 .py 檔案組成的程式

史上最簡單的SpringCloud教程 | 第六篇: 分散式配置中心(Spring Cloud Config)(Finchley版本)

在上一篇文章講述zuul的時候，已經提到過，使用配置服務來儲存各個服務的配置檔案。它就是Spring Cloud Config。 一、簡介 在分散式系統中，由於服務數量巨多，為了方便服務配置檔案統一管理，實時更新，所以需要分散式配置中心元件。在Spring Cloud中，