一種發布訂閱系統中可靠性保障方法及系統的製作方法

2023-06-20 05:49:01 1

專利名稱：一種發布訂閱系統中可靠性保障方法及系統的製作方法
技術領域：
本發明涉及發布訂閱技術，具體涉及ー種發布訂閱系統中可靠性保障方法及系統。
背景技術：
目前，大多數物聯網應用程式依然使用「請求/應答」這種傳統的通信方式，即客戶機/伺服器模式，但隨著網絡規模的擴大和網絡拓撲的變化，這種傳統模式難以滿足用戶的需求。原因在於，客戶端和伺服器端之間直接且經常地同步通信給雙方造成了緊密的耦合度，並削弱了伸縮性。客戶端輪詢遠端的數據源，就需要使用相應資源來交換數據的正確性。短的輪詢間隔帶來的不必要的請求會浪費資源，而長的輪詢間隔會增加更新的延遲。另外，「請求/應答」方式約束了系統的發展。將控制流編碼於應用組件當中，這雖然方便了工程師的使用，卻也將系統的實際配置和各個組件的應用邏輯混雜在一起。因此，通過在運行時調整應用組件來協調整個系統的能力受到了限制。隨著物聯網技術的不斷發展，物聯網應用程式將逐步運行在大型的分布式計算環境中，發布/訂閱模式隨之產生。在發布/訂閱模式中，信息發布者往往脫離了信息消費者，甚至不需要知道它們的存在。每個消息發布/訂閱節點可以獨立地運行，不受其他節點影響。但是，在這種模式中，若系統中某一個節點因故障而丟失，則節點中的用戶將不能收到該節點發布的消息。因此，如何在發布/訂閱模式中使信息以穩定的、有序的、安全的方式傳播，尤其是如何保障這些信息在系統中可靠地傳輸，成為目前需要解決的問題。

