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

有效

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

技術領域

本發明涉及網絡通信技術，尤其涉及一種發布訂閱系統及其通知消息處理方法。

背景技術

基于網絡服務(Web?Service)技術的發布訂閱(Pub/Sub，Publish/Subscribe)系統應用日益廣泛，訂閱者(Subscriber)向通知代理發送訂閱請求，訂閱需要關注的信息，并采用拉取(Pull)方式，獲取發布者(Publisher)發送到發布訂閱系統的通知消息中滿足訂閱請求的通知消息。

當前，基于結構化信息標準促進組織(OASIS，Organization?for?theAdvancement?of?Structured?Information?Standards)制定的網絡服務通知(Web-Service?Notification)標準的發布訂閱系統中，不會將通知消息主動發送給訂閱者，但是，在越來越多的應用發布訂閱系統的場景中，如銀行匯率業務、股票業務和網絡游戲運營業務，迫切需要將通知消息主動發送至訂閱者，以滿足通知消息及時到達的需求；

同時，在需要發布訂閱系統處理大量通知消息的應用場景中，如何平衡發布訂閱系統負荷，提高數據處理性能，也是亟待解決的問題。

發明內容

有鑒于此，本發明的主要目的在于提供一種發布訂閱系統及其通知消息處理方法，以滿足需要主動發送通知消息給訂閱者的應用場景需求；同時平衡發布訂閱系統負荷，以適用需要處理大量通知消息的應用場景。

為達到上述目的，本發明的技術方案是這樣實現的：

本發明提供了一種發布訂閱系統，所述發布訂閱系統包括訂閱者、通知代理、發布者、內部發布者、與所述內部發布者對應的訂閱實體、由所述訂閱者建立的與所述訂閱者對應的消息接收實體、由所述通知代理建立的推送端點、以及由所述訂閱實體建立的推理實體；其中，

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

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

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

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

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

優選的，

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

優選的，

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

優選的，

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

優選的，

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

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

相應的，本發明還提供了一種通知消息處理方法，應用于發布訂閱系統中，所述通知消息處理方法包括：

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

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

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

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

優選的，所述通知消息處理方法還包括：