[發明專利]消息打包與接收方法、裝置、電子設備和介質

在審

• 申請號: 202010900968.5
• 申請日: 2020-08-31
• 公開（公告）號: CN112039753A
• 公開（公告）日: 2020-12-04
• 發明（設計）人: 謝維柱;李樹毫;邢越
• 申請（專利權）人: 北京百度網訊科技有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L29/08
• 代理公司: 北京市漢坤律師事務所 11602
• 代理人: 姜浩然;吳麗麗

本公開提供一種消息打包與接收方法、裝置、電子設備和介質，涉及信息技術領域。所述消息打包方法包括：對待打包的多條消息進行打包，生成第一數據包；至少基于第一數據包所包括的消息的數量，按照預設的規則生成第一數據包的第一編碼信息；以及將第一數據包和第一數據包的第一編碼信息發送至服務端。所述消息接收方法包括：接收來自客戶端的第一數據包和第一數據包的第一編碼信息，第一編碼信息與第一數據包所包括的消息的數量相關；基于第一編碼信息和上一次存儲的第二數據包的第二編碼信息，確定過濾信息，過濾信息指示是否對第一數據包進行過濾。

技術領域

本公開涉及信息技術領域，尤其涉及一種消息打包與接收方法、裝置、電子設備和介質。

背景技術

在信息技術領域，消息系統通常使用分布式消息隊列的方式對消息進行存儲。消息系統可以接收客戶端傳輸的消息并存儲，也可以基于客戶端的訂閱向客戶端推送消息。根據相關技術，客戶端將待傳輸的消息打包成數據包，再以數據包的形式傳輸至消息系統。消息系統可以基于客戶端的訂閱將相應的數據包推送給客戶端。

在此部分中描述的方法不一定是之前已經設想到或采用的方法。除非另有指明，否則不應假定此部分中描述的任何方法僅因其包括在此部分中就被認為是現有技術。類似地，除非另有指明，否則此部分中提及的問題不應認為在任何現有技術中已被公認。

發明內容

根據本公開的一方面，提供一種消息打包方法，包括：對待打包的多條消息進行打包，生成第一數據包；至少基于所述第一數據包所包括的消息的數量，按照預設的規則生成所述第一數據包的第一編碼信息；以及將所述第一數據包和所述第一數據包的第一編碼信息發送至服務端。

根據本公開的另一方面，還提供一種消息接收方法，包括：接收來自客戶端的第一數據包和所述第一數據包的第一編碼信息，所述第一編碼信息與所述第一數據包所包括的消息的數量相關；基于所述第一編碼信息和上一次存儲的第二數據包的第二編碼信息，確定過濾信息，所述過濾信息指示是否對所述第一數據包進行過濾。

根據本公開的另一方面，還提供一種消息打包裝置，包括：打包單元，被配置為對待打包的多條消息進行打包，生成第一數據包；編碼單元，被配置為至少基于所述第一數據包所包括的消息的數量，生成所述第一數據包的第一編碼信息；以及發送單元，被配置為將所述第一數據包和所述第一數據包的第一編碼信息發送至服務端。

根據本公開的另一方面，還提供一種消息接收裝置，包括：接收單元，被配置為接收來自客戶端的第一數據包和所述第一數據包的第一編碼信息，所述第一編碼信息與所述第一數據包所包括的消息的數量相關；以及確定單元，被配置為基于所述第一編碼信息和上一次存儲的第二數據包的第二編碼信息，確定過濾信息，所述過濾信息指示是否對所述第一數據包進行過濾。

根據本公開的又一方面，還提供一種電子設備，包括：處理器；以及存儲程序的存儲器，所述程序包括指令，所述指令在由所述處理器執行時使所述處理器執行根據上述的消息打包方法和消息接收方法。

根據本公開的又一方面，還提供一種存儲程序的計算機可讀存儲介質，所述程序包括指令，所述指令在由電子設備的處理器執行時，致使所述電子設備執行根據上述的消息打包方法和消息接收方法。

在本公開的一個或多個實施例中，基于數據包所包括的消息的數量，按照預設的規則生成數據包的編碼信息，并基于編碼信息對消息進行過濾，有助于兼顧在流量高峰期對于消息傳輸的高吞吐量的要求和在流量低谷期對于消息傳輸的低延遲的要求，并同時保證傳輸的消息不重不丟。

附圖說明

附圖示例性地示出了實施例并且構成說明書的一部分，與說明書的文字描述一起用于講解實施例的示例性實施方式。所示出的實施例僅出于例示的目的，并不限制權利要求的范圍。在所有附圖中，相同的附圖標記指代類似但不一定相同的要素。

圖1是示出根據本公開的示例性實施例的消息打包方法的流程圖；