[發明專利]消息傳輸方法、存儲設備及服務器

在審

• 申請號: 201710754451.8
• 申請日: 2017-08-29
• 公開（公告）號: CN107566251A
• 公開（公告）日: 2018-01-09
• 發明（設計）人: 凌超
• 申請（專利權）人: 闊地教育科技有限公司
• 主分類號: H04L12/58
• 分類號: H04L12/58;H04L12/18;H04L12/24
• 代理公司: 暫無信息
• 代理人: 暫無信息

技術領域

本發明涉及計算機技術領域，具體而言，涉及消息傳輸方法、存儲設備、服務器。

背景技術

在分布式消息系統中，每一個客戶端(client)可能連接不同的節點node，很多 client屬于同一個組，當client向一個節點發送廣播消息后，在由此節點向集群內其他所有節點推送該消息，然后由其他節點向各自的client推送消息。如果節點很多的話，由于系統并不知道組內有多少節點node和client。需要向節點內先廣播消息，再由各個節點向組內廣播消息。節點內消息廣播時會產生很多節點內的消息通訊。浪費流量，增加服務器壓力，同時增加網絡延遲，且隨著節點node的添加，廣播的次數線性增長。

發明內容

有鑒于此，根據本發明實施例的一個方面，一種消息傳輸方法，包括：在多個服務器中確定至少一個中心服務器；所述中心服務器接收來自不同終端的訂閱請求；所述中心服務器根據訂閱組別將所述不同終端分成不同組，并選取多個服務器分別用于服務所述不同組內的終端。

根據本發明實施例的另一方面，還提出了一種存儲設備，其中存儲有多條指令，所述指令適于由處理器加載并執行，包括：在多個服務器中確定至少一個中心服務器；所述中心服務器接收來自不同終端的訂閱請求；所述中心服務器根據訂閱組別將所述不同終端分成不同組，并選取多個服務器分別用于服務所述不同組內的終端。

根據本發明實施例的另一方面，還提供了一種服務器，包括：處理器，適于實現各指令；存儲設備，適于存儲多條指令，所述指令適于由所述處理器加載并執行：接收來自不同終端的訂閱請求；根據訂閱組別將所述不同終端分成不同組，并選取多個服務器分別用于服務所述不同組內的終端。

為了解決節點內消息廣播時會產生很多節點內的消息通訊，浪費流量的問題，本發明實施例在多個服務器中確定至少一個中心服務器；所述中心服務器接收來自不同終端的訂閱請求；所述中心服務器根據訂閱組別將所述不同終端分成不同組，并選取多個服務器分別用于服務所述不同組內的終端，從而減少了消息的廣播次數，減少了網絡延遲，提高了消息傳輸效率。

附圖說明

圖1示出了根據本發明的一個實施例的消息傳輸方法的流程圖；

圖2示出了根據本發明的一個實施例的節點分配圖；

圖3示出了根據本發明的一個實施例的節點圖；

圖4示出了根據本發明的一個實施例的服務器的框圖。

具體實施方式

為了能夠更清楚地理解本發明的上述目的、特征和優點，下面結合附圖和具體實施方式對本發明進行進一步的詳細描述。需要說明的是，在不沖突的情況下，本申請的實施例及實施例中的特征可以相互組合。

在下面的描述中闡述了很多具體細節以便于充分理解本發明，但是，本發明還可以采用其他不同于在此描述的其他方式來實施，因此，本發明的保護范圍并不受下面公開的具體實施例的限制。

圖1示出了根據本發明的一個實施例的消息傳輸方法的流程圖。

如圖1所示，根據本發明實施例的一種消息傳輸方法，包括：

步驟102，在多個服務器中確定至少一個中心服務器。

步驟104，所述中心服務器接收來自不同終端的訂閱請求。

步驟106，所述中心服務器根據訂閱組別將所述不同終端分成不同組，并選取多個服務器分別用于服務所述不同組內的終端。

訂閱請求中包含訂閱組別信息，中心服務器可根據訂閱請求中的訂閱組別信息將這些終端分成不同組別。不同的服務器分別服務不同的組別內的終端。

選取多個服務器分別用于服務所述不同組內的終端，包括：

根據各組別的標識生成對應于各組別的哈希值；

根據各組別的哈希值所處的哈希值區間以及各哈希值區間對應的服務器，將所述各哈希值區間對應的服務器作為分別服務所述不同組內的終端的服務器。

每一個哈希值區間對應一個服務器，根據每一組別的標識能夠生成各組別各自的哈希值，基于哈希值所處的哈希值區間，可為每一組終端分配對應的服務器。

通過快速選舉算法確定所述中心服務器。其中，所述快速選舉算法包括：

計算出所述多個服務器中壓力最小的服務器，將所述壓力最小的服務器作為所述中心服務器，或者將接收到最新消息的服務器作為所述中心服務器。

在服務所述不同組內的終端的多個服務器中的一個服務器失效時，將失效的服務器所服務的終端歸屬至與所述失效的服務器相鄰的服務器，其中，所述相鄰的服務器是哈希值區間相鄰的服務器。