[發(fā)明專利]分布式數(shù)據(jù)接收方法、系統(tǒng)和用于分布式數(shù)據(jù)接收的裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201710700585.1
• 申請(qǐng)日: 2017-08-16
• 公開（公告）號(hào): CN109408219B
• 公開（公告）日: 2021-04-02
• 發(fā)明（設(shè)計(jì)）人: 王小剛;李亞峰;郭建
• 申請(qǐng)（專利權(quán)）人: 中國(guó)電信股份有限公司
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50
• 代理公司: 中國(guó)貿(mào)促會(huì)專利商標(biāo)事務(wù)所有限公司 11038
• 代理人: 劉劍波

1.一種分布式數(shù)據(jù)接收方法，其特征在于，包括：

獲取單位時(shí)間內(nèi)每個(gè)數(shù)據(jù)單位的數(shù)據(jù)量，其中，每個(gè)數(shù)據(jù)單位具有一個(gè)或多個(gè)數(shù)據(jù)源節(jié)點(diǎn)；

根據(jù)每個(gè)數(shù)據(jù)單位的數(shù)據(jù)量占總數(shù)據(jù)量的比值，在第一打分區(qū)間中為每個(gè)數(shù)據(jù)單位分配具有相應(yīng)比例的子區(qū)間；

獲取第二打分區(qū)間中每個(gè)數(shù)據(jù)接收節(jié)點(diǎn)對(duì)應(yīng)的子區(qū)間，其中，所述第二打分區(qū)間用于描述數(shù)據(jù)接收側(cè)各個(gè)數(shù)據(jù)接收節(jié)點(diǎn)的數(shù)據(jù)處理能力，所述第二打分區(qū)間和所述第一打分區(qū)間具有相同的起始點(diǎn)和覆蓋長(zhǎng)度；

基于第一打分區(qū)間中的子區(qū)間覆蓋范圍以及第二打分區(qū)間中的子區(qū)間的覆蓋范圍，確定每個(gè)數(shù)據(jù)單位的數(shù)據(jù)源節(jié)點(diǎn)所對(duì)應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)，包括：生成數(shù)據(jù)源節(jié)點(diǎn)對(duì)應(yīng)的隨機(jī)數(shù)，其中，隨機(jī)數(shù)的數(shù)值在對(duì)應(yīng)的數(shù)據(jù)源節(jié)點(diǎn)所屬的數(shù)據(jù)單位對(duì)應(yīng)的第一打分區(qū)間的子區(qū)間的覆蓋范圍內(nèi)；確定所述隨機(jī)數(shù)在第二打分區(qū)間中所屬的子區(qū)間，將確定的子區(qū)間對(duì)應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)確定為數(shù)據(jù)源節(jié)點(diǎn)所對(duì)應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)；

將每個(gè)數(shù)據(jù)源節(jié)點(diǎn)的數(shù)據(jù)發(fā)送給相應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)。

2.根據(jù)權(quán)利要求1所述的分布式數(shù)據(jù)接收方法，其特征在于，

在數(shù)據(jù)源節(jié)點(diǎn)發(fā)送每個(gè)數(shù)據(jù)之前，在數(shù)據(jù)源節(jié)點(diǎn)所屬的數(shù)據(jù)單位對(duì)應(yīng)的第一打分區(qū)間中的子區(qū)間內(nèi)生成隨機(jī)數(shù)；

將所述隨機(jī)數(shù)在第二打分區(qū)間中所屬的子區(qū)間對(duì)應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)確定為數(shù)據(jù)源節(jié)點(diǎn)的數(shù)據(jù)所對(duì)應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)。

3.根據(jù)權(quán)利要求1所述的分布式數(shù)據(jù)接收方法，其特征在于，根據(jù)每個(gè)數(shù)據(jù)接收節(jié)點(diǎn)的處理速率和/或負(fù)載，在第二打分區(qū)間中為每個(gè)數(shù)據(jù)單位分配具有相應(yīng)比例的子區(qū)間。

4.根據(jù)權(quán)利要求1或3所述的分布式數(shù)據(jù)接收方法，其特征在于，還包括：

當(dāng)某個(gè)數(shù)據(jù)接收節(jié)點(diǎn)發(fā)生故障時(shí)，重新為未發(fā)生故障的數(shù)據(jù)接收節(jié)點(diǎn)分配第二打分區(qū)間中的子區(qū)間。

