[發(fā)明專利]一種編排數(shù)據(jù)處理與接口服務調(diào)用方法

有效

• 申請?zhí)枺?/td>: 202110413134.6
• 申請日: 2021-04-16
• 公開（公告）號: CN112948152B
• 公開（公告）日: 2022-10-18
• 發(fā)明（設計）人: 邵健鋒;朱國全;林鑒;鄭立凡
• 申請（專利權(quán)）人: 深圳市今天國際物流技術股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種編排數(shù)據(jù)處理與接口服務調(diào)用方法，為了克服服務與服務間做數(shù)據(jù)對接時，遇到的各種不確定性與變化，導致需要人為進行開發(fā)、調(diào)整、測試、部署的問題，其特征在于：包括動態(tài)生成http服務接口、http請求調(diào)用、webservice服務接口、webservice請求調(diào)用、定時任務、消息訂閱和發(fā)布、生成sql進行數(shù)據(jù)入庫及各種不同的數(shù)據(jù)格式與結(jié)構(gòu)的相互轉(zhuǎn)換，并能將功能進行編排串聯(lián)成一個數(shù)據(jù)流程，編排過程中根據(jù)運行時的值進行條件判斷路由選擇，具體實現(xiàn)步驟如下：

S1,先根據(jù)需要，創(chuàng)建出服務節(jié)點，服務節(jié)點包括http服務接口節(jié)點、webservice服務接口節(jié)點、定時器節(jié)點、消息訂閱節(jié)點，這類服務節(jié)點的特征是能產(chǎn)生數(shù)據(jù)流入到整個數(shù)據(jù)路由流程中；一個數(shù)據(jù)路由必須要有服務節(jié)點;

S2,根據(jù)需要，創(chuàng)建數(shù)據(jù)轉(zhuǎn)換節(jié)點，針對服務節(jié)點中流入到數(shù)據(jù)路由中的數(shù)據(jù)進行數(shù)據(jù)處理，具體為數(shù)據(jù)格式轉(zhuǎn)換或數(shù)據(jù)結(jié)構(gòu)轉(zhuǎn)換，如果數(shù)據(jù)不需要轉(zhuǎn)換，則不需要數(shù)據(jù)轉(zhuǎn)換節(jié)點;

S3,根據(jù)需要，創(chuàng)建分支節(jié)點，對上一個節(jié)點輸出的數(shù)據(jù)進行邏輯判斷，以決定下一步要流向哪個節(jié)點，如果數(shù)據(jù)只會有一個流向，則不需要創(chuàng)建分支節(jié)點;

S4,根據(jù)需要，創(chuàng)建調(diào)用服務請求節(jié)點，調(diào)用服務請求節(jié)點包括http請求節(jié)點、webservice請求節(jié)點、消息發(fā)布節(jié)點、sql數(shù)據(jù)操作節(jié)點，調(diào)用服務節(jié)點的特征是能將數(shù)據(jù)作為參數(shù)調(diào)用相應的服務節(jié)點，并得到返回信息，如果數(shù)據(jù)不需要作為參數(shù)去調(diào)用服務，則不需要創(chuàng)建調(diào)用服務；

S5,根據(jù)需要重復S1-S4，再將各節(jié)點連線指明從一個服務流向另一個服務；

S6,根據(jù)用戶的編排，進行解析，找到流程定義中的開始節(jié)點，開始節(jié)點為平臺接口；

S7,以開始節(jié)點進行深度遍歷,開始節(jié)點只會是服務節(jié)點，因此根據(jù)服務的類型創(chuàng)建對應的服務，http_server即通過netty動態(tài)創(chuàng)建http服務，webservice_server則先通過javassist動態(tài)生成接口，再通過apache cxf基于動態(tài)生成的接口創(chuàng)建webservice服務；

S8,遍歷與上一個節(jié)點相連的節(jié)點，如果當前節(jié)點是服務節(jié)點，因為平臺接口只能有一個，所以其他服務節(jié)點只能是外部接口節(jié)點，http_client會通過netty創(chuàng)建httpclient發(fā)起http請求，webservice_client會通過cxf創(chuàng)建webservice客戶端；

S9,如果遍歷的當前節(jié)點是數(shù)據(jù)轉(zhuǎn)換節(jié)點，則根據(jù)數(shù)據(jù)轉(zhuǎn)換的類型，創(chuàng)建對應的數(shù)據(jù)處理器jsonToMaap，通過jackson對json進行轉(zhuǎn)換；

S10,如果遍歷的當前節(jié)點是數(shù)據(jù)轉(zhuǎn)換節(jié)點，則會根據(jù)用戶配置的源數(shù)據(jù)格式和目標數(shù)據(jù)格式映射，按源數(shù)據(jù)的每個字段進行遍歷，如果字段配置了表達式，則根據(jù)表達式進行解析得到相應的值作為與源字段相對應的目標字段的值，字段有配置條件表達式則先進行條件判斷，如果條件不滿足則跳過該字段；

S11,根據(jù)數(shù)據(jù)路由定義，把對應節(jié)點創(chuàng)建的各服務節(jié)點，數(shù)據(jù)轉(zhuǎn)換節(jié)點按編排的順序串聯(lián)起來；

S12,在運行時數(shù)據(jù)通過服務節(jié)點接收數(shù)據(jù)進行流轉(zhuǎn)的過程中，上一個節(jié)點的輸出會作為下一個節(jié)點的輸入?yún)?shù)。