[發明專利]基于企業服務總線的數據傳輸調度方法、裝置及服務器

有效

• 申請號: 201611217919.1
• 申請日: 2016-12-26
• 公開（公告）號: CN106844496B
• 公開（公告）日: 2020-04-10
• 發明（設計）人: 劉爽爽;高隆林;張文治;吳丹丹;王興東;趙雷
• 申請（專利權）人: 山東中創軟件商用中間件股份有限公司
• 主分類號: G06F16/25
• 分類號: G06F16/25;H04L29/08
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 羅滿

技術領域

本發明涉及數據傳輸技術領域，更具體地說，涉及一種基于企業服務總線的數據傳輸調度方法、裝置及服務器。

背景技術

企業服務總線是傳統中間件技術與XML、Web服務等技術結合的產物。企業服務總線提供了網絡中最基本的連接中樞，是構筑企業神經系統的必要元素。從功能上看，企業服務總線提供了事件驅動和文檔導向的處理模式，以及分布式的運行管理機制，它支持基于內容的路由和過濾，具備了復雜數據的傳輸能力，并可以提供一系列的標準接口。在企業服務總線中信息量的急劇增加，越來越多的企業發現現存的傳統數據存儲、處理方式已經無法應付數據的增長速度，更無法滿足用戶對數據處理的需求。

因此，如何解決傳統數據庫存儲能力和數據分析能力不足的問題，提高系統處理效率，是本領域技術人員需要解決的。

發明內容

本發明的目的在于提供一種基于企業服務總線的數據傳輸調度方法、裝置及服務器，以實現解決傳統數據庫存儲能力和數據分析能力不足的問題，提高系統處理效率。

為實現上述目的，本發明實施例提供了如下技術方案：

一種基于企業服務總線的數據傳輸調度方法，包括：

接收數據操作請求；

判斷與所述數據操作請求對應的數據是否為結構化數據；

若是，則調用第一服務；所述第一服務用于當與所述數據操作請求對應的數據需要執行Hadoop操作時，通過Hive數據庫響應所述數據操作請求；

若否，則調用第二服務；所述第二服務通過Hbase數據庫響應所述數據操作請求。

其中，若與所述數據操作請求對應的數據為結構化數據，且與所述數據操作請求對應的數據需要進行傳統操作時，通過傳統數據庫響應所述數據操作請求。

其中，所述接收數據操作請求之前，還包括：

在第一裝置中配置第一模型，所述第一模型用于通過Sqoop工具，將傳統數據庫中的數據抽取至Hive數據庫，通過Hive腳本實現Hive數據庫對數據操作請求的響應；

將所述第一裝置中的第一模型包裝成所述第一服務，并將所述第一服務部署至服務器。

其中，所述接收數據操作請求之前，還包括：

在第二裝置中配置第二模型，所述第二模型用于通過Hbase數據庫實現對數據操作請求的響應，完成數據的分布式操作；

將所述第二裝置中的第二模型包裝成所述第二服務，并將所述第二服務部署至服務器。

一種基于企業服務總線的數據傳輸調度裝置，包括：

接收模塊，用于接收數據操作請求；

判斷模塊，用于判斷與所述數據操作請求對應的數據是否為結構化數據；

第一調度模塊，用于與所述數據操作請求對應的數據為結構化數據時，調用第一服務；所述第一服務用于當與所述數據操作請求對應的數據需要執行Hadoop操作時，通過Hive數據庫響應所述數據操作請求；

第二調度模塊，用于與所述數據操作請求對應的數據為非結構化數據時，調用第二服務；所述第二服務通過Hbase數據庫響應所述數據操作請求。

其中，還包括：

執行模塊，用于在與所述數據操作請求對應的數據為結構化數據，且與所述數據操作請求對應的數據需要進行傳統操作時，通過傳統數據庫響應所述數據操作請求。

其中，還包括：

第一模型配置模塊，用于在第一裝置中配置第一模型，所述第一模型用于通過Sqoop工具，將傳統數據庫中的數據抽取至Hive數據庫，通過Hive腳本實現Hive數據庫對數據操作請求的響應；

第一部署模塊，用于將所述第一裝置中的第一模型包裝成所述第一服務，并將所述第一服務部署至服務器。

其中，還包括：

第二模型配置模塊，用于在第二裝置中配置第二模型，所述第二模型用于通過Hbase數據庫實現對數據操作請求的響應，完成數據的分布式操作；

第二部署模塊，用于將所述第二裝置中的第二模型包裝成所述第二服務，并將所述第二服務部署至服務器。

一種服務器，包括上述任意一項數據傳輸調度裝置。

通過以上方案可知，本發明實施例提供的一種基于企業服務總線的數據傳輸調度方法，包括：接收數據操作請求；判斷與所述數據操作請求對應的數據是否為結構化數據；若是，則調用第一服務；所述第一服務用于當與所述數據操作請求對應的數據需要執行Hadoop操作時，通過Hive數據庫響應所述數據操作請求；若否，則調用第二服務；所述第二服務通過Hbase數據庫響應所述數據操作請求；