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

有效

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

1.一種用于在發布/訂閱消息系統的消息訂閱應用程序中管理消息訂閱的方法，所述方法包括以下步驟：

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

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

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

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

2.如權利要求1所述的方法，還包括以下步驟：

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

3.如以上任意一項權利要求所述的方法，其中給定消息的接收的應答觸發所述SMI的保存。

4.如以上任意一項權利要求所述的方法，其中根據預定的協議，依次從每個中間人順序地請求所述消息。

5.如權利要求4所述的方法，其中所述協議是輪叫協議。

6.一種用于在發布/訂閱消息系統的消息中間人應用程序中管理消息訂閱的方法，所述方法包括以下步驟：

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

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

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

7.如權利要求6所述的方法，進一步包括以下步驟：

響應于對給定SMI的后續消息的請求，發送所述后續消息。

8.如權利要求7所述的方法，進一步包括以下步驟：

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

9.如權利要求6-8中任意一項所述的方法，其中在工作的單一單元中進行所述消息到所述消息訂戶的所述發送以及對于所述訂閱的所述SMI的所述記錄。

10.如權利要求6-9中任意一項所述的方法，其中所述SMI被存儲在持續性存儲器中。

11.一種用于在發布/訂閱消息系統的消息訂閱應用程序中管理消息訂閱的裝置，所述裝置可操作用于：

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

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

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

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

12.如權利要求11所述的裝置，進一步可操作用于：

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

13.如權利要求11或12所述的裝置，其中給定消息的接收的應答觸發所述SMI的保存。

14.如權利要求11-13中任意一項所述的裝置，其中根據預定的協議，依次從每個中間人順序地請求所述消息。

15.如權利要求14所述的裝置，其中所述協議是輪叫協議。