[發明專利]消息合并方法、消息處理方法和裝置、設備和介質

在審

• 申請號: 202010945528.1
• 申請日: 2020-09-10
• 公開（公告）號: CN112069438A
• 公開（公告）日: 2020-12-11
• 發明（設計）人: 馬大犁
• 申請（專利權）人: 北京五八信息技術有限公司
• 主分類號: G06F16/958
• 分類號: G06F16/958
• 代理公司: 北京衛智暢科專利代理事務所(普通合伙) 11557
• 代理人: 陳佳

1.一種用于消息合并端的消息合并方法，包括：

接收消息隊列，其中，所述消息包括消息標識和消息內容；

根據所述消息隊列包括的各個消息標識，分別建立鍵值對和對象隊列，其中，所建立的鍵值對的數目等于所述消息隊列包括的消息標識的數目，所述鍵值對中的鍵用于存儲消息標識，所述鍵值對中的值用于存儲消息內容；

基于所述消息隊列中每個消息對應的鍵值對和對象隊列，對所述消息包括的消息內容進行合并處理以生成處理后鍵值對和處理后對象隊列，得到處理后鍵值對集合和處理后對象隊列集合。

2.根據權利要求1所述的方法，其中，所述消息內容包括消息接收時間點和消息處理等候時間段。

3.根據權利要求2所述的方法，其中，所述基于所述消息隊列中每個消息對應的鍵值對和對象隊列，對所述消息包括的消息內容進行合并處理以生成處理后鍵值對和處理后對象隊列，包括：

響應于所述鍵值對的鍵中不存在所述消息的消息標識，執行如下處理：

將所述鍵值對的鍵修改成所述消息包括的消息標識，將所述鍵值對的值修改成所述消息包括的消息內容，以生成處理后鍵值對；

將所述消息包括的消息接收時間點和所述消息包括的消息處理等候時間段的和確定為所述消息的到期時間；

生成對象以及將所述對象加入所述對象隊列以生成處理后對象隊列，其中，所述處理后對象包括所述消息的消息標識、消息接收時間點、消息處理等候時間段和到期時間。

4.根據權利要求3所述的方法，其中，所述基于所述消息隊列中每個消息對應的鍵值對和對象隊列，對所述消息包括的消息內容進行合并處理以生成處理后鍵值對和處理后對象隊列，包括：

響應于所述鍵值對的鍵中存在所述消息的消息標識，將所述鍵值對的值修改成所述消息包括的消息內容，以生成處理后鍵值對。

5.根據權利要求2所述的方法，其中，所述消息內容還包括信息變更內容。

6.一種用于消息處理端的消息處理方法，包括：

從消息合并端的處理后對象隊列中提取處理后對象，其中，所述處理后對象包括消息標識，所述消息合并端實現如權利要求1-5中任一所述的方法；

從所述消息合并端中的、與所述消息標識對應的處理后鍵值對中獲取消息內容以及刪除所述處理后鍵值對中的消息內容；

基于所述消息內容進行消息處理。

7.根據權利要求6所述的方法，其中，所述從消息合并端的處理后對象隊列中提取處理后對象，包括：

從所述處理后對象隊列中提取處理后對象的到期時間為當前時間的處理后對象。

8.根據權利要求7所述的方法，其中，所述基于所述消息內容進行消息處理，包括：

對所述消息內容包括的信息變更內容進行處理，以生成表征處理成功或處理失敗的提交結果；

將所述提交結果發送至所述消息合并端，其中，所述消息合并端響應于接收到表征處理失敗的提交結果以及確定所述信息變更內容的處理失敗次數小于或等于預定次數，補發所述信息變更內容對應的消息。

9.一種用于消息合并端的消息合并裝置，包括：

接收單元，被配置成接收消息隊列，其中，所述消息包括消息標識和消息內容；

建立單元，被配置成根據所述消息隊列包括的各個消息標識，分別建立鍵值對和對象隊列，其中，所建立的鍵值對的數目等于所述消息隊列包括的消息標識的數目，所述鍵值對中的鍵用于存儲消息標識，所述鍵值對中的值用于存儲消息內容；

處理單元，被配置成基于所述消息隊列中每個消息對應的鍵值對和對象隊列，對所述消息包括的消息內容進行合并處理以生成處理后鍵值對和處理后對象隊列，得到處理后鍵值對集合和處理后對象隊列集合。