[發(fā)明專利]一種數(shù)據(jù)訂閱方法、裝置及代理訂閱設(shè)備

在審

• 申請(qǐng)?zhí)枺?/td>: 202210381940.4
• 申請(qǐng)日: 2022-04-12
• 公開（公告）號(hào): CN114676153A
• 公開（公告）日: 2022-06-28
• 發(fā)明（設(shè)計(jì)）人: 譚啟超;張健文
• 申請(qǐng)（專利權(quán)）人: 樹根互聯(lián)股份有限公司
• 主分類號(hào): G06F16/23
• 分類號(hào): G06F16/23;G06F16/25;G06F16/28
• 代理公司: 北京超凡宏宇專利代理事務(wù)所(特殊普通合伙) 11463
• 代理人: 姚大雷

本申請(qǐng)?zhí)峁┮环N數(shù)據(jù)訂閱方法、裝置及代理訂閱設(shè)備。該方法包括：監(jiān)聽源數(shù)據(jù)設(shè)備對(duì)應(yīng)的各源數(shù)據(jù)主題是否更新；獲取各源數(shù)據(jù)主題對(duì)應(yīng)的增量數(shù)據(jù)；將增量數(shù)據(jù)進(jìn)行預(yù)設(shè)類型的數(shù)據(jù)處理，得到業(yè)務(wù)數(shù)據(jù)主題對(duì)應(yīng)的業(yè)務(wù)數(shù)據(jù)，其中，預(yù)設(shè)類型的數(shù)據(jù)處理包括整合、分解和轉(zhuǎn)化，各業(yè)務(wù)數(shù)據(jù)主題與至少一個(gè)源數(shù)據(jù)主題關(guān)聯(lián)；根據(jù)各用戶端設(shè)備發(fā)送的業(yè)務(wù)數(shù)據(jù)獲取請(qǐng)求，以及業(yè)務(wù)數(shù)據(jù)主題與各用戶端設(shè)備之間的預(yù)設(shè)訂閱關(guān)系，將業(yè)務(wù)數(shù)據(jù)發(fā)送至對(duì)應(yīng)的用戶端設(shè)備。本申請(qǐng)通過代理訂閱設(shè)備將源數(shù)據(jù)主題對(duì)應(yīng)的增量數(shù)據(jù)處理為用戶端設(shè)備能夠接收的業(yè)務(wù)數(shù)據(jù)，解除了數(shù)據(jù)源與用戶側(cè)之間的業(yè)務(wù)耦合，降低了數(shù)據(jù)源與用戶側(cè)的對(duì)接成本。

技術(shù)領(lǐng)域

本申請(qǐng)涉及數(shù)據(jù)傳輸領(lǐng)域，尤其涉及一種數(shù)據(jù)訂閱方法、裝置及代理訂閱設(shè)備。

背景技術(shù)

當(dāng)用戶需要獲取某些最新數(shù)據(jù)以進(jìn)行展示或業(yè)務(wù)處理時(shí)，通常會(huì)使用消息隊(duì)列中間件從數(shù)據(jù)源訂閱相應(yīng)的數(shù)據(jù)主題。這樣的方法需要用戶對(duì)所需要獲取的數(shù)據(jù)有較深入的了解，才能找到數(shù)據(jù)源的地址，以從數(shù)據(jù)源選擇合適的數(shù)據(jù)主題，并獲取到所需要的最新數(shù)據(jù)。

在用戶不了解數(shù)據(jù)以及數(shù)據(jù)源的情況下，不能直接獲取到所需要的數(shù)據(jù)主題以及對(duì)應(yīng)的數(shù)據(jù)。因此，上述數(shù)據(jù)獲取方法要求用戶有一定的技術(shù)理解，使得數(shù)據(jù)源與用戶側(cè)的對(duì)接成本較大。

發(fā)明內(nèi)容

為了解決上述技術(shù)問題，本發(fā)明提供了一種數(shù)據(jù)訂閱方法、裝置及代理訂閱設(shè)備，具體方案如下：

第一方面，本申請(qǐng)實(shí)施例提供了一種數(shù)據(jù)訂閱方法，應(yīng)用于代理訂閱設(shè)備，所述代理訂閱設(shè)備連接源數(shù)據(jù)設(shè)備和至少一個(gè)用戶端設(shè)備，所述數(shù)據(jù)訂閱方法包括：

監(jiān)聽所述源數(shù)據(jù)設(shè)備對(duì)應(yīng)的各源數(shù)據(jù)主題是否更新；

獲取各源數(shù)據(jù)主題對(duì)應(yīng)的增量數(shù)據(jù)；

