[發明專利]可擴展消息傳送系統中的數據復制

在審

• 申請號: 201780053565.8
• 申請日: 2017-08-25
• 公開（公告）號: CN109644155A
• 公開（公告）日: 2019-04-16
• 發明（設計）人: Y·哈弗里;L·瓦爾金;F·E·林德
• 申請（專利權）人: 薩托里環球有限責任公司
• 主分類號: H04L12/58
• 分類號: H04L12/58
• 代理公司: 北京林達劉知識產權代理事務所(普通合伙) 11277
• 代理人: 劉新宇

本發明提供了包括編碼在計算機存儲介質上的計算機程序的方法、系統和設備，用于：維護多個通道，各通道包括一個或多個緩沖器中所存儲的有序的多個消息，各緩沖器具有相應的存活時間并且多個副本駐留在相應節點上；檢測所述多個節點中的第一節點的故障，其中所述第一節點存儲第一緩沖器的相應的第一副本，并且至少一個訂戶訂閱一個或多個第一通道的消息；對于具有駐留在所述第一節點上的第一副本的第一緩沖器，將所述多個節點中的任意其它節點標識為存儲所述第一緩沖器的第二副本的第二節點；將所述至少一個訂戶從所述第一節點重定向至所述第二節點；以及針對所述至少一個訂戶，檢索所述第二節點上的所述第二副本中所存儲的消息。

背景技術

本說明書涉及數據通信系統，特別地涉及用于實現消息傳送系統中的數據復制的系統。

發布-訂閱模式(或者“PubSub”)是利用軟件系統實現的數據通信消息傳送布置，其中，所謂的發布者將消息發布到主題，并且所謂的訂戶接收與他們所訂閱的特定主題有關的消息。每個主題可以存在一個或多個發布者，并且發布者一般不知道什么樣的訂戶(如果有的話)將接收到所發布的消息。一些PubSub系統不緩存消息或者具有小的緩存，這意味著訂戶可能不會接收到在訂閱特定主題之前所發布的消息。在消息發布激增期間、或者隨著特定主題的訂戶的數量增加，PubSub系統可能易受到性能不穩定性的影響。

發明內容

一般來說，本說明書中所描述的主題的一個方面可以體現在如下的方法中，該方法包括如下的動作：維護多個通道，各通道包括一個或多個緩沖器中所存儲的有序的多個消息，各緩沖器包括相應的存活時間并且多個副本駐留在相應的多個節點上；檢測所述多個節點中的第一節點的故障，其中所述第一節點存儲針對一個或多個第一通道的第一緩沖器的相應的第一副本，以及其中至少一個訂戶訂閱所述一個或多個第一通道的消息；對于具有駐留在所述第一節點上的第一副本的第一緩沖器，將所述多個節點中的任意其它節點標識為存儲所述第一緩沖器的第二副本的第二節點；將所述至少一個訂戶從所述第一節點重定向至所述第二節點；以及針對所述至少一個訂戶，檢索所述第二節點上的所述第二副本中所存儲的消息。該方面的其它實施例包括相應的系統、設備和計算機程序。

這些和其它方面可以可選地包括以下特征中的一個或多個特征。將所述多個節點中的任意其它節點標識為第二節點可以包括：基于所述多個節點中的任意其它節點中的各節點的相應工作負載來選擇所述第二節點。至少一個發布者可以從所述第一節點重定向至所述第二節點，并且消息可以從所述至少一個發布者發送至所述第二節點以存儲在所述第二副本中。所述第二節點可被配置為將來自發布者的用以存儲在所述第二副本中的消息轉發至所述多個節點中的任意第三節點以將所述消息存儲在所述第一緩沖器的第三副本中。所述第一緩沖器的多個副本可以包括副本鏈，所述副本鏈包括至少頭部副本和尾部副本。所述鏈中的特定副本中所存儲的消息可被轉發至所述鏈的下一相鄰副本以進行存儲，直到所述頭部副本中的消息被存儲在所述尾部副本中為止。檢測所述第一節點的故障可以包括：檢測所述第一副本中所存儲的一個或多個消息未被轉發至所述鏈中的所述第一副本的下一相鄰副本以進行存儲的故障。所述第一副本可以是所述頭部副本，以及至少一個發布者可被配置為在被重定向至所述第二節點之前將所述第一緩沖器的消息發送至所述第一節點以存儲在所述第一副本中。檢測所述多個節點中的所述第一節點的故障可以包括：檢測所述至少一個發布者將消息發送至所述第一節點以存儲在所述第一副本中的故障。檢測所述多個節點中的所述第一節點的故障可以包括：檢測所述至少一個訂戶在被重定向至所述第二節點之前從所述第一副本獲得消息的故障，以及其中所述第一副本可以是所述鏈中的特定副本。