發明內容
有鑑於此，本發明的主要目的在於提供ー種發布訂閱系統中可靠性保障方法及系統，保證拓撲中的節點不會因為故障而丟失，保障訂閱的可靠性，提升了用戶的體驗。為達到上述目的，本發明的技術方案是這樣實現的本發明提供了ー種發布訂閱系統中可靠性保障系統，該可靠性保障系統包括可靠訂閱模塊和節點中的可靠訂閱子模塊；其中，所述可靠訂閱子模塊，用於在節點加入發布訂閱系統時，並在預設的備份/恢復模式為全局備份/恢復模式吋，向所述可靠訂閱模塊發送節點加入消息；以及，對接收到的所述可靠訂閱模塊發送的通知消息進行訂閱備份；所述可靠訂閱模塊，用於在接收到所述節點加入消息時，獲取所述節點的配置信息，根據所述節點的配置信息選擇ー個以上節點作為所述節點的備份節點，通知相應的節點進行訂閱備份，並更新拓撲信息表中的節點拓撲信息。優選地，上述方案中，所述節點為集群代表或集群代理；所述節點為集群代表時，所述可靠訂閱子模塊，還用於向所述可靠訂閱模塊發送集群加入消息；相應的，所述可靠訂閱模塊，還用於接收到所述集群加入消息時，獲取所述集群的配置信息，井根據所述集群的配置信息更新拓撲信息表中的集群拓撲信息。優選地，上述方案中，所述可靠訂閱模塊，還用於將所述節點的備份節點的信息通知所述節點的可靠訂閱子模塊，將所述節點的信息通知所述節點的備份節點的可靠訂閱子模塊；相應的，所述可靠訂閱子模塊，還用於將節點的備份節點信息和將所述節點作為備份節點的其他節點的信息保存在本地的可靠鄰居表中；為所接收到的訂閱消息建立副本，並將訂閱消息副本發送給所述節點的備份節點作為訂閱備份。優選地，上述方案中，所述可靠訂閱模塊，還用於在接收到所述節點失效消息吋，從拓撲信息表中獲取失效節點的備份節點，向優先級最高的備份節點的可靠訂閱子模塊發送對所述失效節點進行訂閱恢復的通知消息，並更新拓撲信息表；相應的，所述優先級最高的備份節點的可靠訂閱子模塊，還用於對所述失效節點 進行訂閱恢復。
優選地，上述方案中，所述可靠訂閱子模塊還用於，接收到備份節點的可靠訂閱子模塊發送的備份消息吋，將所述備份節點的信息添加到所述可靠鄰居表中的備份節點信息中；接收到新訂閱消息吋，為所述新訂閱消息建立副本，從所述可靠鄰居表中獲取所述節點的備份節點，並將新訂閱消息副本發送給所述節點的備份節點作為訂閱備份。優選地，上述方案中，所述可靠訂閱子模塊，還用於在預設的備份/恢復模式為本地備份/恢復模式吋，為所接收到的訂閱消息建立副本作為所述節點的訂閱備份，並在本地保存所述節點的訂閱備份；還用於當所述節點失效時，讀取所述本地保存的訂閱備份進行訂閱恢復。優選地，上述方案中，所述可靠訂閱子模塊，還用於接收到新訂閱消息時，為所接收到的新訂閱消息建立副本，並作為所述節點當前的訂閱備份，同時刪除之前的訂閱備份。優選地，上述方案中，該系統還包括可靠Web消息模塊，用於在待發送的消息中添加消息序列，並在希望接收到確認的消息中插入AckRequested報頭；用於在接收到攜帶有AckRequested報頭的消息後,返回確認消息。本發明還提供了ー種發布訂閱系統中可靠性保障方法，該方法包括在節點加入發布訂閱系統吋，並在預設的備份/恢復模式為全局備份/恢復模式時，節點本地的可靠訂閱子模塊向可靠訂閱模塊發送節點加入消息；可靠訂閱模塊接收到節點加入消息時，獲取所述節點的配置信息，根據所述節點的配置信息選擇ー個以上節點作為所述節點的備份節點，通知相應節點進行訂閱備份，並更新拓撲信息表中的節點拓撲信息。優選地，上述方案中，所述節點為集群代表或集群代理；所述節點為集群代表時，在所述節點本地的可靠訂閱子模塊向可靠訂閱模塊發送節點加入消息以前，該方法還包括所述可靠訂閱子模塊向所述可靠訂閱模塊發送集群加入消息；所述可靠訂閱模塊接收到所述集群加入消息吋，獲取所述集群的配置信息，井根據所述集群的配置信息更新拓撲信息表中的集群拓撲信息。優選地，上述方案中，所述通知相應節點進行訂閱備份為
所述可靠訂閱模塊將所述節點的備份節點的信息通知所述節點的可靠訂閱子模塊，將所述節點的信息通知所述節點的備份節點的可靠訂閱子模塊；所述可靠訂閱子模塊將所述節點的備份節點信息和將所述節點作為備份節點的其他節點的信息保存在本地的可靠鄰居表中；所述可靠訂閱子模塊為所接收到的訂閱消息建立副本，並將訂閱消息副本發送給所述節點的備份節點的可靠訂閱子模塊作為訂閱備份。優選地,上述方案中，該方法還包括所述可靠訂閱模塊接收到所述節點失效消息吋，從拓撲信息表中獲取失效節點的備份節點，通知優先級最高的備份節點的可靠訂閱子模塊對所述失效節點進行訂閱恢復，並更新拓撲信息表。優選地,上述方案中，該方法還包括 所述可靠訂閱子模塊接收到備份節點的可靠訂閱子模塊發送的備份消息時，將所述備份節點的信息添加到所述可靠鄰居表中的備份節點信息中；所述可靠訂閱子模塊接收到新訂閱消息吋，為所述新訂閱消息建立副本，從所述可靠鄰居表中獲取所述節點的備份節點，並將新訂閱消息副本發送給所述節點的備份節點的可靠訂閱子模塊作為訂閱備份。優選地，上述方案中，所述預設的備份/恢復模式為本地備份/恢復模式時，該方法還包括所述可靠訂閱子模塊為所接收到的訂閱消息建立副本作為所述節點的訂閱備份，並在本地保存所述節點的訂閱備份。優選地,上述方案中，該方法還包括 所述節點失效時，可靠訂閱子模塊讀取所述節點本地保存的訂閱備份進行訂閱恢復；所述可靠訂閱子模塊接收到新訂閱消息時，為所接收到的新訂閱消息建立副本，並作為所述節點當前的訂閱備份，同時刪除之前的訂閱備份。優選地,上述方案中，該方法還包括在終端與所述節點之間進行消息傳輸過程中，消息發送端在待發送的消息中添加消息序列，並在希望接收到確認的消息中插入應答需求AckRequested報頭；消息接收端在接收到攜帶有AckRequested報頭的消息後，向消息發送端發送確認消息。本發明提供的發布訂閱系統中可靠性保障方法及系統，通過可靠訂閱模塊管理和維護拓撲的可靠性，通過節點管理和維護本地的可靠性；當有新節點加入發布訂閱系統吋，根據節點本地存儲的預設的備份/恢復模式為全局備份/恢復模式，節點本地的可靠訂閱子模塊向可靠訂閱模塊發送節點加入消息；可靠訂閱模塊接收到節點加入消息，獲取所述節點的配置信息，根據所述節點的配置信息選擇ー個以上節點作為所述節點的備份節點，通知相應節點進行訂閱備份；當收到節點失效消息時，通過讀取可靠訂閱模塊中存儲的拓撲信息表獲得失效節點的備份節點，選擇優先級最高的備份節點的訂閱備份進行訂閱恢復，如此，可保證發布訂閱系統中的節點不會因為故障而丟失，確保訂閱的可靠性，提升了用戶的體驗；且通過優先級的選擇使拓撲中的各個節點的負載均衡。
另外，在終端與節點間的消息傳輸中，通過在待發送的消息中添加消息序列，並在希望收到確認的消息中插入AckRequested報頭；在接收到攜帶有AckRequested報頭的消息後，向消息發送端發送確認消息；如此，實現了在消息傳輸過程中的有序交付、接收保障，確保消息發送端發送的消息能成功抵達消息接收端，保障了消息傳輸的可靠性。


