[發(fā)明專利]數(shù)據(jù)處理的方法、網(wǎng)絡(luò)設(shè)備、計算節(jié)點和系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201910362340.1
• 申請日: 2019-04-30
• 公開（公告）號: CN111865831B
• 公開（公告）日: 2022-05-13
• 發(fā)明（設(shè)計）人: 林偉彬;侯新宇;李濤
• 申請（專利權(quán)）人: 華為技術(shù)有限公司
• 主分類號: H04L49/901
• 分類號: H04L49/901
• 代理公司: 北京龍雙利達知識產(chǎn)權(quán)代理有限公司 11329
• 代理人: 周喬;王君

本申請?zhí)峁┮环N數(shù)據(jù)處理的方法、網(wǎng)絡(luò)設(shè)備、計算節(jié)點和系統(tǒng)，該方法包括：網(wǎng)絡(luò)設(shè)備根據(jù)第一隊列的標識，從計算節(jié)點的隊列信息存儲空間中讀取該第一隊列的指針信息；再根據(jù)該讀指針獲取該第一隊列中待處理數(shù)據(jù)，并處理該待處理數(shù)據(jù)；然后，根據(jù)該第一寫指針更新該讀指針所指示的單元的位置。上述技術(shù)方案可以減少傳統(tǒng)技術(shù)中網(wǎng)絡(luò)設(shè)備使用的寫指針和計算節(jié)點存儲的寫指針不一致，所導致的網(wǎng)絡(luò)設(shè)備數(shù)據(jù)處理錯誤的問題。

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

本申請涉及信息技術(shù)領(lǐng)域，更具體地，涉及數(shù)據(jù)處理的方法、網(wǎng)絡(luò)設(shè)備、計算節(jié)點和系統(tǒng)。

背景技術(shù)

數(shù)據(jù)中心網(wǎng)絡(luò)中的源計算節(jié)點可以通過源網(wǎng)絡(luò)設(shè)備將待處理的數(shù)據(jù)發(fā)送至目標網(wǎng)絡(luò)設(shè)備，然后由該目的網(wǎng)絡(luò)設(shè)備將該接收到的數(shù)據(jù)寫入到目的計算節(jié)點中。該源網(wǎng)絡(luò)設(shè)備和該目標網(wǎng)絡(luò)設(shè)備可以為網(wǎng)卡。該源網(wǎng)絡(luò)設(shè)備和該目標網(wǎng)絡(luò)設(shè)備可以用于源計算節(jié)點和目的計算節(jié)點之間相通信。

上述數(shù)據(jù)傳輸過程需要基于隊列(queue)實現(xiàn)。每個隊列中包括多個單元。利用指針指示當前隊列中的待處理的單元和最新加入到當前隊列中的單元。傳統(tǒng)技術(shù)方案中，源網(wǎng)絡(luò)設(shè)備會先從源計算節(jié)點獲取寫指針的物理地址，該寫指針存放在該物理地址對應(yīng)的存儲空間中。源網(wǎng)絡(luò)設(shè)備根據(jù)該寫指針的物理地址，從源計算節(jié)點獲取寫指針。該寫指針用于指示最新加入到當前隊列的單元。這樣，源網(wǎng)絡(luò)設(shè)備可以根據(jù)該寫指針，確定當前隊列的最后一個的單元(即最新加入到當前隊列的單元)。但是，源計算節(jié)點和源網(wǎng)絡(luò)設(shè)備之間不是實時同步指針信息，在源計算節(jié)點在將寫指針通知給源網(wǎng)絡(luò)設(shè)備后，源計算節(jié)點可能繼續(xù)在當前隊列寫入新的單元。在此情況下，源網(wǎng)絡(luò)設(shè)備獲取到的寫指針所指示的單元并非是最新寫入到當前隊列中的單元。綜上所述，因為源網(wǎng)絡(luò)設(shè)備獲取的寫指針和源計算節(jié)點中寫指針并非實時同步，會出現(xiàn)數(shù)據(jù)不一致，導致源網(wǎng)絡(luò)設(shè)備獲取到的寫指針不是最新的寫指針，影響網(wǎng)絡(luò)設(shè)備的處理過程。

