[發明專利]在發布/訂閱消息系統中管理消息訂閱

有效

• 申請號: 201280024141.6
• 申請日: 2012-05-02
• 公開（公告）號: CN103562890A
• 公開（公告）日: 2014-02-05
• 發明（設計）人: G.D.比爾達爾;A.D.班克斯;A.D.迪克;B.C.霍姆伍德
• 申請（專利權）人: 國際商業機器公司
• 主分類號: G06F13/00
• 分類號: G06F13/00;H04L12/58
• 代理公司: 北京市柳沈律師事務所 11105
• 代理人: 張貴東

技術領域

本發明涉及一種在發布/訂閱消息系統中管理消息訂閱的方法、裝置或計算機程序產品。

背景技術

在計算機化的發布/訂閱系統中，訂戶應用程序（訂戶）可以向單一消息中間人（broker）應用程序（消息中間人）預定以便接收發布的消息。如果該消息中間人出現故障，則訂戶不能接收消息。當訂戶重新連接到消息中間人時，可能已經錯過了一些消息。

一些發布/訂閱消息系統提供高可靠性高可用性（HRHI）消息中間人以便減少訂閱服務丟失或中斷的概率。換言之，安排這樣的HRHI服務以對于給定訂閱保持消息順序并且不丟失消息。這樣的訂閱服務可以通過同時預定提供多個訂閱流的多個中間人來提供。該訂閱可以從多個消息中間人直接接收或者通過向中間的消息中間人的單個訂閱來接收。

這樣的HRHI訂閱服務的一個問題是它們就在消息訂戶或中間人應用程序處所需的處理而言是相對昂貴的。例如，需要保持訂戶的狀態，即，已經接收了來自給定訂閱的哪些消息的記錄。該狀態使得在連接中斷后從相關消息中間人恢復訂閱成為可能。此外，在從多個消息中間人接收到單個訂閱的情況下，管理冗余或重復消息是相對復雜的處理。

發明內容

本發明的實施例提供了一種用于在發布/訂閱消息系統的消息訂閱應用程序中管理消息訂閱的方法，所述方法包括以下步驟：

預定由消息中間人的集合的每個并行地提供的訂閱，所述訂閱包括公共消息序列，每個公共消息與公共順序消息標識符（SMI）相關聯；

從所述消息中間人的所選擇之一檢索消息，并且對于在所述消息中間人的所述訂閱觸發相關聯SMI的保存；

響應于所述消息訂戶的重啟，恢復到所述消息中間人的集合以便對于在所述消息中間人的任一個的所述訂閱確定最新保存的SMI；以及

從所述消息中間人的所選擇之一，通過請求與所述最新SMI相關聯的消息的后續消息來繼續所述訂閱。

所述方法還包括以下步驟：

響應于來自所述所選擇的消息中間人的所述訂閱的所述繼續，指示所述集合中的剩余消息中間人的每個丟棄所述序列中在與所述確定的最新SMI相關聯的消息之前的、并包括該消息的任何排隊的消息。

給定消息的接收應答可以觸發SMI的保存。根據預定的協議，可以依次從每個中間人順序地請求所述消息。該協議可以是輪叫（round?robin）協議。

另一實施例提供了一種用于在發布/訂閱消息系統的消息中間人應用程序中管理消息訂閱的方法，所述方法包括以下步驟：

響應于來自消息訂戶的訂閱請求來預定訂閱，所述訂閱包括公共消息序列，每個公共消息與公共順序消息標識符（SMI）相關聯；

發送消息到所述消息訂戶，并且與在所述消息中間人的所述訂閱相關聯地記錄相關SMI；以及

響應于來自所述消息訂戶的請求發送所述SMI到所述消息訂戶。

所述方法可以進一步包括以下步驟：

響應于對給定SMI的后續消息的請求，發送后續消息。所述方法可以進一步包括以下步驟：

響應于所述后續消息的所述發送，丟棄所述序列中的任何排隊的先前消息以及所述后續消息。

可以在工作的單一單元中進行所述消息到所述消息訂戶的所述發送以及對于所述訂閱的所述SMI的所述記錄。SMI可以被存儲在持續性存儲器中。

另一實施例提供了一種用于在發布/訂閱消息系統的消息訂閱應用程序中管理消息訂閱的裝置，所述裝置可操作用于：

預定由消息中間人的集合的每個并行地提供的訂閱，所述訂閱包括公共消息序列，每個公共消息與公共順序消息標識符（SMI）相關聯；

從所述消息中間人的所選擇之一檢索消息，并且對于在所述消息中間人的所述訂閱觸發相關聯SMI的保存；

響應于所述消息訂戶的重啟，恢復到所述消息中間人的集合以便對于在所述消息中間人的任一個的所述訂閱確定最新保存的SMI；以及

從所述消息中間人的所選擇之一，通過請求與所述最新SMI相關聯的消息的后續消息來繼續所述訂閱。

另一實施例提供了一種用于在發布/訂閱消息系統的消息中間人應用程序中管理消息訂閱的裝置，所述裝置可操作用于：

響應于來自消息訂戶的訂閱請求來預定訂閱，所述訂閱包括公共消息序列，每個公共消息與公共順序消息標識符（SMI）相關聯；

發送消息到所述消息訂戶，并且與在所述消息中間人的所述訂閱相關聯地記錄相關SMI；以及

響應于來自所述消息訂戶的請求發送所述SMI到所述消息訂戶。