[發(fā)明專利]服務(wù)發(fā)現(xiàn)系統(tǒng)、服務(wù)數(shù)據(jù)管理方法、服務(wù)器及存儲(chǔ)介質(zhì)

有效

• 申請(qǐng)?zhí)枺?/td>: 202010437872.X
• 申請(qǐng)日: 2020-05-21
• 公開(kāi)（公告）號(hào): CN111600958B
• 公開(kāi)（公告）日: 2023-06-02
• 發(fā)明（設(shè)計(jì)）人: 劉鳳鳴;陳旭升
• 申請(qǐng)（專利權(quán)）人: 廣州市百果園信息技術(shù)有限公司
• 主分類號(hào): H04L67/51
• 分類號(hào): H04L67/51;G06F16/27;H04L67/1097
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種服務(wù)發(fā)現(xiàn)系統(tǒng)，其特征在于，包括：一致性存儲(chǔ)服務(wù)層和服務(wù)接入層，所述服務(wù)接入層包括至少兩個(gè)服務(wù)接入點(diǎn)；

所述服務(wù)接入點(diǎn)，用于接收所創(chuàng)建第一服務(wù)的注冊(cè)請(qǐng)求，以接入所述第一服務(wù)，并將所述第一服務(wù)的服務(wù)上線數(shù)據(jù)寫入所述一致性存儲(chǔ)服務(wù)層；

所述一致性存儲(chǔ)服務(wù)層，用于在接收到所述服務(wù)上線數(shù)據(jù)后生成對(duì)應(yīng)的目標(biāo)全局序號(hào)，并關(guān)聯(lián)存儲(chǔ)所述目標(biāo)全局序號(hào)及所述服務(wù)上線數(shù)據(jù)；

所述一致性存儲(chǔ)服務(wù)層包括：

序號(hào)確定單元，用于在接收到所述服務(wù)上線數(shù)據(jù)后，確定本地存儲(chǔ)的當(dāng)前最大目標(biāo)全局序號(hào)，并將所述當(dāng)前最大目標(biāo)全局序號(hào)加一個(gè)確定值作為所述第一服務(wù)的目標(biāo)全局序號(hào)；

其中，多個(gè)服務(wù)接入點(diǎn)存在同時(shí)接入不同第一服務(wù)并將所對(duì)應(yīng)第一服務(wù)的服務(wù)上線數(shù)據(jù)同時(shí)寫入一致性服務(wù)存儲(chǔ)數(shù)據(jù)的可能。

2.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，

所述服務(wù)接入點(diǎn)，還用于向所述服務(wù)接入層中的其他各服務(wù)接入點(diǎn)廣播所述第一服務(wù)的上線數(shù)據(jù)寫入通知；

其他各服務(wù)接入點(diǎn)，分別用于在接收到所述上線數(shù)據(jù)寫入通知后，確定本地緩存的當(dāng)前待比對(duì)序號(hào)并反饋給所述一致性存儲(chǔ)服務(wù)層；

所述一致性存儲(chǔ)服務(wù)層，還用于根據(jù)接收的各當(dāng)前待比對(duì)序號(hào)，向所對(duì)應(yīng)服務(wù)接入點(diǎn)反饋待同步服務(wù)數(shù)據(jù)，以使所述第一服務(wù)的服務(wù)上線數(shù)據(jù)同步到所述服務(wù)接入層中的其他各服務(wù)接入點(diǎn)。

3.根據(jù)權(quán)利要求2所述的系統(tǒng)，其特征在于，所述一致性存儲(chǔ)服務(wù)層，具體用于：

對(duì)于每個(gè)其他服務(wù)接入點(diǎn)，接收到所述其他服務(wù)接入點(diǎn)的當(dāng)前待比對(duì)序號(hào)后，獲取當(dāng)前時(shí)刻本地對(duì)應(yīng)的當(dāng)前最大目標(biāo)全局序號(hào)；

將所述當(dāng)前待比對(duì)序號(hào)相對(duì)所述當(dāng)前最大目標(biāo)全局序號(hào)缺少的序號(hào)記為待同步全局序號(hào)，并將各所述待同步全局序號(hào)及相應(yīng)的服務(wù)上線數(shù)據(jù)作為待同步服務(wù)數(shù)據(jù)反饋給所述其他服務(wù)接入點(diǎn)；

其中，所述待同步全局序號(hào)中至少包括所述第一服務(wù)對(duì)應(yīng)的目標(biāo)全局序號(hào)。

4.根據(jù)權(quán)利要求2所述的系統(tǒng)，其特征在于，所述其他各服務(wù)接入點(diǎn)，還分別用于：

接收所述一致性存儲(chǔ)服務(wù)層對(duì)應(yīng)反饋的待同步服務(wù)數(shù)據(jù)，并將各所述待同步數(shù)據(jù)反饋給已接入的各第二服務(wù)，以使所述第一服務(wù)的服務(wù)上線數(shù)據(jù)同步在已接入的各第二服務(wù)中。

5.根據(jù)權(quán)利要求2所述的系統(tǒng)，其特征在于，所述其他各服務(wù)接入點(diǎn)，還分別用于：

信息接收單元，用于接收所述一致性存儲(chǔ)服務(wù)層對(duì)應(yīng)反饋的待同步服務(wù)數(shù)據(jù)并本地存儲(chǔ)；

數(shù)據(jù)反饋單元，用于在接收到所接入第三服務(wù)發(fā)送的數(shù)據(jù)同步請(qǐng)求后，確定所述第三服務(wù)當(dāng)前具備的基準(zhǔn)全局序號(hào)，并根據(jù)最大全局序號(hào)向所述第三服務(wù)發(fā)送待反饋服務(wù)數(shù)據(jù)，以使所述第一服務(wù)的服務(wù)上線數(shù)據(jù)在所接入的第三服務(wù)中同步。

6.根據(jù)權(quán)利要求5所述的系統(tǒng)，其特征在于，所述數(shù)據(jù)反饋單元，具體用于：

接收所接入第三服務(wù)發(fā)送的數(shù)據(jù)同步請(qǐng)求，獲取所述數(shù)據(jù)同步請(qǐng)求中包含的所述第三服務(wù)當(dāng)前具備的基準(zhǔn)全局序號(hào)；

提取當(dāng)前時(shí)刻本地存儲(chǔ)的當(dāng)前最大全局序號(hào)，并確定所述基準(zhǔn)全局序號(hào)相對(duì)所述當(dāng)前最大全局序號(hào)確定的增量序號(hào)；

從本地存儲(chǔ)中提取各增量序號(hào)對(duì)應(yīng)的服務(wù)上線數(shù)據(jù)形成待反饋服務(wù)數(shù)據(jù)并發(fā)送給所述第三服務(wù)。

7.一種服務(wù)數(shù)據(jù)管理方法，其特征在于，由權(quán)利要求1-6任一項(xiàng)所述的服務(wù)發(fā)現(xiàn)系統(tǒng)執(zhí)行，包括：

服務(wù)接入點(diǎn)接收所創(chuàng)建第一服務(wù)的注冊(cè)請(qǐng)求，以接入所述第一服務(wù)，并將所述第一服務(wù)的服務(wù)上線數(shù)據(jù)寫入一致性存儲(chǔ)服務(wù)層；

所述一致性存儲(chǔ)服務(wù)層在接收到所述服務(wù)上線數(shù)據(jù)后生成對(duì)應(yīng)的目標(biāo)全局序號(hào)，并關(guān)聯(lián)存儲(chǔ)所述目標(biāo)全局序號(hào)及所述服務(wù)上線數(shù)據(jù)。