[發(fā)明專利]消息合并方法、消息處理方法和裝置、設(shè)備和介質(zhì)在審
| 申請?zhí)枺?/td> | 202010945528.1 | 申請日: | 2020-09-10 |
| 公開(公告)號: | CN112069438A | 公開(公告)日: | 2020-12-11 |
| 發(fā)明(設(shè)計)人: | 馬大犁 | 申請(專利權(quán))人: | 北京五八信息技術(shù)有限公司 |
| 主分類號: | G06F16/958 | 分類號: | G06F16/958 |
| 代理公司: | 北京衛(wèi)智暢科專利代理事務(wù)所(普通合伙) 11557 | 代理人: | 陳佳 |
| 地址: | 100080 北京市海淀區(qū)學清*** | 國省代碼: | 北京;11 |
| 權(quán)利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關(guān)鍵詞: | 消息 合并 方法 處理 裝置 設(shè)備 介質(zhì) | ||
本公開的實施例公開了消息合并方法、消息處理方法和裝置、設(shè)備和介質(zhì)。該方法的一具體實施方式包括:接收消息隊列;根據(jù)上述消息隊列包括的各個消息標識,分別建立鍵值對和對象隊列,其中,所建立的鍵值對的數(shù)目等于上述消息隊列包括的消息標識的數(shù)目,上述鍵值對中的鍵用于存儲消息標識,上述鍵值對中的值用于存儲消息內(nèi)容;基于上述消息隊列中每個消息對應(yīng)的鍵值對和對象隊列,對上述消息包括的消息內(nèi)容進行合并處理以生成處理后鍵值對和處理后對象隊列,得到處理后鍵值對集合和處理后對象隊列集合。該實施方式能夠降低重復(fù)處理的消息的消息內(nèi)容的數(shù)量,為消減相關(guān)設(shè)備在處理消息的消息內(nèi)容時的處理負荷提供支持。
技術(shù)領(lǐng)域
本公開的實施例涉及計算機技術(shù)領(lǐng)域,具體涉及消息合并方法、消息處理方法和裝置、設(shè)備和計算機可讀介質(zhì)。
背景技術(shù)
當前,消息處理設(shè)備通常需要在設(shè)定時間內(nèi)處理成千上萬的消息。然而,這些消息的接收往往存在高峰,大量消息的來臨對消息處理設(shè)備造成了較大的處理負荷。因此,如何消減處理負荷是需要面臨的一個問題。
發(fā)明內(nèi)容
本公開的內(nèi)容部分用于以簡要的形式介紹構(gòu)思,這些構(gòu)思將在后面的具體實施方式部分被詳細描述。本公開的內(nèi)容部分并不旨在標識要求保護的技術(shù)方案的關(guān)鍵特征或必要特征,也不旨在用于限制所要求的保護的技術(shù)方案的范圍。
本公開的一些實施例提出了消息合并方法、消息處理方法和裝置、設(shè)備和計算機可讀介質(zhì),來解決以上背景技術(shù)部分提到的技術(shù)問題。
第一方面,本公開的一些實施例提供了一種用于消息合并端的消息合并方法,該方法包括:接收消息隊列,其中,上述消息包括消息標識和消息內(nèi)容;根據(jù)上述消息隊列包括的各個消息標識,分別建立鍵值對和對象隊列,其中,所建立的鍵值對的數(shù)目等于上述消息隊列包括的消息標識的數(shù)目,上述鍵值對中的鍵用于存儲消息標識,上述鍵值對中的值用于存儲消息內(nèi)容;基于上述消息隊列中每個消息對應(yīng)的鍵值對和對象隊列,對上述消息包括的消息內(nèi)容進行合并處理以生成處理后鍵值對和處理后對象隊列,得到處理后鍵值對集合和處理后對象隊列集合。
第二方面,本公開的一些實施例提供了一種用于消息合并端的消息合并裝置,裝置包括:接收單元,被配置成接收消息隊列,其中,上述消息包括消息標識和消息內(nèi)容;建立單元,被配置成根據(jù)上述消息隊列包括的各個消息標識,分別建立鍵值對和對象隊列,其中,所建立的鍵值對的數(shù)目等于上述消息隊列包括的消息標識的數(shù)目,上述鍵值對中的鍵用于存儲消息標識,上述鍵值對中的值用于存儲消息內(nèi)容;處理單元,被配置成基于上述消息隊列中每個消息對應(yīng)的鍵值對和對象隊列,對上述消息包括的消息內(nèi)容進行合并處理以生成處理后鍵值對和處理后對象隊列,得到處理后鍵值對集合和處理后對象隊列集合。
第三方面,本公開的一些實施例提供了一種用于消息處理端的消息處理方法,該方法包括:從消息合并端的處理后對象隊列中提取處理后對象,其中,上述處理后對象包括消息標識;從上述消息合并端中的、與上述消息標識對應(yīng)的處理后鍵值對中獲取消息內(nèi)容以及刪除上述處理后鍵值對中的消息內(nèi)容;基于上述消息內(nèi)容進行消息處理。
第四方面,本公開的一些實施例提供了消息處理端的消息處理裝置,裝置包括:提取單元,被配置成從消息合并端的處理后對象隊列中提取處理后對象,其中,上述處理后對象包括消息標識;刪除單元,被配置成從上述消息合并端中的、與上述消息標識對應(yīng)的處理后鍵值對中獲取消息內(nèi)容以及刪除上述處理后鍵值對中的消息內(nèi)容;處理單元,被配置成基于上述消息內(nèi)容進行消息處理。
第五方面,本公開的一些實施例提供了一種電子設(shè)備,包括:一個或多個處理器;存儲裝置,其上存儲有一個或多個程序,當一個或多個程序被一個或多個處理器執(zhí)行,使得一個或多個處理器實現(xiàn)如第一、二方面中任一的方法。
第六方面,本公開的一些實施例提供了一種計算機可讀介質(zhì),其上存儲有計算機程序,其中,程序被處理器執(zhí)行時實現(xiàn)如第一、二方面中任一的方法。
該專利技術(shù)資料僅供研究查看技術(shù)是否侵權(quán)等信息,商用須獲得專利權(quán)人授權(quán)。該專利全部權(quán)利屬于北京五八信息技術(shù)有限公司,未經(jīng)北京五八信息技術(shù)有限公司許可,擅自商用是侵權(quán)行為。如果您想購買此專利、獲得商業(yè)授權(quán)和技術(shù)合作,請聯(lián)系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/202010945528.1/2.html,轉(zhuǎn)載請聲明來源鉆瓜專利網(wǎng)。





