[發明專利]一種發布訂閱系統及其通知消息處理方法

有效

• 申請號: 201210562319.4
• 申請日: 2012-12-21
• 公開（公告）號: CN103037000A
• 公開（公告）日: 2013-04-10
• 發明（設計）人: 章洋;陳俊亮;柴兆航
• 申請（專利權）人: 北京郵電大學
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 北京派特恩知識產權代理事務所(普通合伙) 11270
• 代理人: 張振偉;王黎延

1.一種發布訂閱系統，其特征在于，所述發布訂閱系統包括訂閱者、通知代理、發布者、內部發布者、與所述內部發布者對應的訂閱實體、由所述訂閱者建立的與所述訂閱者對應的消息接收實體、由所述通知代理建立的推送端點、以及由所述訂閱實體建立的推理實體；其中，

所述通知代理，用于接收所述發布者發送的通知消息并轉發至所述內部發布者；

所述內部發布者，用于確定所述訂閱實體的當前負荷未超過設定閾值時，將所述通知消息通過所述訂閱實體轉發至所述推理實體；

所述推理實體，用于確定通知消息滿足所述推理實體的初始化過濾條件時，發送通知消息至與所述訂閱實體關聯的推送端點；

所述推送端點，用于轉發通知消息至與所述推送端點關聯的消息接收實體；

所述消息接收實體，用于將接收的通知消息發送至所述訂閱者。

2.根據權利要求1所述的發布訂閱系統，其特征在于，

所述通知代理，還用于根據訂閱請求更新訂閱關系描述，所述訂閱關系描述包括訂閱請求與從屬的訂閱請求的語義優先級排序，以及訂閱請求與從屬的訂閱請求攜帶的關鍵字。

3.根據權利要求1所述的發布訂閱系統，其特征在于，

所述通知代理，還用于接收所述發布者發送的通知消息后，根據訂閱關系描述，確定攜帶關鍵字與所述通知消息攜帶的關鍵字匹配的訂閱請求和/或從屬訂閱請求，并按語義優先級對匹配的訂閱請求和/或從屬訂閱請求進行排序，按照所述排序將所述通知消息發送至根據匹配的訂閱請求和/或從屬訂閱請求建立的訂閱實體對應的內部發布者。

4.根據權利要求1、2或3所述的發布訂閱系統，其特征在于，

所述通知代理，還用于接收到所述訂閱者建立推送端點的請求消息時，建立所述推送端點；將所述請求消息攜帶的消息接收實體地址在推送端點進行注冊，關聯所述消息接收實體和所述推送端點，并在接收所述推送端點返回的推送端點地址時，轉發至所述訂閱者。

5.根據權利要求4所述的發布訂閱系統，其特征在于，

所述通知代理，還用于建立所述推送端點后，接收到所述訂閱者發送的訂閱請求時建立訂閱實體，以所述訂閱請求攜帶的訂閱名、關鍵字和過濾條件初始化所述訂閱實體，并將訂閱請求攜帶的推送端點地址在所述訂閱實體進行注冊，關聯所述推送端點和所述訂閱實體；

所述訂閱實體，還用于建立推理實體，以所述訂閱請求攜帶的過濾條件初始化所述推理實體。

6.一種通知消息處理方法，應用于發布訂閱系統中，其特征在于，所述通知消息處理方法包括：

所述通知代理接收到所述發布者發送的通知消息后，轉發至所述內部發布者；

所述內部發布者確定所述訂閱實體的當前負荷未超出設定閾值時，將所述通知消息通過所述訂閱實體轉發至所述推理實體；

所述推理實體確定所述通知消息滿足所述推理實體的初始化過濾條件時，將所述通知消息發送至與所述訂閱實體關聯的推送端點；

所述推送端點將所述通知消息轉發至與所述推送端點關聯的消息接收實體，并由所述消息接收實體將所述通知消息發送至所述訂閱者。

7.根據權利要求6所述的方法，其特征在于，所述通知代理接收到所述訂閱者發送的訂閱請求時，所述方法還包括：

所述通知代理根據訂閱請求更新訂閱關系描述，所述訂閱關系描述包括訂閱請求與所述訂閱請求的從屬訂閱請求的語義優先級排序，以及所述訂閱請求與所述從屬訂閱請求攜帶的關鍵字。

8.根據權利要求6所述的方法，其特征在于，所述通知代理接收到所述發布者發送的通知消息后，轉發至所述內部發布者，包括：

所述通知代理接收到所述發布者發送的通知消息后，根據訂閱關系描述，確定與所述通知消息攜帶的關鍵字匹配的訂閱請求和/或從屬訂閱請求，并按語義優先級對匹配的訂閱請求和/或從屬訂閱請求進行排序，按照所述排序將所述通知消息發送至根據匹配的訂閱請求和/或從屬訂閱請求建立的訂閱實體對應的內部發布者。

9.根據權利要求6、7或8所述的方法，其特征在于，所述方法還包括：

所述通知代理接收到所述訂閱者建立推送端點的請求消息時，建立所述推送端點；

所述通知代理將所述請求消息攜帶的消息接收實體地址在所述推送端點進行注冊，關聯所述消息接收實體和所述推送端點，并在接收到所述推送端點返回的推送端點地址時，轉發至所述訂閱者。

10.根據權利要求9所述的方法，其特征在于，所述通知代理建立所述推送端點后，所述方法還包括：

所述通知代理在接收到所述訂閱者發送的訂閱請求時，建立訂閱實體，以所述訂閱請求攜帶的訂閱名、關鍵字和過濾條件初始化所述訂閱實體，并將所述訂閱請求攜帶的推送端點地址在所述訂閱實體進行注冊，關聯所述推送端點和所述訂閱實體；

所述訂閱實體建立推理實體，以所述訂閱請求攜帶的過濾條件初始化所述推理實體。