[發明專利]一種消息推送方法、裝置、系統、電子設備和存儲介質

在審

• 申請號: 202110460984.1
• 申請日: 2021-04-27
• 公開（公告）號: CN113157466A
• 公開（公告）日: 2021-07-23
• 發明（設計）人: 李潘林
• 申請（專利權）人: 上海銷氪信息科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 豆貝貝

本申請公開了一種消息推送方法、裝置、系統、電子設備和存儲介質，該方法包括：websocket服務集群中各個服務器訂閱redis消息中間件的用戶消息主題；當業務方發布指定消息到redis消息中間件時，websocket服務集群中各個服務器接收redis消息中間件廣播的指定消息；websocket服務集群中各個服務器檢測本地是否存儲有目標用戶信息；目標用戶信息為與指定消息對應的用戶信息；存儲有目標用戶信息的服務器將接收到的指定消息推送至目標用戶信息對應的客戶端。該方法中的websocket服務集群可直接接收到redis消息中間件廣播的指定消息以發送給客戶端，實現過程簡單高效，方便快捷。

技術領域

本申請涉及websocket消息推送技術領域，特別涉及一種消息推送方法、裝置、系統、電子設備和存儲介質。

背景技術

目前，傳統的websocket實時消息推送服務，在websocket服務器集群環境部署下會存在無法準確識別用戶對象具體存放的節點服務器的位置，從而導致消息推送無法有效送達到客戶端。相關技術中，業務方隨機發送消息到某一服務器時，該服務器通過遍歷zookeeper中間件的方式來獲取其他各個服務器的信息，該zookeeper中間件中注冊有服務器集群的信息，然后該服務器將接收到的消息發送給其他各個服務器，以達到將消息有效送達給客戶端的目的。這種方式首先需要訪問zookeeper中間件，再一一發送消息給各個服務器，過程繁瑣且效率低。

發明內容

本申請的目的是提供一種消息推送方法、裝置、系統、電子設備和存儲介質，websocket服務集群可直接接收到redis消息中間件廣播的指定消息，進而發送給目標用戶信息對應的客戶端，實現過程簡單高效，方便快捷，并能夠保證消息有效送達到客戶端。其具體方案如下：

第一方面，本申請公開了一種消息推送方法，包括：

websocket服務集群中各個服務器訂閱redis消息中間件的用戶消息主題；

當業務方發布指定消息到所述redis消息中間件時，所述websocket服務集群中各個服務器接收所述redis消息中間件廣播的所述指定消息；

所述websocket服務集群中各個服務器檢測本地是否存儲有目標用戶信息；所述目標用戶信息為與所述指定消息對應的用戶信息；

存儲有所述目標用戶信息的服務器將接收到的所述指定消息推送至所述目標用戶信息對應的客戶端。

可選的，在所述存儲有所述目標用戶信息的服務器將接收到的所述指定消息推送至所述目標用戶信息對應的客戶端之前，還包括：

若存儲有所述目標用戶信息的服務器檢測到所述目標用戶信息中的用戶狀態為不在線時，將所述指定消息存儲于Mysql數據庫，以當所述目標用戶信息中的用戶狀態為在線時，發送所述指定消息至所述目標用戶信息對應的客戶端。

可選的，所述當業務方發布指定消息到所述redis消息中間件時，所述websocket服務集群中各個服務器接收所述redis消息中間件廣播的所述指定消息，包括：

當所述業務方調用消息分發服務將發布的所述指定消息發送至所述redis消息中間件時，所述websocket服務集群中各個服務器接收所述redis消息中間件廣播的所述指定消息。

可選的，所述存儲有所述目標用戶信息的服務器將接收到的所述指定消息推送至所述目標用戶信息對應的客戶端，包括：

當注冊有所述目標用戶信息的客戶端包含多個時，存儲有所述目標用戶信息的服務器將接收到的所述指定消息推送至注冊有所述目標用戶信息的各個客戶端。

可選的，在所述存儲有所述目標用戶信息的服務器將接收到的所述指定消息推送至所述目標用戶信息對應的客戶端之前，還包括：