[發(fā)明專利]基于Netty框架的數(shù)據(jù)處理方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202210280862.9
• 申請(qǐng)日: 2022-03-22
• 公開（公告）號(hào): CN114640719A
• 公開（公告）日: 2022-06-17
• 發(fā)明（設(shè)計(jì)）人: 孫旭
• 申請(qǐng)（專利權(quán)）人: 康鍵信息技術(shù)（深圳）有限公司
• 主分類號(hào): H04L69/06
• 分類號(hào): H04L69/06;H04L67/01;G06F9/38;G06F9/54
• 代理公司: 北京市京大律師事務(wù)所 11321
• 代理人: 沈克琪

1.一種基于Netty框架的數(shù)據(jù)處理方法，所述Netty框架設(shè)有多個(gè)并行執(zhí)行的線程，其特征在于，所述數(shù)據(jù)處理方法包括：

獲取服務(wù)端上的待發(fā)送數(shù)據(jù)，將所述待發(fā)送數(shù)據(jù)分發(fā)給多個(gè)線程執(zhí)行；

通過所述線程對(duì)對(duì)應(yīng)的待發(fā)送數(shù)據(jù)按照預(yù)設(shè)的SBE協(xié)議進(jìn)行編碼處理，得到SBE消息；

將所述SBE消息發(fā)送至客戶端。

2.根據(jù)權(quán)利要求1所述的基于Netty框架的數(shù)據(jù)處理方法，其特征在于，所述獲取客戶端上的待發(fā)送數(shù)據(jù)，將所述待發(fā)送數(shù)據(jù)分發(fā)給多個(gè)線程執(zhí)行，包括：

獲取服務(wù)端上設(shè)有發(fā)送標(biāo)記的數(shù)據(jù)，得到待發(fā)送數(shù)據(jù)；

按照消息隊(duì)列的存儲(chǔ)規(guī)則，將所述待發(fā)送數(shù)據(jù)劃分為多個(gè)片段，形成待處理消息隊(duì)列；

獲取所述服務(wù)端上存在空閑資源的至少兩個(gè)線程，并按照優(yōu)先級(jí)對(duì)所述至少兩個(gè)線程進(jìn)行排序，得到線程序列；

通過所述線程序列中的各線程依次輪詢所述待處理消息隊(duì)列，得到待處理消息隊(duì)列中的資源要求，并判斷對(duì)應(yīng)的線程上空閑資源是否滿足所述資源要求；

若是，則將所述片段分發(fā)給對(duì)應(yīng)的線程執(zhí)行，直到所有片段分發(fā)完成。

3.根據(jù)權(quán)利要求1所述的基于Netty框架的數(shù)據(jù)處理方法，其特征在于，所述通過所述線程對(duì)對(duì)應(yīng)的待發(fā)送數(shù)據(jù)按照預(yù)設(shè)的SBE協(xié)議進(jìn)行編碼處理，得到SBE消息，包括：

在所述待發(fā)送數(shù)據(jù)經(jīng)劃分而成的片段被分發(fā)給對(duì)應(yīng)的線程執(zhí)行后，通過所述線程構(gòu)造一個(gè)通道，并構(gòu)建與所述通道對(duì)應(yīng)的管道；

在所述管道上的Handler鏈上對(duì)所述片段按照預(yù)設(shè)的SBE協(xié)議進(jìn)行編碼處理，得到多個(gè)SBE消息片段，其中，所述Handler鏈包括至少一個(gè)Handler；

將多個(gè)所述SBE消息片段進(jìn)行合并，得到SBE消息。

4.根據(jù)權(quán)利要求1所述的基于Netty框架的數(shù)據(jù)處理方法，其特征在于，所述將所述SBE消息發(fā)送至客戶端，包括：

在所述待發(fā)送數(shù)據(jù)被劃分而成的片段被分發(fā)給對(duì)應(yīng)的線程執(zhí)行后，通過所述線程創(chuàng)建用于處理寫事件的子通道；

調(diào)用所述子通道上的調(diào)用鏈將所述SBE消息發(fā)送至服務(wù)端，其中，所述調(diào)用鏈包括至少一個(gè)Handler。

5.根據(jù)權(quán)利要求2所述的基于Netty框架的數(shù)據(jù)處理方法，其特征在于，所述通過所述線程序列中的各線程依次輪詢所述待處理消息隊(duì)列，得到待處理消息隊(duì)列中的資源要求，并判斷對(duì)應(yīng)的線程上空閑資源是否滿足所述資源要求，包括：

輪詢所述待處理消息隊(duì)列，判斷消息隊(duì)列中是否有所述待處理消息；

如果消息隊(duì)列中有所述待處理消息，則獲取該待處理消息對(duì)應(yīng)的事件類型，其中，不同的事件類型對(duì)應(yīng)不同的資源要求；

調(diào)用Selector的selectNow()方法，觸發(fā)Selector的選擇操作，如果有就緒的Channel，則返回就緒的通道集合，如果沒有就緒的通道，則返回0；

根據(jù)所述就緒的通道集合，依次讀取所述就緒的通道具有的SelectionKey的值，獲取所述就緒的通道對(duì)應(yīng)的事件類型；

如果所述就緒的通道對(duì)應(yīng)的事件類型包含所述待處理消息對(duì)應(yīng)的事件類型，則判定對(duì)應(yīng)的線程上空閑資源是否滿足所述資源要求，反之則判定不滿足。

6.根據(jù)權(quán)利要求1-5中任一項(xiàng)所述的基于Netty框架的數(shù)據(jù)處理方法，其特征在于，所述數(shù)據(jù)處理方法還包括：

對(duì)多個(gè)客戶端發(fā)送過來的數(shù)據(jù)進(jìn)行監(jiān)聽；

將監(jiān)聽到的數(shù)據(jù)分發(fā)給多個(gè)線程執(zhí)行；

在相應(yīng)線程上對(duì)所述監(jiān)聽到的數(shù)據(jù)進(jìn)行處理和接收操作；

對(duì)所述接收到的數(shù)據(jù)中的SBE消息按照預(yù)設(shè)的SBE協(xié)議進(jìn)行解碼處理，得到解碼后的數(shù)據(jù)；

將所述解碼后的數(shù)據(jù)發(fā)送到服務(wù)端。