[發(fā)明專(zhuān)利]一種發(fā)布訂閱系統(tǒng)中可靠性保障方法及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201210560977.X
• 申請(qǐng)日: 2012-12-21
• 公開(kāi)（公告）號(hào): CN102984174A
• 公開(kāi)（公告）日: 2013-03-20
• 發(fā)明（設(shè)計(jì)）人: 章洋;陳俊亮;郭文琪
• 申請(qǐng)（專(zhuān)利權(quán)）人: 北京郵電大學(xué)
• 主分類(lèi)號(hào): H04L29/06
• 分類(lèi)號(hào): H04L29/06;H04L29/08
• 代理公司: 北京派特恩知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11270
• 代理人: 張振偉;王黎延

1.一種發(fā)布訂閱系統(tǒng)中可靠性保障系統(tǒng)，其特征在于，該可靠性保障系統(tǒng)包括可靠訂閱模塊和節(jié)點(diǎn)中的可靠訂閱子模塊；其中，

所述可靠訂閱子模塊，用于在節(jié)點(diǎn)加入發(fā)布訂閱系統(tǒng)時(shí)，并在預(yù)設(shè)的備份/恢復(fù)模式為全局備份/恢復(fù)模式時(shí)，向所述可靠訂閱模塊發(fā)送節(jié)點(diǎn)加入消息；以及，對(duì)接收到的所述可靠訂閱模塊發(fā)送的通知消息進(jìn)行訂閱備份；

所述可靠訂閱模塊，用于在接收到所述節(jié)點(diǎn)加入消息時(shí)，獲取所述節(jié)點(diǎn)的配置信息，根據(jù)所述節(jié)點(diǎn)的配置信息選擇一個(gè)以上節(jié)點(diǎn)作為所述節(jié)點(diǎn)的備份節(jié)點(diǎn)，通知相應(yīng)的節(jié)點(diǎn)進(jìn)行訂閱備份，并更新拓?fù)湫畔⒈碇械墓?jié)點(diǎn)拓?fù)湫畔ⅰ?/p>

2.根據(jù)權(quán)利要求1所述的可靠性保障系統(tǒng)，其特征在于，所述節(jié)點(diǎn)為集群代表或集群代理；

所述節(jié)點(diǎn)為集群代表時(shí)，所述可靠訂閱子模塊，還用于向所述可靠訂閱模塊發(fā)送集群加入消息；

相應(yīng)的，所述可靠訂閱模塊，還用于接收到所述集群加入消息時(shí)，獲取所述集群的配置信息，并根據(jù)所述集群的配置信息更新拓?fù)湫畔⒈碇械募和負(fù)湫畔ⅰ?/p>

3.根據(jù)權(quán)利要求1或2所述的可靠性保障系統(tǒng)，其特征在于，

所述可靠訂閱模塊，還用于將所述節(jié)點(diǎn)的備份節(jié)點(diǎn)的信息通知所述節(jié)點(diǎn)的可靠訂閱子模塊，將所述節(jié)點(diǎn)的信息通知所述節(jié)點(diǎn)的備份節(jié)點(diǎn)的可靠訂閱子模塊；

相應(yīng)的，所述可靠訂閱子模塊，還用于將節(jié)點(diǎn)的備份節(jié)點(diǎn)信息和將所述節(jié)點(diǎn)作為備份節(jié)點(diǎn)的其他節(jié)點(diǎn)的信息保存在本地的可靠鄰居表中；為所接收到的訂閱消息建立副本，并將訂閱消息副本發(fā)送給所述節(jié)點(diǎn)的備份節(jié)點(diǎn)作為訂閱備份。

4.根據(jù)權(quán)利要求1或2所述的可靠性保障系統(tǒng)，其特征在于，

所述可靠訂閱模塊，還用于在接收到所述節(jié)點(diǎn)失效消息時(shí)，從拓?fù)湫畔⒈碇蝎@取失效節(jié)點(diǎn)的備份節(jié)點(diǎn)，向優(yōu)先級(jí)最高的備份節(jié)點(diǎn)的可靠訂閱子模塊發(fā)送對(duì)所述失效節(jié)點(diǎn)進(jìn)行訂閱恢復(fù)的通知消息，并更新拓?fù)湫畔⒈恚?/p>

