[發(fā)明專利]分布式圖數(shù)據(jù)處理方法和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201710014047.7
• 申請(qǐng)日: 2017-01-09
• 公開（公告）號(hào): CN106815080B
• 公開（公告）日: 2020-01-14
• 發(fā)明（設(shè)計(jì)）人: 李建欣;曹英杰;李博;張揚(yáng)揚(yáng)
• 申請(qǐng)（專利權(quán)）人: 北京航空航天大學(xué)
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50
• 代理公司: 11205 北京同立鈞成知識(shí)產(chǎn)權(quán)代理有限公司
• 代理人: 楊澤;劉芳

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

在第一從計(jì)算節(jié)點(diǎn)執(zhí)行完本輪迭代處理，并且判斷消息隊(duì)列中不存在待處理的第二計(jì)算消息、以及判斷當(dāng)前處理的分塊中不存在活躍頂點(diǎn)時(shí)，在等待接收目標(biāo)從計(jì)算節(jié)點(diǎn)發(fā)送的回復(fù)響應(yīng)的過(guò)程中，判斷是否接收到第二從計(jì)算節(jié)點(diǎn)發(fā)送的第二計(jì)算消息，其中，所述目標(biāo)從計(jì)算節(jié)點(diǎn)為接收所述第一從計(jì)算節(jié)點(diǎn)發(fā)送的第一計(jì)算消息的從計(jì)算節(jié)點(diǎn)；

若是，則執(zhí)行下一輪迭代處理；

若判斷沒(méi)有接收到所述第二計(jì)算消息，則在接收到所述目標(biāo)從計(jì)算節(jié)點(diǎn)發(fā)送的回復(fù)響應(yīng)后，將迭代處理過(guò)程中的處理信息發(fā)送給服務(wù)器；其中，所述處理信息包括所述第一從計(jì)算節(jié)點(diǎn)在迭代處理過(guò)程中發(fā)送的第一計(jì)算消息的個(gè)數(shù)以及接收的第二計(jì)算消息的個(gè)數(shù)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將迭代處理過(guò)程中的處理信息發(fā)送給服務(wù)器之后，所述方法還包括：

在等待接收主計(jì)算節(jié)點(diǎn)發(fā)送的控制命令的過(guò)程中，判斷是否接收到所述第二從計(jì)算節(jié)點(diǎn)發(fā)送的第二計(jì)算消息；

若是，則執(zhí)行下一輪迭代處理。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，在執(zhí)行下一輪迭代處理之前，所述方法還包括：

向服務(wù)器發(fā)送刪除命令，所述刪除命令用于指示所述服務(wù)器刪除所述處理信息；

向所述第二從計(jì)算節(jié)點(diǎn)發(fā)送回復(fù)響應(yīng)。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

按照預(yù)設(shè)的分塊的優(yōu)先級(jí)對(duì)分塊進(jìn)行迭代處理；其中，優(yōu)先級(jí)高的分塊的活躍頂點(diǎn)的數(shù)目大于優(yōu)先級(jí)低的分塊的活躍頂點(diǎn)的數(shù)目。

5.根據(jù)權(quán)利要求1-4任一項(xiàng)所述的方法，其特征在于，所述方法還包括：

在第一從計(jì)算節(jié)點(diǎn)向目標(biāo)從計(jì)算節(jié)點(diǎn)發(fā)送所述第一計(jì)算消息時(shí)，判斷所述第一從計(jì)算節(jié)點(diǎn)的發(fā)送緩沖區(qū)的消息緩存量是否大于預(yù)設(shè)閾值；

若是，則停止發(fā)送所述第一計(jì)算消息。

6.一種分布式圖數(shù)據(jù)處理方法，其特征在于，包括：

從服務(wù)器中獲取每個(gè)從計(jì)算節(jié)點(diǎn)發(fā)送的處理信息；其中，所述處理信息包括所述每個(gè)從計(jì)算節(jié)點(diǎn)在迭代處理的過(guò)程中發(fā)送的第一計(jì)算消息的個(gè)數(shù)和接收的第二計(jì)算消息的個(gè)數(shù)；

判斷所述每個(gè)從計(jì)算節(jié)點(diǎn)在迭代處理的過(guò)程中發(fā)送的第一計(jì)算消息的個(gè)數(shù)之和與所述每個(gè)從計(jì)算節(jié)點(diǎn)在迭代處理的過(guò)程中接收的第二計(jì)算消息的個(gè)數(shù)之和是否相等；

若是，則向每個(gè)所述從計(jì)算節(jié)點(diǎn)發(fā)送算法終止的控制命令。

7.一種分布式圖數(shù)據(jù)處理裝置，其特征在于，包括：第一判斷模塊和第一處理模塊，其中，

所述第一判斷模塊，用于在第一從計(jì)算節(jié)點(diǎn)執(zhí)行完本輪迭代處理，并且判斷消息隊(duì)列中不存在待處理的第二計(jì)算消息、以及判斷當(dāng)前處理的分塊中不存在活躍頂點(diǎn)時(shí)，在等待接收目標(biāo)從計(jì)算節(jié)點(diǎn)發(fā)送的回復(fù)響應(yīng)的過(guò)程中，判斷是否接收到第二從計(jì)算節(jié)點(diǎn)發(fā)送的第二計(jì)算消息，其中，所述目標(biāo)從計(jì)算節(jié)點(diǎn)為接收所述第一從計(jì)算節(jié)點(diǎn)發(fā)送的第一計(jì)算消息的從計(jì)算節(jié)點(diǎn)；

所述第一處理模塊，用于在所述第一判斷模塊判斷在等待接收目標(biāo)從計(jì)算節(jié)點(diǎn)發(fā)送的回復(fù)響應(yīng)的過(guò)程中，接收到第二從計(jì)算節(jié)點(diǎn)發(fā)送的第二計(jì)算消息時(shí)，執(zhí)行下一輪迭代處理；

所述第一處理模塊，還用于在所述第一判斷模塊判斷沒(méi)有接收到所述第二計(jì)算消息時(shí)，則在接收到所述目標(biāo)從計(jì)算節(jié)點(diǎn)發(fā)送的回復(fù)響應(yīng)后，將迭代處理過(guò)程中的處理信息發(fā)送給服務(wù)器；其中，所述處理信息包括所述第一從計(jì)算節(jié)點(diǎn)在迭代處理過(guò)程中發(fā)送的第一計(jì)算消息的個(gè)數(shù)以及接收的第二計(jì)算消息的個(gè)數(shù)。

8.根據(jù)權(quán)利要求7所述的裝置，其特征在于，所述第一判斷模塊，還用于在所述第一處理模塊將迭代處理過(guò)程中的處理信息發(fā)送給服務(wù)器之后，在等待接收主計(jì)算節(jié)點(diǎn)發(fā)送的控制命令的過(guò)程中，判斷是否接收到所述第二從計(jì)算節(jié)點(diǎn)發(fā)送的第二計(jì)算消息；

所述第一處理模塊，還用于在所述第一判斷模塊判斷在等待接收主計(jì)算節(jié)點(diǎn)發(fā)送的控制命令的過(guò)程中，接收到所述第二從計(jì)算節(jié)點(diǎn)發(fā)送的第二計(jì)算消息時(shí)，執(zhí)行下一輪迭代處理。