[發明專利]鏈路消息處理方法、裝置、存儲介質及計算機設備

有效

• 申請號: 201910282236.1
• 申請日: 2019-04-09
• 公開（公告）號: CN110187979B
• 公開（公告）日: 2021-05-18
• 發明（設計）人: 黃振華;張鈞
• 申請（專利權）人: 口口相傳(北京)網絡技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京中強智尚知識產權代理有限公司 11448
• 代理人: 黃耀威

1.一種鏈路消息處理方法，其特征在于，包括：

對多個鏈路消息對應鏈路的多個算子進行類別劃分；對所述多個算子中的多個網絡型算子進行網絡層封裝處理，得到網絡型算子層；

獲取待處理的多個鏈路消息；

判斷針對所述待處理的多個鏈路消息所需要調度執行的算子是否為網絡型算子，具體包括：對所述待處理的多個鏈路消息的數據結構解析，得到所述待處理的多個鏈路消息對應的處理請求類型；若所述處理請求類型為網絡處理請求，則確定針對所述待處理的多個鏈路消息所需要調度執行的算子為網絡型算子；其中，算子為鏈路拆分后的各個鏈路階段的算子，不同的鏈路階段對應的算子不同，各個鏈路階段的算子用于對各個鏈路階段的鏈路消息進行處理；

若為網絡型算子，則調度執行需要啟動一個線程的網絡型算子層，將所述待處理的多個鏈路消息發送給網絡層進行處理；

接收所述網絡層反饋的處理結果，調用預設回調函數將所述處理結果封裝成下游鏈路消息并發送到消息處理隊列中。

2.根據權利要求1所述的方法，其特征在于，所述對所述多個算子中的多個網絡型算子進行網絡層封裝處理，得到網絡型算子層，包括：

基于預設的網絡層封裝函數，對所述多個網絡型算子進行網絡層封裝處理，得到所述網絡型算子層。

3.根據權利要求1所述的方法，其特征在于，所述判斷針對所述待處理的多個鏈路消息所需要調度執行的算子是否為網絡型算子之后，所述方法還包括：

若為計算型算子，則調度執行計算型算子對所述待處理的多個鏈路消息進行處理。

4.一種鏈路消息處理裝置，其特征在于，包括：

劃分單元，用于對多個鏈路消息對應鏈路的多個算子進行類別劃分；

封裝單元，用于對所述多個算子中的多個網絡型算子進行網絡層封裝處理，得到網絡型算子層；

獲取單元，用于獲取待處理的多個鏈路消息；

判斷單元，用于判斷針對所述待處理的多個鏈路消息所需要調度執行的算子是否為網絡型算子，具體包括：對所述待處理的多個鏈路消息的數據結構解析，得到所述待處理的多個鏈路消息對應的處理請求類型；若所述處理請求類型為網絡處理請求，則確定針對所述待處理的多個鏈路消息所需要調度執行的算子為網絡型算子；其中，算子為鏈路拆分后的各個鏈路階段的算子，不同的鏈路階段對應的算子不同，各個鏈路階段的算子用于對各個鏈路階段的鏈路消息進行處理；

處理單元，用于若針對所述待處理的多個鏈路消息所需要調度執行的算子為網絡型算子，則調度執行需要啟動一個線程的網絡型算子層，將所述待處理的多個鏈路消息發送給網絡層進行處理；

接收單元，用于接收所述網絡層反饋的處理結果；

發送單元，還用于調用預設回調函數將所述處理結果封裝成下游鏈路消息并發送到消息處理隊列中。

5.根據權利要求4所述的裝置，其特征在于，

所述封裝單元，具體用于基于預設的網絡層封裝函數，對所述多個網絡型算子進行網絡層封裝處理，得到所述網絡型算子層。

6.根據權利要求4所述的裝置，其特征在于，

所述處理單元，還用于若針對所述待處理的多個鏈路消息所需要調度執行的算子為計算型算子，則調度執行計算型算子對所述待處理的多個鏈路消息進行處理。

7.一種存儲介質，其上存儲有計算機程序，所述存儲介質中存儲有至少一可執行指令，所述可執行指令使處理器執行如權利要求1-3中任一項所述的鏈路消息處理方法對應的操作。

8.一種計算機設備，包括處理器、存儲器、通信接口和通信總線所述處理器、所述存儲器和所述通信接口通過所述通信總線完成相互間的通信，所述存儲器用于存放至少一可執行指令，所述可執行指令使所述處理器執行如權利要求1-3中任一項所述的鏈路消息處理方法對應的操作。