[發明專利]一種消息廣播的方法和裝置

有效

• 申請號: 201910068518.1
• 申請日: 2019-01-24
• 公開（公告）號: CN111478781B
• 公開（公告）日: 2022-11-08
• 發明（設計）人: 劉鋒
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: H04L12/18
• 分類號: H04L12/18
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 張一軍;張效榮

本發明公開了一種消息廣播的方法和裝置，涉及計算機技術領域。該方法的一具體實施方式包括：根據消息廣播任務獲取接入點的網絡地址信息集合；確定每個網絡地址信息對應的接入點，并調用接入點的進程廣播服務將消息廣播給用戶，其中，進程廣播服務用于使接入點從其進程的內存中讀取連接標識并將消息投遞給連接標識對應的用戶，連接標識用于標識接入點與用戶的關聯關系。該實施方式能夠實現在進程內進行消息廣播，從而降低消息廣播的延遲并減輕網絡負擔，提升用戶體驗。

技術領域

本發明涉及計算機技術領域，尤其涉及一種消息廣播的方法和裝置。

背景技術

在一些大型(百萬、千萬級在線用戶)的群交互系統中，廣播延遲問題一直是個難題。以現今最為流行的直播系統為例，在直播場景中，彈幕作為觀眾之間以及觀眾與主播互動交互的重要方式，每位觀眾都期待自己的發言能夠得到主播和其他觀眾的快速響應。然而，直播間觀眾數量眾多，怎樣保證消息能夠低延遲地廣播給直播間的所有人，是直播系統架構設計所需研究的重要課題。

在實現本發明過程中，發明人發現現有技術中至少存在如下問題：

在以直播系統為例的大型群交互系統中，現有的廣播方式由于需要跨進程加載用戶的連接信息，以及分批次RPC遠程調用消息投遞服務會造成很高的延遲以及增加網絡負擔，因此，當直播間觀眾數量多，用戶頻繁發言時，消息廣播的延遲很高，用戶體驗差。

發明內容

有鑒于此，本發明實施例提供一種消息廣播的方法和裝置，能夠實現在進程內進行消息廣播，從而降低消息廣播的延遲并減輕網絡負擔，提升用戶體驗。

為實現上述目的，根據本發明實施例的一個方面，提供了一種消息廣播的方法。

一種消息廣播的方法，包括：根據消息廣播任務獲取接入點的網絡地址信息集合；確定每個網絡地址信息對應的接入點，并調用所述接入點的進程廣播服務將消息廣播給用戶，其中，所述進程廣播服務用于使所述接入點從其進程的內存中讀取連接標識并將所述消息投遞給所述連接標識對應的用戶，所述連接標識用于標識接入點與用戶的關聯關系。

可選地，通過映射表和列表結合的方式保存數據之間的關聯關系。

可選地，所述數據包括群交互系統標識、用戶標識和連接標識，并且，將群交互系統標識與連接標識集合之間的關聯關系以群交互系統標識為鍵名，以連接標識集合為鍵值存儲到第一映射表中；將連接標識集合存儲到列表中；將用戶標識與用戶在連接標識集合中的下標位置之間的關聯關系以用戶標識為鍵名，以用戶在連接標識集合中的下標位置為鍵值存儲到第二映射表中。

可選地，將所述消息投遞給所述連接標識對應的用戶包括：將所述連接標識進行復制分段后分配給投遞線程池，以將所述消息異步投遞給所述連接標識對應的用戶。

根據本發明實施例的另一方面，提供了一種消息廣播的裝置。

一種消息廣播的裝置，包括：信息獲取模塊，用于根據消息廣播任務獲取接入點的網絡地址信息集合；消息廣播模塊，用于確定每個網絡地址信息對應的接入點，并調用所述接入點的進程廣播服務將消息廣播給用戶，其中，所述進程廣播服務用于使所述接入點從其進程的內存中讀取連接標識并將所述消息投遞給所述連接標識對應的用戶，所述連接標識用于標識接入點與用戶的關聯關系。

可選地，通過映射表和列表結合的方式保存數據之間的關聯關系。

可選地，所述數據包括群交互系統標識、用戶標識和連接標識，并且，將群交互系統標識與連接標識集合之間的關聯關系以群交互系統標識為鍵名，以連接標識集合為鍵值存儲到第一映射表中；將連接標識集合存儲到列表中；將用戶標識與用戶在連接標識集合中的下標位置之間的關聯關系以用戶標識為鍵名，以用戶在連接標識集合中的下標位置為鍵值存儲到第二映射表中。

可選地，所述消息廣播模塊還用于：將所述連接標識進行復制分段后分配給投遞線程池，以將所述消息異步投遞給所述連接標識對應的用戶。