[發(fā)明專利]可擴(kuò)展消息傳送系統(tǒng)中的數(shù)據(jù)復(fù)制

在審

• 申請?zhí)枺?/td>: 201780053565.8
• 申請日: 2017-08-25
• 公開（公告）號: CN109644155A
• 公開（公告）日: 2019-04-16
• 發(fā)明（設(shè)計(jì)）人: Y·哈弗里;L·瓦爾金;F·E·林德
• 申請（專利權(quán)）人: 薩托里環(huán)球有限責(zé)任公司
• 主分類號: H04L12/58
• 分類號: H04L12/58
• 代理公司: 北京林達(dá)劉知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11277
• 代理人: 劉新宇

1.一種計(jì)算機(jī)實(shí)現(xiàn)的方法，包括：

維護(hù)多個通道，

其中各通道包括一個或多個緩沖器中所存儲的有序的多個消息，各緩沖器包括相應(yīng)的存活時間，各緩沖器包括多個副本，以及各副本駐留在相應(yīng)的多個節(jié)點(diǎn)上；

檢測所述多個節(jié)點(diǎn)中的第一節(jié)點(diǎn)的故障，

其中所述第一節(jié)點(diǎn)存儲針對一個或多個第一通道的第一緩沖器的相應(yīng)的第一副本，以及至少一個訂戶訂閱所述一個或多個第一通道的消息；

對于具有駐留在所述第一節(jié)點(diǎn)上的第一副本的第一緩沖器，將所述多個節(jié)點(diǎn)中的任意其它節(jié)點(diǎn)標(biāo)識為存儲所述第一緩沖器的第二副本的第二節(jié)點(diǎn)；

將所述至少一個訂戶從所述第一節(jié)點(diǎn)重定向至所述第二節(jié)點(diǎn)；以及

針對所述至少一個訂戶，檢索所述第二節(jié)點(diǎn)上的所述第二副本中所存儲的消息。

2.根據(jù)權(quán)利要求1所述的方法，其中，將所述多個節(jié)點(diǎn)中的任意其它節(jié)點(diǎn)標(biāo)識為存儲所述第一緩沖器的第二副本的第二節(jié)點(diǎn)包括：

基于所述多個節(jié)點(diǎn)中的任意其它節(jié)點(diǎn)中的各節(jié)點(diǎn)的相應(yīng)工作負(fù)載來選擇所述第二節(jié)點(diǎn)。

3.根據(jù)權(quán)利要求1所述的方法，還包括：

將至少一個發(fā)布者從所述第一節(jié)點(diǎn)重定向至所述第二節(jié)點(diǎn)；以及

將來自所述至少一個發(fā)布者的消息發(fā)送至所述第二節(jié)點(diǎn)以存儲在所述第二副本中。

4.根據(jù)權(quán)利要求1所述的方法，其中，所述第二節(jié)點(diǎn)被配置為將來自發(fā)布者的用以存儲在所述第二副本中的消息轉(zhuǎn)發(fā)至所述多個節(jié)點(diǎn)中的任意第三節(jié)點(diǎn)以將所述消息存儲在所述第一緩沖器的第三副本中。

5.根據(jù)權(quán)利要求1所述的方法，其中，所述第一緩沖器的多個副本包括副本鏈，所述副本鏈包括至少頭部副本和尾部副本。

6.根據(jù)權(quán)利要求5所述的方法，其中，所述鏈中的特定副本中所存儲的消息被轉(zhuǎn)發(fā)至所述鏈的下一相鄰副本以進(jìn)行存儲，直到所述頭部副本中的消息被存儲在所述尾部副本中為止。

7.根據(jù)權(quán)利要求6所述的方法，其中，檢測所述多個節(jié)點(diǎn)中的所述第一節(jié)點(diǎn)的故障包括：

檢測所述第一副本中所存儲的一個或多個消息未被轉(zhuǎn)發(fā)至所述鏈中的所述第一副本的下一相鄰副本以進(jìn)行存儲的故障。

8.根據(jù)權(quán)利要求5所述的方法，其中，所述第一副本包括所述頭部副本，以及至少一個發(fā)布者被配置為在被重定向至所述第二節(jié)點(diǎn)之前將所述第一緩沖器的消息發(fā)送至所述第一節(jié)點(diǎn)以存儲在所述第一副本中。

9.根據(jù)權(quán)利要求8所述的方法，其中，檢測所述多個節(jié)點(diǎn)中的所述第一節(jié)點(diǎn)的故障包括：

檢測所述至少一個發(fā)布者將消息發(fā)送至所述第一節(jié)點(diǎn)以存儲在所述第一副本中的故障。

10.根據(jù)權(quán)利要求5所述的方法，其中，檢測所述多個節(jié)點(diǎn)中的所述第一節(jié)點(diǎn)的故障包括：

檢測所述至少一個訂戶在被重定向至所述第二節(jié)點(diǎn)之前從所述第一副本獲得消息的故障，以及其中所述第一副本是所述鏈中的特定副本。

11.一種消息傳送系統(tǒng)，包括：

通道管理器，其被配置為維護(hù)多個通道，

其中各通道包括一個或多個緩沖器中所存儲的有序的多個消息，各緩沖器包括相應(yīng)的存活時間，各緩沖器包括多個副本，各副本駐留在相應(yīng)的多個節(jié)點(diǎn)上，以及

其中所述通道管理器能夠操作以進(jìn)行包括以下各項(xiàng)的操作：

檢測所述多個節(jié)點(diǎn)中的第一節(jié)點(diǎn)的故障，

其中所述第一節(jié)點(diǎn)存儲針對一個或多個第一通道的第一緩沖器的相應(yīng)的第一副本，以及至少一個訂戶訂閱所述一個或多個第一通道的消息；

對于具有駐留在所述第一節(jié)點(diǎn)上的第一副本的第一緩沖器，將所述多個節(jié)點(diǎn)中的任意其它節(jié)點(diǎn)標(biāo)識為存儲所述第一緩沖器的第二副本的第二節(jié)點(diǎn)；

將所述至少一個訂戶從所述第一節(jié)點(diǎn)重定向至所述第二節(jié)點(diǎn)；以及

針對所述至少一個訂戶，檢索所述第二節(jié)點(diǎn)上的所述第二副本中所存儲的消息。