相應(yīng)的，所述優(yōu)先級(jí)最高的備份節(jié)點(diǎn)的可靠訂閱子模塊，還用于對(duì)所述失效節(jié)點(diǎn)進(jìn)行訂閱恢復(fù)。

5.根據(jù)權(quán)利要求1或2所述的可靠性保障系統(tǒng)，其特征在于，所述可靠訂閱子模塊還用于，

接收到備份節(jié)點(diǎn)的可靠訂閱子模塊發(fā)送的備份消息時(shí)，將所述備份節(jié)點(diǎn)的信息添加到所述可靠鄰居表中的備份節(jié)點(diǎn)信息中；

接收到新訂閱消息時(shí)，為所述新訂閱消息建立副本，從所述可靠鄰居表中獲取所述節(jié)點(diǎn)的備份節(jié)點(diǎn)，并將新訂閱消息副本發(fā)送給所述節(jié)點(diǎn)的備份節(jié)點(diǎn)作為訂閱備份。

6.根據(jù)權(quán)利要求1所述的可靠性保障系統(tǒng)，其特征在于，

所述可靠訂閱子模塊，還用于在預(yù)設(shè)的備份/恢復(fù)模式為本地備份/恢復(fù)模式時(shí)，為所接收到的訂閱消息建立副本作為所述節(jié)點(diǎn)的訂閱備份，并在本地保存所述節(jié)點(diǎn)的訂閱備份；還用于當(dāng)所述節(jié)點(diǎn)失效時(shí)，讀取所述本地保存的訂閱備份進(jìn)行訂閱恢復(fù)。

7.根據(jù)權(quán)利要求6所述的可靠性保障系統(tǒng)，其特征在于，

所述可靠訂閱子模塊，還用于接收到新訂閱消息時(shí)，為所接收到的新訂閱消息建立副本，并作為所述節(jié)點(diǎn)當(dāng)前的訂閱備份，同時(shí)刪除之前的訂閱備份。

8.根據(jù)權(quán)利要求3、5或7所述的可靠性保障系統(tǒng)，其特征在于，該系統(tǒng)還包括可靠Web消息模塊，用于在待發(fā)送的消息中添加消息序列，并在希望接收到確認(rèn)的消息中插入AckRequested報(bào)頭；用于在接收到攜帶有AckRequested報(bào)頭的消息后，返回確認(rèn)消息。

9.一種發(fā)布訂閱系統(tǒng)中可靠性保障方法，其特征在于，該方法包括：

在節(jié)點(diǎn)加入發(fā)布訂閱系統(tǒng)時(shí)，并在預(yù)設(shè)的備份/恢復(fù)模式為全局備份/恢復(fù)模式時(shí)，節(jié)點(diǎn)本地的可靠訂閱子模塊向可靠訂閱模塊發(fā)送節(jié)點(diǎn)加入消息；

可靠訂閱模塊接收到節(jié)點(diǎn)加入消息時(shí)，獲取所述節(jié)點(diǎn)的配置信息，根據(jù)所述節(jié)點(diǎn)的配置信息選擇一個(gè)以上節(jié)點(diǎn)作為所述節(jié)點(diǎn)的備份節(jié)點(diǎn)，通知相應(yīng)節(jié)點(diǎn)進(jìn)行訂閱備份，并更新拓?fù)湫畔⒈碇械墓?jié)點(diǎn)拓?fù)湫畔ⅰ?/p>

10.根據(jù)權(quán)利要求9所述的方法，其特征在于，所述節(jié)點(diǎn)為集群代表或集群代理；

所述節(jié)點(diǎn)為集群代表時(shí)，在所述節(jié)點(diǎn)本地的可靠訂閱子模塊向可靠訂閱模塊發(fā)送節(jié)點(diǎn)加入消息以前，該方法還包括：

所述可靠訂閱子模塊向所述可靠訂閱模塊發(fā)送集群加入消息；

所述可靠訂閱模塊接收到所述集群加入消息時(shí)，獲取所述集群的配置信息，并根據(jù)所述集群的配置信息更新拓?fù)湫畔⒈碇械募和負(fù)湫畔ⅰ?/p>