[發明專利]一種分布式Web即時消息發送系統和方法

在審

• 申請號: 201810031183.1
• 申請日: 2018-01-12
• 公開（公告）號: CN108200184A
• 公開（公告）日: 2018-06-22
• 發明（設計）人: 蔡衛衛
• 申請（專利權）人: 鄭州云海信息技術有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/58
• 代理公司: 濟南信達專利事務所有限公司 37100
• 代理人: 韓月娥

本發明公開一種分布式Web即時消息發送系統和方法，涉及Web應用技術，Web應用部署多個服務節點時，通過在服務節點中使用消息發送器、消息消費者、消息轉發器配合WebSocket及消息隊列技術，某個客戶端訪問Web應用時，其連接的服務節點通過WebSocket直接發送消息給客戶端，同時消息發送到消息隊列中，其他所有服務節點消費消息隊列中消息，然后把消息發送給連接到此服務節點的客戶端，使訪問分布式Web應用的所有客戶端能夠接收到所有服務節點發送的消息。本發明保證訪問客戶端能夠準確訂閱消息，并接收到其連接的服務器及其他服務器上發送的消息，防止客戶端消息丟失；能夠應用于IOP平臺及其他服務產品，具有很好的復用價值。

技術領域

本發明涉及Web應用技術，具體的說是一種分布式Web即時消息發送系統和方法。

背景技術

Web頁面即時通訊多采用WebSocket，由服務端將消息推送給Web瀏覽器。WebSocket協議是基于TCP的一種網絡協議，它實現了瀏覽器與服務器全雙工(full-duplex)通信——允許服務器主動發送信息給客戶端。Web頁面即時通訊在單個服務節點的情況下是有效的，能夠正常通訊的。

但是當今Web應用由于大規模、大用戶量、高并發的需求，需要分布式部署，包含多個服務節點，而一個客戶端（Web瀏覽器）訪問應用的時候，只會連接其中一個服務節點（比如服務節點1），那么其他服務節點（比如服務節點2、服務節點3）上產生的消息則無法發送給這個客戶端，導致這個客戶端只能接收到部分消息，如附圖1所示。這種情況下，可能會造成Web應用中訪問客戶端消息丟失。

發明內容

本發明針對目前技術發展的需求和不足之處，提供一種分布式Web即時消息發送系統和方法。

本發明所述一種分布式Web即時消息發送系統，解決上述技術問題采用的技術方案如下：所述分布式Web即時消息發送系統，其系統架構包括：

客戶端，能夠連接上Web應用中的一個服務節點，接收Web應用中所有服務節點發送過來的消息；

消息隊列服務器，用于接收所有服務節點發送的消息，臨時存放消息；

Web應用中若干服務節點，通過WebSocket直接向與其連接的客戶端發送消息，并將消息發送給消息隊列服務器；服務節點能夠消費消息隊列服務器中存放的其他服務節點的消息，并將消息發送給連接到其上的客戶端。

進一步，Web應用中的所有服務節點，均設置了消息發送器、消息轉發器、消息消費者。

進一步，所述消息發送器，用于服務節點通過WebSocket直接發送消息給與其連接的客戶端。

進一步，所述消息轉發器，用于服務節點將消息發送給消息隊列服務器。

進一步，所述消息消費者，連接于所述消息隊列服務器，用于服務節點消費消息隊列服務器中存放的其他服務節點的消息，并負責對消息進行處理，轉發消息給消息發送器。

本發明提出的一種分布式Web即時消息發送方法，具體實現流程包括:

步驟1、客戶端訪問Web應用中服務節點，客戶端連接一個服務節點，服務節點通過WebSocket直接發送消息給與其連接的客戶端；

步驟2、服務節點將消息發送到消息隊列服務器中臨時存放；

步驟3、服務節點消費消息隊列服務器中存放的其他服務節點的消息，并將消息發送給與其連接的客戶端；

步驟4、其他服務節點消費消息隊列服務器中存放的該服務節點的消息，并將消息發送給與其連接的客戶端。

進一步，所述步驟1：所述服務節點通過其消息發送器直接發送消息給客戶端。