[發(fā)明專利]一種消息推送管理方法和裝置

在審

• 申請?zhí)枺?/td>: 202010897268.5
• 申請日: 2020-08-31
• 公開（公告）號: CN113783913A
• 公開（公告）日: 2021-12-10
• 發(fā)明（設計）人: 孫岑
• 申請（專利權）人: 北京沃東天駿信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/58
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 郝紅玉;馮培培

本發(fā)明公開了一種消息推送管理方法和裝置，涉及計算機技術領域。該方法的一具體實施方式包括：統(tǒng)計預定歷史時長內各用戶在應用中的登陸次數(shù)，將登陸次數(shù)大于或等于預定次數(shù)閾值的用戶確定為活躍用戶，剩余用戶確定為非活躍用戶；獲取與單個用戶對應的消息列表，比對消息記錄表和消息列表中的消息，確定未拉取消息；優(yōu)先執(zhí)行對活躍用戶的未拉取消息的拉取操作，在將消息推送至活躍用戶完畢后，再執(zhí)行對非活躍用戶的未拉取消息的拉取操作。該實施方式保證在活動前一個黃金時間段(如1～2小時)內將消息推送給用戶，有效保證了用戶尤其是活躍用戶的參與度，實現(xiàn)消息層級發(fā)送，以此提高消息發(fā)送效率。

技術領域

本發(fā)明涉及計算機技術領域，尤其涉及一種消息推送管理方法和裝置。

背景技術

在即將開展活動時，需要給百萬甚至千萬用戶發(fā)送消息進行活動推送，保證用戶在活動還沒開始前即可收到消息。用戶查看消息時需要訪問應用后臺的消息明細接口，在用戶查看消息后，后臺會將該消息打標已讀。

目前需將用戶ID與消息ID之間的關系存儲到數(shù)據(jù)庫，并依據(jù)該關系將消息推送至用戶移動端的操作，需8小時以上。由于耗時過長，所以只能考慮提前一天發(fā)送，當活動真正開始時可能有些用戶已經(jīng)忘記了，導致推送效果不理想，所以需縮短推送時間點，例如在活動開始前1～2小時內收到消息。

針對上述問題，目前采用多線程方式進行消息入庫處理，以在發(fā)送消息至用戶移動端的同時，將用戶ID和消息ID之間的關系存儲到數(shù)據(jù)庫中。隨著用戶數(shù)量的增多，需開啟的線程數(shù)也隨之增多，對服務器的性能要求也逐漸提高，但線程數(shù)會達到一定瓶頸，所以仍不能解決發(fā)送效率低的問題。

發(fā)明內容

有鑒于此，本發(fā)明實施例提供一種消息推送管理方法和裝置，至少能夠解決現(xiàn)有技術中發(fā)送消息效率低的問題。

為實現(xiàn)上述目的，根據(jù)本發(fā)明實施例的一個方面，提供了一種消息推送管理方法，包括：

統(tǒng)計預定歷史時長內各用戶在應用中的登陸次數(shù)，將登陸次數(shù)大于或等于預定次數(shù)閾值的用戶確定為活躍用戶，剩余用戶確定為非活躍用戶；

獲取與單個用戶對應的消息列表，比對消息記錄表和所述消息列表中的消息，確定未拉取消息；其中，消息列表用于存儲已拉取的消息，消息記錄表用于記錄應用中推送的所有消息；

優(yōu)先執(zhí)行對活躍用戶的未拉取消息的拉取操作，在將消息推送至活躍用戶完畢后，再執(zhí)行對非活躍用戶的未拉取消息的拉取操作。

可選的，還包括：響應于單個活躍用戶的登陸應用操作，判斷當前隊列中是否存在空閑位，若存在，則將所述單個活躍用戶添加至所述隊列的隊尾處；若不存在，則移除位于隊列首位的活躍用戶，并依次順移剩余位置處的活躍用戶，以將所述單個活躍用戶添加至所述隊列的隊尾處。

可選的，所述比對消息記錄表和所述消息列表中的消息，確定未拉取消息，包括：獲取所述消息列表中各消息的消息標識，確定最大消息標識；若所述最大消息標識小于所述消息記錄表中的最大消息標識，則將所述消息記錄表中位于所述消息列表中最大消息標識之后的消息，作為未拉取消息。

可選的，所述作為未拉取消息，還包括：獲取每個消息的生成時間，去除生成時間早于用戶在應用中的注冊時間的消息；和/或獲取與每個消息對應的活動開始時間，去除開始時間早于當前時間的消息。

可選的，所述獲取與單個用戶對應的消息列表，還包括：根據(jù)各消息所屬的一級類型和二級類型，對所述消息列表中的消息進行分組，得到多個子消息列表。

可選的，還包括：確定與單個用戶的用戶標識對應的日志文件，將拉取到的消息的標識存儲至所述日志文件中；以及同步所述日志文件至緩存中；其中，所述日志文件存儲在數(shù)據(jù)庫中。

可選的，還包括：獲取所述消息列表中各消息的狀態(tài)，確定狀態(tài)為未讀的消息；響應于對至少一個未讀消息的點擊讀取操作，將所述至少一個未讀消息的狀態(tài)更改為已讀。