圖I為本發明發布訂閱系統中可靠性保障系統的組成架構示意圖；圖2為本發明中可靠訂閱模塊收到不同類型的消息後的處理方法流程示意圖；圖3為本發明中可靠訂閱子模塊在節點加入時的處理方法流程示意圖；
圖4為本發明中終端與節點間消息傳輸的方法流程示意圖。
具體實施例方式本發明的基本思想是將處在同一個區域網的代理組成ー個集群，在集群內部選擇ー個代理作為集群代表，集群之間通過集群代表進行通信；每個集群內部包含ー個以上的節點，節點可以是集群代表，也可以是集群代理；系統中有一個服務於整個發布訂閱環境的可靠訂閱模塊，負責管理和維護整個拓撲訂閱的可靠性；每個節點中有一個服務於節點本地的發布訂閱環境的可靠訂閱子模塊，負責管理和維護節點本地訂閱的可靠性。在節點的備份/恢復模式為全局備份/恢復模式吋，可靠訂閱模塊會根據所述節點的配置信息選擇ー個以上節點作為所述節點的備份節點，並通知相應節點進行訂閱備份；在節點失效時，可靠訂閱模塊讀取拓撲信息表獲得失效節點的備份節點，並通知所述失效節點的備份節點進行訂閱恢復；其中，可靠訂閱模塊中存儲有拓撲信息表，所述拓撲信息表中記錄了整個拓撲中的備份信息。一旦某ー節點失效，可通過讀取拓撲信息表獲知失效節點的備份節點，進而通知所述失效節點的備份節點進行訂閱恢復；其中，可靠訂閱子模塊中存儲有可靠鄰居表，可靠鄰居表中記錄了節點的備份情況，管理並維護節點本地訂閱的可靠性。下面結合附圖及具體實施例對本發明再作進ー步詳細的說明。圖I為本發明發布訂閱系統中可靠性保障系統的組成架構示意圖，如圖I所示，該可靠性保障系統包括可靠訂閱模塊11和節點中的可靠訂閱子模塊12 ;其中，所述可靠訂閱子模塊12，用於節點加入發布訂閱系統時，並在預設的備份/恢復模式為全局備份/恢復模式吋，向所述可靠訂閱模塊11發送節點加入消息；以及，對接收到的所述可靠訂閱模塊發送的通知消息進行訂閱備份；所述可靠訂閱模塊11，用於在接收到節點加入消息時，獲取所述節點的配置信息，根據所述節點的配置信息選擇ー個以上節點作為所述節點的備份節點，通知相應的節點進行訂閱備份，並更新拓撲信息表中的節點拓撲信息；優選地，所述節點為集群代表或集群代理；所述節點為集群代表時，所述可靠訂閱子模塊12，還用於向所述可靠訂閱模塊11發送集群加入消息；相應的，所述可靠訂閱模塊11，還用於接收到集群加入消息時，獲取所述集群的配置信息，井根據所述集群的配置信息更新拓撲信息表中的集群拓撲信息。優選地，所述可靠訂閱模塊11，還用於將所述節點的備份節點的信息通知所述節點的可靠訂閱子模塊12，將所述節點的信息通知所述節點的備份節點的可靠訂閱子模塊12 ；相應的，所述可靠訂閱子模塊12，還用於將自身的備份節點信息和將所述節點作為備份節點的其他節點的信息保存在本地的可靠鄰居表中；為所接收到的訂閱消息建立副本，並將訂閱消息副本發送給所述節點的備份節點作為訂閱備份。優選地，所述可靠訂閱模塊11，還用於在接收到所述節點失效消息吋，從拓撲信息表中獲取失效節點的備份節點，向優先級最高的備份節點的可靠訂閱子模塊12發送對所述失效節點進行訂閱恢復的通知消息，並更新拓撲信息表；相應的，所述優先級最高的備份節點的可靠訂閱子模塊12，還用於對所述失效節點進行訂閱恢復。 相應的，所述系統還包括管理者模塊，用於檢測失效節點，井向可靠訂閱模塊11發送節點失效消息。這裡，備份節點的優先級由拓撲信息和節點負載能力決定，同一集群內的備份節點的優先級高於不同集群間的備份節點的優先級，負載能力強的備份節點的優先級高於負載能力弱的備份節點的優先級；例如Groupl中的備份節點的優先級高於Group2中的備份節點的優先級。優選地，所述可靠訂閱子模塊12，還用於接收到備份節點的可靠訂閱子模塊12發送的備份消息吋，將所述備份節點的信息添加到所述可靠鄰居表中的備份節點信息中；在接收到新訂閱消息吋，為所述新訂閱消息建立副本，從所述可靠鄰居表中獲取所述節點的備份節點，並將新訂閱消息副本發送給所述節點的備份節點作為訂閱備份。 優選地，所述可靠訂閱子模塊12，還用於在預設的備份/恢復模式為本地備份/恢復模式吋，為所接收到的訂閱消息建立副本作為所述節點訂閱備份，並在本地保存所述節點的訂閱備份；還用於當所述節點失效時，讀取所述本地保存的訂閱備份進行訂閱恢復。優選地，所述可靠訂閱子模塊12，還用於在接收到新訂閱消息時，為所接收到的新訂閱消息建立副本，並作為所述節點當前的訂閱備份，同時刪除之前的訂閱備份。優選地，該可靠性保障系統還包括可靠Web消息模塊，用於在待發送的消息中添加消息序列，並在希望接收到確認的消息中插入AckRequested報頭；用於在接收到攜帶有AckRequested報頭的消息後,返回確認消息。為實現上述系統，本發明還提供了了ー種發布訂閱系統中可靠性保障方法，該方法包括在節點加入發布訂閱系統吋，並在預設的備份/恢復模式為全局備份/恢復模式時，節點本地的可靠訂閱子模塊向可靠訂閱模塊發送節點加入消息；可靠訂閱模塊接收到節點加入消息時，獲取所述節點的配置信息，根據所述節點的配置信息選擇ー個以上節點作為所述節點的備份節點，通知相應節點進行訂閱備份，並更新拓撲信息表中的節點拓撲信息。這裡，所述節點的配置信息在所述節點本地存儲，所述備份/恢復模式為預先設置；其中，所述節點的配置信息包括節點的IP位址、節點所屬的集群號、節點號、節點備份能力信息；所述節點備份能力信息具體為當前節點所能承受的備份信息量。優選地，所述節點為集群代表或集群代理；所述節點為集群代表時，在所述節點本地的可靠訂閱子模塊向可靠訂閱模塊發送節點加入消息以前，該方法還包括所述可靠訂閱子模塊向所述可靠訂閱模塊發送集群加入消息；所述可靠訂閱模塊接收到所述集群加入消息時，獲取所述集群的配置信息，井根據所述集群的配置信息更新拓撲信息表中的集群拓撲信息。這裡，當所述節點作為集群代表要加入拓撲吋，需先發送集群加入消息，再發送節點加入消息。
、
這裡，所述集群的配置信息包括集群號、節點號、節點的備份能力信息。表I為本發明可靠訂閱模塊中的拓撲信息表的不意表；如表I所不，假設系統中包括兩個集群，所述集群名稱分別為Groupl和Group2，Groupl中包含有節點A、節點B和節點C三個節點，Group2中包含有節點D和節點E兩個節點，以節點A為例，節點A將訂閱消息副本發送給節點B和節點D，則節點B和節點D為節點A的備份節點，同時節點C將訂閱消息副本發送給節點A,則節點A為節點C的被備份節點；其餘四個節點的備份情況和被備份情況的得出過程與節點A相同，得到如表I中所述的拓撲信息表在Groupl中，節點A的備份節點為節點B和節點D，被備份節點為節點C ;節點B的備份節點為節點C和節點E，被備份節點為節點A和節點D ;節點C的備份節點為節點A和節點D，被備份節點為節點B和節點E ;在Group2中，節點D的備份節點為節點E和節點B，被備份節點為節點A、節點C和節點E ;節點E的備份節點為節點D和節點C，被備份節點為節點B和節點D ；
拓撲信息表
節點Ciroup Γ 備份Ti點被備份節點
XIB.:.........DC
BII C, E ' A, D
廠1IA F\D U
IIJ~\、 JL/JD、 XZr
D2「 E、BA、C、E E2「 D、CB, D表I優選地，所述通知相應節點進行訂閱備份具體為所述可靠訂閱模塊將所述節點的備份節點的信息通知所述節點的可靠訂閱子模塊，將所述節點的信息通知所述節點的備份節點的可靠訂閱子模塊；所述可靠訂閱子模塊將所述節點的備份節點信息和將所述節點作為備份節點的其他節點的信息保存在本地的可靠鄰居表中；
所述可靠訂閱子模塊為所接收到的訂閱消息建立副本，並將訂閱消息副本發送給所述節點的備份節點的可靠訂閱子模塊作為訂閱備份。這裡，所述備份節點信息和所述節點作為備份節點的其他節點的信息包括節點的IP位址、節點所屬的集群名和節點名等信息。表2為本發明節點中的可靠鄰居表的示意表，如表2所示，可靠鄰居表中包含備份鄰居表和被備份鄰居表兩張表格，其中，表2(a)為備份鄰居表，表示當前節點將訂閱備份保存在備份節點中。備份鄰居表中包含當前節點的備份節點信息，包括備份節點的IP位址、集群名和節點名；例如當前節點的備份節點名稱為Brokerl，其所在集群名稱為Groupl，備份節點的IP位址為192. 168. I. 15。表2(b)為被備份鄰居表，表示其他節點將當前節點作為備份節點，將訂閱備份保存在當前節點中。被備份鄰居表中包含被備份節點的IP位址、集群名和節點名。
權利要求
1.一種發布訂閱系統中可靠性保障系統，其特徵在於，該可靠性保障系統包括可靠訂閱模塊和節點中的可靠訂閱子模塊；其中，所述可靠訂閱子模塊，用於在節點加入發布訂閱系統時，並在預設的備份/恢復模式為全局備份/恢復模式時，向所述可靠訂閱模塊發送節點加入消息；以及，對接收到的所述可靠訂閱模塊發送的通知消息進行訂閱備份；所述可靠訂閱模塊，用於在接收到所述節點加入消息時，獲取所述節點的配置信息，根據所述節點的配置信息選擇一個以上節點作為所述節點的備份節點，通知相應的節點進行訂閱備份，並更新拓撲信息表中的節點拓撲信息。
2.根據權利要求I所述的可靠性保障系統，其特徵在於，所述節點為集群代表或集群代理；所述節點為集群代表時，所述可靠訂閱子模塊，還用於向所述可靠訂閱模塊發送集群加入消息；相應的，所述可靠訂閱模塊，還用於接收到所述集群加入消息時，獲取所述集群的配置信息，並根據所述集群的配置信息更新拓撲信息表中的集群拓撲信息。
3.根據權利要求I或2所述的可靠性保障系統，其特徵在於，所述可靠訂閱模塊，還用於將所述節點的備份節點的信息通知所述節點的可靠訂閱子模塊，將所述節點的信息通知所述節點的備份節點的可靠訂閱子模塊；相應的，所述可靠訂閱子模塊，還用於將節點的備份節點信息和將所述節點作為備份節點的其他節點的信息保存在本地的可靠鄰居表中；為所接收到的訂閱消息建立副本，並將訂閱消息副本發送給所述節點的備份節點作為訂閱備份。
4.根據權利要求I或2所述的可靠性保障系統，其特徵在於，所述可靠訂閱模塊，還用於在接收到所述節點失效消息時，從拓撲信息表中獲取失效節點的備份節點，向優先級最高的備份節點的可靠訂閱子模塊發送對所述失效節點進行訂閱恢復的通知消息，並更新拓撲信息表；相應的，所述優先級最高的備份節點的可靠訂閱子模塊，還用於對所述失效節點進行訂閱恢復。
5.根據權利要求I或2所述的可靠性保障系統，其特徵在於，所述可靠訂閱子模塊還用於，接收到備份節點的可靠訂閱子模塊發送的備份消息時，將所述備份節點的信息添加到所述可靠鄰居表中的備份節點信息中；接收到新訂閱消息時，為所述新訂閱消息建立副本，從所述可靠鄰居表中獲取所述節點的備份節點，並將新訂閱消息副本發送給所述節點的備份節點作為訂閱備份。
6.根據權利要求I所述的可靠性保障系統，其特徵在於，所述可靠訂閱子模塊，還用於在預設的備份/恢復模式為本地備份/恢復模式時，為所接收到的訂閱消息建立副本作為所述節點的訂閱備份，並在本地保存所述節點的訂閱備份；還用於當所述節點失效時，讀取所述本地保存的訂閱備份進行訂閱恢復。
7.根據權利要求6所述的可靠性保障系統，其特徵在於，所述可靠訂閱子模塊，還用於接收到新訂閱消息時，為所接收到的新訂閱消息建立副本，並作為所述節點當前的訂閱備份，同時刪除之前的訂閱備份。
8.根據權利要求3、5或7所述的可靠性保障系統，其特徵在於，該系統還包括可靠 Web消息模塊，用於在待發送的消息中添加消息序列，並在希望接收到確認的消息中插入 AckRequested報頭；用於在接收到攜帶有AckRequested報頭的消息後,返回確認消息。
9.一種發布訂閱系統中可靠性保障方法，其特徵在於，該方法包括在節點加入發布訂閱系統時，並在預設的備份/恢復模式為全局備份/恢復模式時，節點本地的可靠訂閱子模塊向可靠訂閱模塊發送節點加入消息；可靠訂閱模塊接收到節點加入消息時，獲取所述節點的配置信息，根據所述節點的配置信息選擇一個以上節點作為所述節點的備份節點，通知相應節點進行訂閱備份，並更新拓撲信息表中的節點拓撲信息。
10.根據權利要求9所述的方法，其特徵在於，所述節點為集群代表或集群代理；所述節點為集群代表時，在所述節點本地的可靠訂閱子模塊向可靠訂閱模塊發送節點加入消息以前，該方法還包括所述可靠訂閱子模塊向所述可靠訂閱模塊發送集群加入消息；所述可靠訂閱模塊接收到所述集群加入消息時，獲取所述集群的配置信息，並根據所述集群的配置信息更新拓撲信息表中的集群拓撲信息。
11.根據權利要求9或10所述的方法，其特徵在於，所述通知相應節點進行訂閱備份為所述可靠訂閱模塊將所述節點的備份節點的信息通知所述節點的可靠訂閱子模塊，將所述節點的信息通知所述節點的備份節點的可靠訂閱子模塊；所述可靠訂閱子模塊將所述節點的備份節點信息和將所述節點作為備份節點的其他節點的信息保存在本地的可靠鄰居表中；所述可靠訂閱子模塊為所接收到的訂閱消息建立副本，並將訂閱消息副本發送給所述節點的備份節點的可靠訂閱子模塊作為訂閱備份。
12.根據權利要求9或10所述的方法，其特徵在於，該方法還包括所述可靠訂閱模塊接收到所述節點失效消息時，從拓撲信息表中獲取失效節點的備份節點，通知優先級最高的備份節點的可靠訂閱子模塊對所述失效節點進行訂閱恢復，並更新拓撲信息表。
13.根據權利要求9或10所述的方法，其特徵在於，該方法還包括所述可靠訂閱子模塊接收到備份節點的可靠訂閱子模塊發送的備份消息時，將所述備份節點的信息添加到所述可靠鄰居表中的備份節點信息中；所述可靠訂閱子模塊接收到新訂閱消息時，為所述新訂閱消息建立副本，從所述可靠鄰居表中獲取所述節點的備份節點，並將新訂閱消息副本發送給所述節點的備份節點的可靠訂閱子模塊作為訂閱備份。
14.根據權利要求9所述的方法，其特徵在於，所述預設的備份/恢復模式為本地備份 /恢復模式時，該方法還包括所述可靠訂閱子模塊為所接收到的訂閱消息建立副本作為所述節點的訂閱備份，並在本地保存所述節點的訂閱備份。
15.根據權利要求14所述的方法，其特徵在於，該方法還包括所述節點失效時，可靠訂閱子模塊讀取所述節點本地保存的訂閱備份進行訂閱恢復；所述可靠訂閱子模塊接收到新訂閱消息時，為所接收到的新訂閱消息建立副本，並作為所述節點當前的訂閱備份，同時刪除之前的訂閱備份。
16.根據權利要求11、13或15所述的方法，其特徵在於，該方法還包括在終端與所述可靠訂閱子模塊之間進行消息傳輸過程中，消息發送端在待發送的消息中添加消息序列，並在希望接收到確認的消息中插入應答需求AckRequested報頭；消息接收端在接收到攜帶有AckRequested報頭的消息後，向消息發送端發送確認消
全文摘要
本發明公開了一種發布訂閱系統中可靠性保障方法，該方法包括在節點加入發布訂閱系統時，並在預設的備份/恢復模式為全局備份/恢復模式時，節點本地的可靠訂閱子模塊向可靠訂閱模塊發送節點加入消息；可靠訂閱模塊接收到節點加入消息時，獲取所述節點的配置信息，根據所述節點的配置信息選擇一個以上節點作為所述節點的備份節點，通知相應節點進行訂閱備份，並更新拓撲信息表中的節點拓撲信息。本發明還公開了一種發布訂閱系統中可靠性保障系統，採用本發明的技術方案，保證拓撲中的節點不會因為故障而丟失，保障訂閱的可靠性，提升了用戶的體驗。
文檔編號H04L29/08GK102984174SQ20121056097
公開日2013年3月20日 申請日期2012年12月21日 優先權日2012年12月21日
發明者章洋, 陳俊亮, 郭文琪 申請人:北京郵電大學