[發明專利]基于流計算引擎的可定制化模塊開發系統及方法

有效

• 申請號: 201511017694.0
• 申請日: 2015-12-29
• 公開（公告）號: CN106933549B
• 公開（公告）日: 2020-04-21
• 發明（設計）人: 顧剛
• 申請（專利權）人: 中移(蘇州)軟件技術有限公司;中國移動通信集團公司
• 主分類號: G06F8/10
• 分類號: G06F8/10;G06F8/20
• 代理公司: 北京派特恩知識產權代理有限公司 11270
• 代理人: 姚開麗;張振偉

1.一種基于流計算引擎的可定制化模塊開發系統，其特征在于，所述系統包括：組件設計模板、組件模板解析引擎、組件池、拓撲工廠以及拓撲提交解析引擎；

其中，所述組件設計模板用于使用戶根據所述組件設計模板創建組件集；

所述組件模板解析引擎用于對所述組件集進行解析；

所述組件池用于存放和記錄所述組件集；

所述拓撲工廠用于基于所述組件集向用戶提供構建拓撲結構的界面；

所述拓撲提交解析引擎用于對用戶所構建的拓撲結構進行解析，根據解析結果和與當前使用的流計算引擎對應的拓撲構建方式，建立適用于當前使用的流計算引擎的拓撲結構，并提交至流計算引擎。

2.根據權利要求1所述的系統，其特征在于，所述組件設計模板包括：功能組件集合和配置文件；

其中，所述功能組件集合包括多個功能組件；所述配置文件中包含所述功能組件集合的名稱以及每個所述功能組件的配置信息；

所述功能組件的配置信息包括：功能組件名稱、功能組件介紹、功能組件類型、功能組件類路徑、功能組件參數、功能組件輸入以及功能組件輸出。

3.根據權利要求2所述的系統，其特征在于，所述組件模板解析引擎具體用于：解析所述配置文件，根據所述配置文件，記錄所述功能組件的內容并將所述功能組件存放至所述組件池中。

4.根據權利要求3所述的系統，其特征在于，所述組件池包括數據存儲器和功能組件存儲池；

所述數據存儲器用于存放所述功能組件的配置信息；所述功能組件存儲池用于存儲并管理用戶創建的所述組件集。

5.根據權利要求4所述的系統，其特征在于，所述拓撲工廠包括拓撲工廠界面和拓撲關系生成器；

其中，所述拓撲工廠界面用于向用戶提供構建拓撲結構的界面，并根據所述功能組件集合搭建拓撲結構；所述拓撲關系生成器用于根據所述拓撲結構生成拓撲結構序列。

6.根據權利要求5所述的系統，其特征在于，所述拓撲提交解析引擎包括拓撲解析器和拓撲提交器；

所述拓撲解析器用于對所述拓撲關系生成器生成的拓撲結構序列進行解析，并根據解析結果和與當前使用的流計算引擎對應的拓撲構建方式，建立適用于當前使用的流計算引擎的拓撲結構；所述拓撲提交器用于將所述拓撲解析器建立的所述拓撲結構及使用的功能組件發送至所述流計算引擎。

7.一種基于流計算引擎的可定制化模塊開發方法，其特征在于，所述方法包括：

在拓撲工廠中，選取組件集中的功能組件類型，填寫功能組件參數，搭建拓撲結構；

根據所述拓撲結構，生成拓撲配置文件，所述拓撲配置文件中包含功能組件類型、功能組件參數、功能組件的內容、功能組件之間的關系、功能組件數據的分組方式，并將所述拓撲配置文件發送給拓撲提交解析引擎；

所述拓撲提交解析引擎解析所述拓撲配置文件，并從組件池中獲取相應的實例功能組件，并將所述拓撲配置文件中相應的所述功能組件參數注入所述實例功能組件；

所述拓撲提交解析引擎根據所述實例功能組件和當前使用的流計算引擎對應的拓撲構建方式，建立適用于當前使用的流計算引擎的拓撲結構并發送至所述流計算引擎。

8.根據權利要求7所述的方法，其特征在于，所述在拓撲工廠中，選取組件集中的功能組件類型，填寫功能組件參數，搭建拓撲結構之前，還包括：

利用組件設計模板創建所述組件集；所述組件設計模板包括：功能組件集合和配置文件；并將所述組件集傳輸到組件模板解析引擎；

所述組件模板解析引擎解析所述配置文件，根據所述配置文件，記錄所述功能組件的內容，將所述功能組件集合存放至所述組件池中。

9.根據權利要求8所述的方法，其特征在于，所述將所述組件集傳輸到組件模板解析引擎，包括：

將所述組件集以壓縮文件格式或jar文件格式傳輸到所述組件模板解析引擎。

10.根據權利要求9所述的方法，其特征在于，所述組件模板解析引擎解析所述配置文件，根據所述配置文件，記錄所述功能組件的內容，將所述功能組件集合存放至所述組件池中，包括：

所述組件模板解析引擎利用MD5校驗接收到的壓縮文件格式或jar文件格式的所述組件集，確保接收所述組件集在傳輸過程中無丟失后，讀取所述配置文件和功能組件集合；

所述組件模板解析引擎根據功能組件名稱，執行功能組件類路徑，校驗所述功能組件是否存在；在校驗成功后，將與所述功能組件對應的配置信息存放至所述組件模板解析引擎的數據存儲器對應的功能組件表中，并設定所述功能組件對應的功能組件集合的打包文件存放位置；

所述組件模板解析引擎遍歷所有功能組件后，將所述功能組件集合存放至所述組件池中。