[發明專利]消息推送方法、裝置、計算機設備和存儲介質

有效

• 申請號: 202011097078.1
• 申請日: 2020-10-14
• 公開（公告）號: CN112448883B
• 公開（公告）日: 2023-05-05
• 發明（設計）人: 唐東;王剛;徐恒;錢偉;葛振宇
• 申請（專利權）人: 蘇寧云計算有限公司
• 主分類號: H04L51/214
• 分類號: H04L51/214;H04L67/10;H04L67/55;G06F9/54
• 代理公司: 北京市萬慧達律師事務所 11111
• 代理人: 劉艷麗

本申請涉及一種消息推送方法、裝置、計算機設備和存儲介質。所述方法包括：同時執行第一處理邏輯和第二處理邏輯；其中，所述第一處理邏輯的執行過程包括：在接收到分布式緩存發送的第一事件參數時，根據所述第一事件參數生成第一推送任務，將所述第一推送任務加入消息推送隊列；所述第二處理邏輯的執行過程包括：在滿足預設觸發條件時根據預先確定的消息主題集合獲得第二事件參數，根據所述第二事件參數生成第二推送任務，將所述第二推送任務加入所述消息推送隊列；根據所述消息推送隊列進行消息推送。本申請實施例能夠在服務節點和分布式緩存出現掉線狀況時避免消息丟失，保證同步且及時的消息推送服務。

技術領域

本申請涉及消息推送技術領域，特別是涉及一種消息推送方法、裝置、計算機設備和存儲介質。

背景技術

在分布式系統中實現消息的實時推送，由于推送服務為集群部署，所以會存在多個服務節點。各個服務節點無法同時向連接至該節點的客戶端發送消息，導致不同客戶端接收到新消息的時間不一致，同時導致了部分客戶端中的消息推送不及時。為了協調這些服務節點同時向連接到本節點的客戶端發送消息，通常會通過分布式緩存的發布訂閱機制來實現服務節點間的事件通知。

然而，在實際情況中，服務節點和分布式緩存之間可能會掉線，服務節點在掉線后重連，會丟失掉線期間的事件，這會造成部分消息無法發送給連接至該服務節點的客戶端。

發明內容

本發明針對現有技術的缺點，提供了一種消息推送方法、裝置、計算機設備和存儲介質。本發明實施例能夠實現在服務節點和分布式緩存出現掉線狀況時避免消息丟失，保證同步且及時的消息推送服務。

本發明根據第一方面提供了消息推送方法，在一個實施例中，該方法包括：

同時執行第一處理邏輯和第二處理邏輯；其中，第一處理邏輯的執行過程包括：在接收到分布式緩存發送的第一事件參數時，根據第一事件參數生成第一推送任務，將第一推送任務加入消息推送隊列；第二處理邏輯的執行過程包括：在滿足預設觸發條件時根據預先確定的消息主題集合獲得第二事件參數，根據第二事件參數生成第二推送任務，將第二推送任務加入所述消息推送隊列；

根據消息推送隊列進行消息推送。

本發明根據第二方面提供了一種消息推送裝置，在一個實施例中，該裝置包括：

任務模塊，用于同時執行第一處理邏輯和第二處理邏輯；其中，第一處理邏輯的執行過程包括：在接收到分布式緩存發送的第一事件參數時，根據第一事件參數生成第一推送任務，將第一推送任務加入消息推送隊列；第二處理邏輯的執行過程包括：在滿足預設觸發條件時根據預先確定的消息主題集合獲得第二事件參數，根據第二事件參數生成第二推送任務，將第二推送任務加入消息推送隊列；

推送模塊，用于根據消息推送隊列進行消息推送。

本發明根據第三方面提供了一種消息推送計算機設備，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，所述處理器執行所述計算機程序時實現上述方法實施例中的步驟。

本發明根據第四方面提供了一種消息推送計算機可讀存儲介質，其上存儲有計算機程序，所述計算機程序被處理器執行時實現上述方法實施例中的步驟。

上述消息推送方法、裝置、計算機設備和存儲介質的實施例中，在第一處理邏輯中通過分布式緩存接收第一事件參數并生成第一推送任務，實現了多服務節點間的事件通知和數據傳遞，能夠實時接收消息參數，可實現消息的及時推送與更新；同時執行第一處理邏輯和第二處理邏輯，在第二處理邏輯的執行過程中利用預先確定的消息主題集合獲取第二事件參數并生成第二推送任務，有效避免了推送服務節點掉線期間可能產生的消息丟失，保證所有消息的及時推送。

附圖說明

圖1為一個實施例中消息推送方法的應用環境圖；

圖2為一個實施例中消息推送方法的流程示意圖；