[發明專利]一種數據訂閱方法、裝置及代理訂閱設備

在審

• 申請號: 202210381940.4
• 申請日: 2022-04-12
• 公開（公告）號: CN114676153A
• 公開（公告）日: 2022-06-28
• 發明（設計）人: 譚啟超;張健文
• 申請（專利權）人: 樹根互聯股份有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/25;G06F16/28
• 代理公司: 北京超凡宏宇專利代理事務所(特殊普通合伙) 11463
• 代理人: 姚大雷

1.一種數據訂閱方法，其特征在于，應用于代理訂閱設備，所述代理訂閱設備連接源數據設備和至少一個用戶端設備，所述數據訂閱方法包括：

監聽所述源數據設備對應的各源數據主題是否更新；

獲取各源數據主題對應的增量數據；

將所述增量數據進行預設類型的數據處理，得到業務數據主題對應的業務數據，其中，所述預設類型的數據處理包括整合、分解和轉化，各業務數據主題與至少一個源數據主題關聯；

根據各用戶端設備發送的業務數據獲取請求，以及所述業務數據主題與各所述用戶端設備之間的預設訂閱關系，將所述業務數據發送至對應的用戶端設備。

2.根據權利要求1所述的數據訂閱方法，其特征在于，所述預設類型的數據處理為整合，將所述增量數據進行預設類型的數據處理，得到業務數據主題對應的業務數據的步驟，包括：

若業務數據主題與至少兩個源數據主題關聯，將各所述源數據主題對應的第一元數據進行合并，得到所述業務數據主題對應的第二元數據；

其中，所述第一元數據用于指示源數據主題對應的源數據的存儲區域，所述第二元數據對應的全部源數據為所述業務數據主題對應的業務數據。

3.根據權利要求1所述的數據訂閱方法，其特征在于，所述預設類型的數據處理為轉換，將所述增量數據進行預設類型的數據處理，得到業務數據主題對應的業務數據的步驟，包括：

根據預設的第一字段與第二字段之間的第一映射關系，通過字段映射將所述增量數據中的第一字段轉換為對應的第二字段，得到業務數據主題對應的業務數據。

4.根據權利要求1所述的數據訂閱方法，其特征在于，所述預設訂閱關系的創建步驟，包括：

接收用戶端設備發送的訂閱請求，其中，所述訂閱請求包括需要訂閱的業務數據主題以及所述用戶端設備對應的設備標識；

根據所述訂閱請求創建所述預設訂閱關系，其中，所述預設訂閱關系包括所述設備標識與需要訂閱的所述業務數據主題之間的第二映射關系。

5.根據權利要求4所述的數據訂閱方法，其特征在于，根據各用戶端設備發送的業務數據獲取請求，以及所述業務數據主題與各所述用戶端設備之間的預設訂閱關系，將所述業務數據發送至對應的所述用戶端設備的步驟，包括：

判斷所述業務數據主題對應的所述用戶端設備是否為免檢設備；

若所述業務數據主題對應的所述用戶端設備不是免檢設備，對所述用戶端設備發送的業務數據獲取請求進行校驗，所述業務數據獲取請求包括設備標識以及發送所述業務數據獲取請求對應的請求時間戳；

若校驗成功，將所述業務數據主題對應的所述業務數據發送至所述設備標識對應的所述用戶端設備。

6.根據權利要求5所述的數據訂閱方法，其特征在于，所述預設訂閱關系包括訂閱授權時間區間，對所述用戶端設備發送的業務數據獲取請求進行校驗的步驟，包括：

若所述業務數據獲取請求中的設備標識與所述預設訂閱關系中的設備標識相同，判斷所述請求時間戳是否處于所述訂閱授權時間區間內；

若所述請求時間戳處于所述訂閱授權時間區間內，判定校驗成功；

若所述請求時間戳不處于所述訂閱授權時間區間內，判定校驗失敗。

7.一種數據訂閱裝置，其特征在于，應用于代理訂閱設備，所述代理訂閱設備連接源數據設備和至少一個用戶端設備，所述數據訂閱裝置包括：

監聽模塊,用于監聽所述源數據設備對應的各源數據主題是否更新；

獲取模塊,用于獲取各源數據主題對應的增量數據；

處理模塊,用于將所述增量數據進行預設類型的數據處理，得到業務數據主題對應的業務數據，其中，所述預設類型的數據處理包括整合、分解和轉化，各業務數據主題與至少一個源數據主題關聯；

發送模塊,用于根據各所述用戶端設備發送的業務數據獲取請求，以及所述業務數據主題與各所述用戶端設備之間的預設訂閱關系，將所述業務數據發送至對應的所述用戶端設備。