然而，隨著數(shù)據(jù)中心中數(shù)據(jù)處理量的增加，計算節(jié)點之間通過多個隊列傳輸不同業(yè)務(wù)應(yīng)用的數(shù)據(jù)，隊列的數(shù)量以及每個網(wǎng)絡(luò)設(shè)備所需處理的數(shù)據(jù)也隨之增加，網(wǎng)絡(luò)設(shè)備無法實時的根據(jù)計算節(jié)點中存儲的最新的寫指針更新其存儲的寫指針，導致網(wǎng)絡(luò)設(shè)備存儲的寫指針和計算節(jié)點生成的寫指針的不一致，進而出現(xiàn)數(shù)據(jù)處理錯誤的問題。

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

本申請?zhí)峁┮环N數(shù)據(jù)處理的方法、網(wǎng)絡(luò)設(shè)備、計算節(jié)點和通信系統(tǒng)，可以減少網(wǎng)絡(luò)設(shè)備使用的寫指針和計算節(jié)點存儲的寫指針不一致，導致網(wǎng)絡(luò)設(shè)備數(shù)據(jù)處理錯誤的問題

第一方面，本申請?zhí)峁┮环N數(shù)據(jù)處理的方法，該方法包括：網(wǎng)絡(luò)設(shè)備根據(jù)第一隊列的標識，從計算節(jié)點的隊列信息存儲空間中讀取該第一隊列的指針信息，其中該網(wǎng)絡(luò)設(shè)備和該計算節(jié)點相連，該隊列信息存儲空間設(shè)置于該計算節(jié)點的內(nèi)存中，該網(wǎng)絡(luò)設(shè)備用于實現(xiàn)該計算節(jié)點和其他計算節(jié)點之間基于隊列對進行通信，該隊列對包括多個隊列，該第一隊列為該多個隊列中任意一個，該第一隊列的指針信息包括第一寫指針和讀指針，該讀指針用于指示該網(wǎng)絡(luò)設(shè)備需要處理的下一個單元的位置，該第一寫指針用于指示該第一隊列中當前時刻允許該計算節(jié)點存儲數(shù)據(jù)的最后一個單元的位置；該網(wǎng)絡(luò)設(shè)備根據(jù)該讀指針獲取該第一隊列中待處理數(shù)據(jù)，并處理該待處理數(shù)據(jù)；該網(wǎng)絡(luò)設(shè)備根據(jù)該第一寫指針更新該讀指針所指示的單元的位置。計算節(jié)點的隊列信息存儲空間中第一隊列的寫指針是計算節(jié)點實施維護的寫指針。

因此，上述技術(shù)方案中，該網(wǎng)絡(luò)設(shè)備從該隊列信息存儲空間讀取的第一隊列的寫指針就是計算節(jié)點確定的最新的寫指針。可以避免傳統(tǒng)技術(shù)中網(wǎng)絡(luò)設(shè)備使用的寫指針和計算節(jié)點存儲的寫指針不一致，導致網(wǎng)絡(luò)設(shè)備數(shù)據(jù)處理錯誤的問題。而且，上述數(shù)據(jù)處理中，計算節(jié)點每次更新寫指針的位置后，直接將寫指針傳遞給網(wǎng)絡(luò)設(shè)備，避免傳統(tǒng)技術(shù)中網(wǎng)絡(luò)設(shè)備需要兩次讀操作(第一次讀操作獲取計算節(jié)點中存儲寫指針的物理位置，第二次讀操作時根據(jù)上述物理位置讀取寫指針)才能獲取指針的操作，減少了讀操作的數(shù)量，降低了系統(tǒng)處理能力，提高了系統(tǒng)處理效率。另外，傳統(tǒng)技術(shù)中需要兩個存儲空間保存一個寫指針。具體地，兩個存儲空間中的一個保存寫指針的地址，另一個保存寫指針。本申請?zhí)峁┑姆椒ㄖ皇褂靡粋€存儲空間就可以保存寫指針。因此，可以節(jié)省存儲空間。