[發(fā)明專利]一種消息推送方法、系統(tǒng)、設(shè)備及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202110592859.6
• 申請日: 2021-05-28
• 公開（公告）號: CN113382048A
• 公開（公告）日: 2021-09-10
• 發(fā)明（設(shè)計）人: 王妙玉;周亮;黃宇航;吳寧泉
• 申請（專利權(quán)）人: 廣東好太太智能家居有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06;G06F16/958;G06F9/54
• 代理公司: 廣州市越秀區(qū)哲力專利商標(biāo)事務(wù)所(普通合伙) 44288
• 代理人: 成嬋娟

1.一種消息推送方法，其特征在于，應(yīng)用在包括至少一代理服務(wù)器和多個后臺服務(wù)器的分布式系統(tǒng)中，每個所述后臺服務(wù)器均對應(yīng)有至少一客戶端；其消息推送方法包括：

所述代理服務(wù)器響應(yīng)于連接請求在所述后臺服務(wù)器與所述客戶端之間建立連接通道，并對所有已建立連接的客戶端的標(biāo)識信息進(jìn)行存儲；

在任意一所述后臺服務(wù)器產(chǎn)生消息時，所述代理服務(wù)器從訂閱的消息隊列中接收所述后臺服務(wù)器所發(fā)布的消息，并根據(jù)所述標(biāo)識信息將消息推送至所有已建立連接的客戶端中。

2.根據(jù)權(quán)利要求1所述的消息推送方法，其特征在于，所述代理服務(wù)器采用WebSocket協(xié)議在所述后臺服務(wù)器與所述客戶端之間建立長連接。

3.根據(jù)權(quán)利要求2所述的消息推送方法，其特征在于，所述客戶端與所述后臺服務(wù)器之間建立WebSocket連接后，所述代理服務(wù)器為所述客戶端建立對應(yīng)的標(biāo)識信息，所述標(biāo)識信息為所述客戶端的唯一標(biāo)識碼。

4.根據(jù)權(quán)利要求1所述的消息推送方法，其特征在于，所有已建立連接的所述后臺服務(wù)器共同訂閱的同一消息隊列的主題消息，并在任意一所述后臺服務(wù)器產(chǎn)生消息后將其發(fā)布到所述消息隊列的主題消息中。

5.根據(jù)權(quán)利要求1所述的消息推送方法，其特征在于，當(dāng)多個所述后臺服務(wù)器同時產(chǎn)生消息時，按照預(yù)設(shè)的優(yōu)先級規(guī)則將多個后臺服務(wù)器所發(fā)布的消息依次發(fā)布至所訂閱的消息隊列中。

6.根據(jù)權(quán)利要求1所述的消息推送方法，其特征在于，還包括：

任意一所述后臺服務(wù)器將產(chǎn)生的消息發(fā)布至所述消息隊列的同時，對消息進(jìn)行副本處理并寫入非易失內(nèi)存中進(jìn)行存儲；若識別到所述消息隊列中的消息出現(xiàn)丟失時，從所述非易失內(nèi)存中獲取消息并將其推送至所述客戶端中。

7.根據(jù)權(quán)利要求1所述的消息推送方法，其特征在于，還包括：

任意一所述后臺服務(wù)器在產(chǎn)生所述消息時對所述消息添加唯一的約束編碼，所述代理服務(wù)器從所述消息隊列中獲取所述消息時，識別所述消息的約束編碼，判斷該消息的約束編碼是否與前一消息的約束編碼相同，若相同，則丟棄該消息，若不相同，才將該消息推送至所述客戶端中。

8.一種消息推送系統(tǒng)，其特征在于，包括：

多個后臺服務(wù)器，與多個客戶端之間建立WebSocket連接，并在任意一所述后臺服務(wù)器產(chǎn)生消息時將所述消息發(fā)布至多個所述后臺服務(wù)器共同訂閱的消息隊列中；

代理服務(wù)器，用于從訂閱的消息隊列中接收所述后臺服務(wù)器所發(fā)布的消息，并將所述消息推送至所有已建立WebSocket連接的客戶端中。

9.一種電子設(shè)備，其特征在于，其包括處理器、存儲器及存儲于所述存儲器上并可在所述處理器上運(yùn)行的計算機(jī)程序，所述處理器執(zhí)行所述計算機(jī)程序時實現(xiàn)權(quán)利要求1～8任一所述的消息推送方法。

10.一種存儲介質(zhì)，其特征在于，其上存儲有計算機(jī)程序，所述計算機(jī)程序被執(zhí)行時實現(xiàn)權(quán)利要求1～8任一所述的消息推送方法。