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

在審

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

本公開的實施例公開了消息合并方法、消息處理方法和裝置、設備和介質。該方法的一具體實施方式包括：接收消息隊列；根據上述消息隊列包括的各個消息標識，分別建立鍵值對和對象隊列，其中，所建立的鍵值對的數目等于上述消息隊列包括的消息標識的數目，上述鍵值對中的鍵用于存儲消息標識，上述鍵值對中的值用于存儲消息內容；基于上述消息隊列中每個消息對應的鍵值對和對象隊列，對上述消息包括的消息內容進行合并處理以生成處理后鍵值對和處理后對象隊列，得到處理后鍵值對集合和處理后對象隊列集合。該實施方式能夠降低重復處理的消息的消息內容的數量，為消減相關設備在處理消息的消息內容時的處理負荷提供支持。

技術領域

本公開的實施例涉及計算機技術領域，具體涉及消息合并方法、消息處理方法和裝置、設備和計算機可讀介質。

背景技術

當前，消息處理設備通常需要在設定時間內處理成千上萬的消息。然而，這些消息的接收往往存在高峰，大量消息的來臨對消息處理設備造成了較大的處理負荷。因此，如何消減處理負荷是需要面臨的一個問題。

發明內容

本公開的內容部分用于以簡要的形式介紹構思，這些構思將在后面的具體實施方式部分被詳細描述。本公開的內容部分并不旨在標識要求保護的技術方案的關鍵特征或必要特征，也不旨在用于限制所要求的保護的技術方案的范圍。

本公開的一些實施例提出了消息合并方法、消息處理方法和裝置、設備和計算機可讀介質，來解決以上背景技術部分提到的技術問題。

第一方面，本公開的一些實施例提供了一種用于消息合并端的消息合并方法，該方法包括：接收消息隊列，其中，上述消息包括消息標識和消息內容；根據上述消息隊列包括的各個消息標識，分別建立鍵值對和對象隊列，其中，所建立的鍵值對的數目等于上述消息隊列包括的消息標識的數目，上述鍵值對中的鍵用于存儲消息標識，上述鍵值對中的值用于存儲消息內容；基于上述消息隊列中每個消息對應的鍵值對和對象隊列，對上述消息包括的消息內容進行合并處理以生成處理后鍵值對和處理后對象隊列，得到處理后鍵值對集合和處理后對象隊列集合。

第二方面，本公開的一些實施例提供了一種用于消息合并端的消息合并裝置，裝置包括：接收單元，被配置成接收消息隊列，其中，上述消息包括消息標識和消息內容；建立單元，被配置成根據上述消息隊列包括的各個消息標識，分別建立鍵值對和對象隊列，其中，所建立的鍵值對的數目等于上述消息隊列包括的消息標識的數目，上述鍵值對中的鍵用于存儲消息標識，上述鍵值對中的值用于存儲消息內容；處理單元，被配置成基于上述消息隊列中每個消息對應的鍵值對和對象隊列，對上述消息包括的消息內容進行合并處理以生成處理后鍵值對和處理后對象隊列，得到處理后鍵值對集合和處理后對象隊列集合。

第三方面，本公開的一些實施例提供了一種用于消息處理端的消息處理方法，該方法包括：從消息合并端的處理后對象隊列中提取處理后對象，其中，上述處理后對象包括消息標識；從上述消息合并端中的、與上述消息標識對應的處理后鍵值對中獲取消息內容以及刪除上述處理后鍵值對中的消息內容；基于上述消息內容進行消息處理。

第四方面，本公開的一些實施例提供了消息處理端的消息處理裝置，裝置包括：提取單元，被配置成從消息合并端的處理后對象隊列中提取處理后對象，其中，上述處理后對象包括消息標識；刪除單元，被配置成從上述消息合并端中的、與上述消息標識對應的處理后鍵值對中獲取消息內容以及刪除上述處理后鍵值對中的消息內容；處理單元，被配置成基于上述消息內容進行消息處理。

第五方面，本公開的一些實施例提供了一種電子設備，包括：一個或多個處理器；存儲裝置，其上存儲有一個或多個程序，當一個或多個程序被一個或多個處理器執行，使得一個或多個處理器實現如第一、二方面中任一的方法。

第六方面，本公開的一些實施例提供了一種計算機可讀介質，其上存儲有計算機程序，其中，程序被處理器執行時實現如第一、二方面中任一的方法。