5.一種用于分布式數(shù)據(jù)接收的裝置，其特征在于，包括：

數(shù)據(jù)量統(tǒng)計(jì)模塊，被配置為獲取單位時(shí)間內(nèi)每個(gè)數(shù)據(jù)單位的數(shù)據(jù)量，其中，每個(gè)數(shù)據(jù)單位具有一個(gè)或多個(gè)數(shù)據(jù)源節(jié)點(diǎn)；

第一打分區(qū)間分配模塊，被配置為根據(jù)每個(gè)數(shù)據(jù)單位的數(shù)據(jù)量占總數(shù)據(jù)量的比值，在第一打分區(qū)間中為每個(gè)數(shù)據(jù)單位分配具有相應(yīng)比例的子區(qū)間；

第二打分區(qū)間獲取模塊，被配置為獲取第二打分區(qū)間中每個(gè)數(shù)據(jù)接收節(jié)點(diǎn)對(duì)應(yīng)的子區(qū)間，其中，所述第二打分區(qū)間用于描述數(shù)據(jù)接收側(cè)各個(gè)數(shù)據(jù)接收節(jié)點(diǎn)的數(shù)據(jù)處理能力，所述第二打分區(qū)間和所述第一打分區(qū)間具有相同的起始點(diǎn)和覆蓋長(zhǎng)度；

收發(fā)關(guān)系確定模塊，被配置為基于第一打分區(qū)間中的子區(qū)間覆蓋范圍以及第二打分區(qū)間中的子區(qū)間的覆蓋范圍，確定每個(gè)數(shù)據(jù)單位的數(shù)據(jù)源節(jié)點(diǎn)所對(duì)應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)，包括：生成數(shù)據(jù)源節(jié)點(diǎn)對(duì)應(yīng)的隨機(jī)數(shù)，其中，隨機(jī)數(shù)的數(shù)值在對(duì)應(yīng)的數(shù)據(jù)源節(jié)點(diǎn)所屬的數(shù)據(jù)單位對(duì)應(yīng)的第一打分區(qū)間的子區(qū)間的覆蓋范圍內(nèi)；確定所述隨機(jī)數(shù)在第二打分區(qū)間中所屬的子區(qū)間，將確定的子區(qū)間對(duì)應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)確定為數(shù)據(jù)源節(jié)點(diǎn)所對(duì)應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)；

發(fā)送指示模塊，被配置為將每個(gè)數(shù)據(jù)源節(jié)點(diǎn)的數(shù)據(jù)發(fā)送給相應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)。

6.根據(jù)權(quán)利要求5所述的裝置，其特征在于，所述收發(fā)關(guān)系確定模塊進(jìn)一步被配置為：

在數(shù)據(jù)源節(jié)點(diǎn)發(fā)送每個(gè)數(shù)據(jù)之前，在數(shù)據(jù)源節(jié)點(diǎn)所屬的數(shù)據(jù)單位對(duì)應(yīng)的第一打分區(qū)間中的子區(qū)間內(nèi)生成隨機(jī)數(shù)；

將所述隨機(jī)數(shù)在第二打分區(qū)間中所屬的子區(qū)間對(duì)應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)確定為數(shù)據(jù)源節(jié)點(diǎn)的數(shù)據(jù)所對(duì)應(yīng)的數(shù)據(jù)接收節(jié)點(diǎn)。

7.根據(jù)權(quán)利要求5所述的裝置，其特征在于，所述第二打分區(qū)間獲取模塊進(jìn)一步被配置為根據(jù)每個(gè)數(shù)據(jù)接收節(jié)點(diǎn)的處理速率和/或負(fù)載，在第二打分區(qū)間中為每個(gè)數(shù)據(jù)單位分配具有相應(yīng)比例的子區(qū)間。

8.根據(jù)權(quán)利要求5或7所述的裝置，其特征在于，所述第二打分區(qū)間獲取模塊進(jìn)一步被配置為當(dāng)某個(gè)數(shù)據(jù)接收節(jié)點(diǎn)發(fā)生故障時(shí)，重新為未發(fā)生故障的數(shù)據(jù)接收節(jié)點(diǎn)分配第二打分區(qū)間中的子區(qū)間。