[發明專利]消息處理方法和裝置、存儲介質和電子裝置

在審

• 申請號: 202010091950.5
• 申請日: 2020-02-13
• 公開（公告）號: CN111338814A
• 公開（公告）日: 2020-06-26
• 發明（設計）人: 楊學毅;李倉良;祝夢遙
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/22;G06F16/2458
• 代理公司: 北京華夏泰和知識產權代理有限公司 11662
• 代理人: 郭金鑫;劉蔓莉

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

獲取具有目標消息標識的待處理數據，其中，所述待處理數據為從與目標流處理任務對應的多個節點處收集的數據，所述目標流處理任務為目標消息由被生產節點生產到被消費節點消費的流處理任務，所述目標消息標識用于唯一標識所述目標消息；

在根據所述待處理數據確定所述目標消息未被正常消費的情況下，將所述目標消息添加到目標消息隊列中，其中，所述目標消息隊列中存儲有與待處理的流處理任務對應的消息。

2.根據權利要求1所述的方法，其特征在于，所述獲取具有目標消息標識的待處理數據包括：

從數據庫中讀取目標時間段內的目標數據，其中，所述數據庫中存儲有從節點集群中的各個節點收集的數據，所述目標時間段的起始時刻與當前時刻的時間差為目標差值；

使用所述目標消息標識從所述目標數據中匹配出具有所述目標消息標識的所述待處理數據。

3.根據權利要求2所述的方法，其特征在于，在所述獲取具有目標消息標識的待處理數據之前，所述方法還包括：

接收所述多個節點發送的所述待處理數據，其中，所述待處理數據包括所述生產節點發送的第一數據和其他節點發送的第二數據，所述第一數據包括所述目標消息、所述目標消息標識和時間戳，所述其他節點為所述多個節點中除了所述生產節點以外的節點，所述第二數據包括所述目標消息標識和時間戳；

將所述待處理數據保存到所述數據庫中。

4.根據權利要求1所述的方法，其特征在于，在所述獲取具有目標消息標識的待處理數據之后，所述方法還包括：

根據具有所述目標消息標識的所述待處理數據，確定所述目標消息在各個相鄰節點的后一個節點處是否被正常消費，其中，所述相鄰節點為所述多個節點中按照所述目標流處理任務具有相鄰關系的兩個節點；

在確定出所述目標消息在所述多個節點中的目標節點未被正常消費的情況下，確定所述目標消息未被正常消費。

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

在所述將所述目標消息添加到目標消息隊列中之前，所述方法還包括：將所述待處理數據發送到目標設備，以通過所述目標設備顯示所述目標消息以及所述目標節點；接收所述目標設備發送的修改指令，其中，所述修改指令用于修改所述目標流處理任務的任務處理流程；

在所述將所述目標消息添加到目標消息隊列中之后，所述方法還包括：按照修改后的所述任務處理流程處理所述目標消息。

6.根據權利要求1所述的方法，其特征在于，在根據所述待處理數據確定所述目標消息已被所述消費節點正常消費的情況下，所述方法還包括：

將所述待處理數據從數據庫中清除，其中，所述數據庫中存儲有從節點集群中的各個節點處收集的數據。

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

獲取單元，用于獲取具有目標消息標識的待處理數據，其中，所述待處理數據為從與目標流處理任務對應的多個節點處收集的數據，所述目標流處理任務為目標消息由被生產節點生產到被消費節點消費的流處理任務，所述目標消息標識用于唯一標識所述目標消息；

添加單元，用于在根據所述待處理數據確定所述目標消息未被正常消費的情況下，將所述目標消息添加到目標消息隊列中，其中，所述目標消息隊列中存儲有與待處理的流處理任務對應的消息。

8.根據權利要求7所述的裝置，其特征在于，所述獲取單元包括：

讀取模塊，用于從數據庫中讀取目標時間段內的目標數據，其中，所述數據庫中存儲有從節點集群中的各個節點收集的數據，所述目標時間段的起始時刻與當前時刻的時間差為目標差值；

匹配模塊，用于使用所述目標消息標識從所述目標數據中匹配出具有所述目標消息標識的所述待處理數據。

9.一種計算機可讀的存儲介質，其特征在于，所述存儲介質中存儲有計算機程序，其中，所述計算機程序被設置為運行時執行權利要求1至6中任一項所述的方法。

10.一種電子裝置，包括存儲器和處理器，其特征在于，所述存儲器中存儲有計算機程序，所述處理器被設置為通過所述計算機程序執行權利要求1至6中任一項所述的方法。