將所述增量數(shù)據(jù)進(jìn)行預(yù)設(shè)類型的數(shù)據(jù)處理，得到業(yè)務(wù)數(shù)據(jù)主題對(duì)應(yīng)的業(yè)務(wù)數(shù)據(jù)，其中，所述預(yù)設(shè)類型的數(shù)據(jù)處理包括整合、分解和轉(zhuǎn)化，各業(yè)務(wù)數(shù)據(jù)主題與至少一個(gè)源數(shù)據(jù)主題關(guān)聯(lián)；

根據(jù)各用戶端設(shè)備發(fā)送的業(yè)務(wù)數(shù)據(jù)獲取請(qǐng)求，以及所述業(yè)務(wù)數(shù)據(jù)主題與各所述用戶端設(shè)備之間的預(yù)設(shè)訂閱關(guān)系，將所述業(yè)務(wù)數(shù)據(jù)發(fā)送至對(duì)應(yīng)的用戶端設(shè)備。

根據(jù)本申請(qǐng)公開的一種具體實(shí)施方式，所述預(yù)設(shè)類型的數(shù)據(jù)處理為整合，將所述增量數(shù)據(jù)進(jìn)行預(yù)設(shè)類型的數(shù)據(jù)處理，得到業(yè)務(wù)數(shù)據(jù)主題對(duì)應(yīng)的業(yè)務(wù)數(shù)據(jù)的步驟，包括：

若業(yè)務(wù)數(shù)據(jù)主題與至少兩個(gè)源數(shù)據(jù)主題關(guān)聯(lián)，將各所述源數(shù)據(jù)主題對(duì)應(yīng)的第一元數(shù)據(jù)進(jìn)行合并，得到所述業(yè)務(wù)數(shù)據(jù)主題對(duì)應(yīng)的第二元數(shù)據(jù)；

其中，所述第一元數(shù)據(jù)用于指示源數(shù)據(jù)主題對(duì)應(yīng)的源數(shù)據(jù)的存儲(chǔ)區(qū)域，所述第二元數(shù)據(jù)對(duì)應(yīng)的全部源數(shù)據(jù)為所述業(yè)務(wù)數(shù)據(jù)主題對(duì)應(yīng)的業(yè)務(wù)數(shù)據(jù)。

根據(jù)本申請(qǐng)公開的一種具體實(shí)施方式，所述預(yù)設(shè)類型的數(shù)據(jù)處理為轉(zhuǎn)換，將所述增量數(shù)據(jù)進(jìn)行預(yù)設(shè)類型的數(shù)據(jù)處理，得到業(yè)務(wù)數(shù)據(jù)主題對(duì)應(yīng)的業(yè)務(wù)數(shù)據(jù)的步驟，包括：

根據(jù)預(yù)設(shè)的第一字段與第二字段之間的第一映射關(guān)系，通過字段映射將所述增量數(shù)據(jù)中的第一字段轉(zhuǎn)換為對(duì)應(yīng)的第二字段，得到業(yè)務(wù)數(shù)據(jù)主題對(duì)應(yīng)的業(yè)務(wù)數(shù)據(jù)。

根據(jù)本申請(qǐng)公開的一種具體實(shí)施方式，所述預(yù)設(shè)訂閱關(guān)系的創(chuàng)建步驟，包括：

接收用戶端設(shè)備發(fā)送的訂閱請(qǐng)求，其中，所述訂閱請(qǐng)求包括需要訂閱的業(yè)務(wù)數(shù)據(jù)主題以及所述用戶端設(shè)備對(duì)應(yīng)的設(shè)備標(biāo)識(shí)；

根據(jù)所述訂閱請(qǐng)求創(chuàng)建所述預(yù)設(shè)訂閱關(guān)系，其中，所述預(yù)設(shè)訂閱關(guān)系包括所述設(shè)備標(biāo)識(shí)與需要訂閱的所述業(yè)務(wù)數(shù)據(jù)主題之間的第二映射關(guān)系。

根據(jù)本申請(qǐng)公開的一種具體實(shí)施方式，根據(jù)各用戶端設(shè)備發(fā)送的業(yè)務(wù)數(shù)據(jù)獲取請(qǐng)求，以及所述業(yè)務(wù)數(shù)據(jù)主題與各所述用戶端設(shè)備之間的預(yù)設(shè)訂閱關(guān)系，將所述業(yè)務(wù)數(shù)據(jù)發(fā)送至對(duì)應(yīng)的所述用戶端設(shè)備的步驟，包括：

判斷所述業(yè)務(wù)數(shù)據(jù)主題對(duì)應(yīng)的所述用戶端設(shè)備是否為免檢設(shè)備；