[發明專利]基于混合云的數據交換方法、裝置及計算機可讀介質

在審

• 申請號: 202010170388.5
• 申請日: 2020-03-12
• 公開（公告）號: CN111371621A
• 公開（公告）日: 2020-07-03
• 發明（設計）人: 岳現國
• 申請（專利權）人: 浪潮通用軟件有限公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L12/26;H04L29/08
• 代理公司: 濟南信達專利事務所有限公司 37100
• 代理人: 程佩玉

1.基于混合云的數據交換方法，其特征在于，包括：

根據預設的訂閱機制，將一數據提供方提供的一數據接口注冊為一數據服務，配置該數據服務的第一配置信息，所述第一配置信息包括來源云標識、來源系統標識及數據主體；

根據所述訂閱機制，將一數據消費方提供的一數據消費邏輯接口注冊為一訂閱者，配置該訂閱者的第二配置信息，所述第二配置信息包括來源云標識、來源系統標識及訂閱的數據服務；

在監聽到任一第一數據提供方提供任一目標數據時，根據配置的各個所述第一配置信息和各個所述第二配置信息，確定可訂閱所述目標數據的每一個第一訂閱者；

針對每一個所述第一訂閱者均執行：根據當前第一訂閱者的第二配置信息，將所述目標數據發送給所述當前第一訂閱者所屬的第一數據消費方。

2.根據權利要求1所述的方法，其特征在于，

在監聽到所述目標數據之后，進一步包括：將所述目標數據緩存至預設的緩存區；

在所述將所述目標數據發送給所述當前第一訂閱者所屬的第一數據消費方之后，進一步包括：接收所述第一數據消費方返回的、針對所述目標數據的訂閱成功通知；

在確定出每一個所述第一訂閱者均已返回針對所述目標數據的訂閱成功通知時，將所述目標數據從所述緩存區中刪除。

3.根據權利要求2所述的方法，其特征在于，

在監聽到所述目標數據時，進一步包括：記錄當前時間為所述目標數據的時間戳；

針對所述緩存區中緩存的每一個數據，均執行：根據當前數據的時間戳，實時監測所述當前數據的緩存持續時間是否達到預設時長，若是，將所述當前數據從所述緩存區中刪除。

4.根據權利要求2或3所述的方法，其特征在于，

所述將所述目標數據緩存至預設的緩存區，包括：采用Kafka中間件將所述目標數據緩存至預設的緩存區。

5.基于混合云的數據交換裝置，其特征在于，包括：

數據服務發布模塊，用于根據預設的訂閱機制，將一數據提供方提供的一數據接口注冊為一數據服務，配置該數據服務的第一配置信息，所述第一配置信息包括來源云標識、來源系統標識及數據主體；

數據服務訂閱模塊，用于根據所述訂閱機制，將一數據消費方提供的一數據消費邏輯接口注冊為一訂閱者，配置該訂閱者的第二配置信息，所述第二配置信息包括來源云標識、來源系統標識及訂閱的數據服務；

數據監聽模塊，用于在監聽到任一第一數據提供方提供任一目標數據時，觸發數據發布模塊；

所述數據發布模塊，用于根據配置的各個所述第一配置信息和各個所述第二配置信息，確定可訂閱所述目標數據的每一個第一訂閱者；

數據消費模塊，用于針對每一個所述第一訂閱者均執行：根據當前第一訂閱者的第二配置信息，將所述目標數據發送給所述當前第一訂閱者所屬的第一數據消費方。

6.根據權利要求5所述的基于混合云的數據交換裝置，其特征在于，

所述數據監聽模塊，用于將所述目標數據緩存至預設的緩存區；

所述數據消費模塊，用于接收所述第一數據消費方返回的、針對所述目標數據的訂閱成功通知；在確定出每一個所述第一訂閱者均已返回針對所述目標數據的訂閱成功通知時，將所述目標數據從所述緩存區中刪除。

7.根據權利要求6所述的基于混合云的數據交換裝置，其特征在于，

所述數據監聽模塊，用于在監聽到所述目標數據時，記錄當前時間為所述目標數據的時間戳；

所述數據消費模塊，用于針對所述緩存區中緩存的每一個數據，均執行：根據當前數據的時間戳，實時監測所述當前數據的緩存持續時間是否達到預設時長，若是，將所述當前數據從所述緩存區中刪除。

8.根據權利要求6或7所述的基于混合云的數據交換裝置，其特征在于，

所述數據監聽模塊，用于采用Kafka中間件將所述目標數據緩存至預設的緩存區。