[發明專利]一種基于內容的發布訂閱系統中的事件快速匹配方法

有效

• 申請號: 201610046085.6
• 申請日: 2016-01-22
• 公開（公告）號: CN105740337B
• 公開（公告）日: 2019-03-12
• 發明（設計）人: 董永強;呂希來
• 申請（專利權）人: 東南大學
• 主分類號: G06F16/958
• 分類號: G06F16/958;G06F16/9535
• 代理公司: 南京蘇高專利商標事務所(普通合伙) 32204
• 代理人: 柏尚春

本發明公開了一種基于內容的發布訂閱系統中的事件快速匹配方法，包括以下步驟：1、建立事件多級索引樹和訂閱多級索引樹；2、用戶將訂閱請求或發布事件發送給事件匹配節點；3、事件匹配節點將接收到的發布事件插入到事件多級索引樹中；4、根據事件多級索引樹對訂閱表達式進行簡化處理，將得到的簡化后的謂詞插入訂閱多級索引樹中；5、針對接收到的訂閱請求或者發布事件，找到與之匹配的事件或者訂閱候選集合，然后進行逐一匹配；6、完成匹配之后，事件匹配節點將事件按照一定的路由協議發送給對應的訂閱者。本發明在保證匹配準確性的同時，支持對復雜邏輯表達式的處理，而且既可以對新出現的事件消息快速找出合適的接收者，也可以對新的訂閱請求快速找出對應的發布事件。

技術領域

本發明涉及計算機網絡中的發布訂閱技術領域，特別涉及一種基于內容的發布訂閱系統中的事件快速匹配方法。

背景技術

發布訂閱是一種消息傳播模式，消息的發布者將消息按照不同類別進行分類或描述，而不需要對消息的接收者有所了解；消息的接收者對屬于某個類別或符合特定條件的消息提出訂閱請求，只接收自身所感興趣的信息，而不需要對發布者有所了解。發布訂閱系統為信息交換和分布式工作流，提供了時間和空間上的解耦以及規模可擴展的通信基礎架構。通常情況下，發布訂閱系統包含三個模塊——發布者、訂閱者以及中間件(事件匹配節點)，中間件接收發布者的發布事件和訂閱者的訂閱請求，進行匹配之后將事件發送給所需的訂閱者。

發布訂閱系統具有異步性、松耦合和多點通信等特點，通過事件模型和訂閱模型通常可將發布訂閱模型分為基于主題和基于內容兩種模式。其中基于內容的發布訂閱系統表達能力較強，能夠更細粒度地表達用戶所感興趣的事件，只有當消息的屬性或內容滿足訂閱者定義的條件時，消息才會被投遞到相應的訂閱者。

在基于內容的發布訂閱系統中，事件是發布者發布的信息，每個事件有一個唯一ID，同時包含一個或者多個(屬性，值)二元組，用于描述該事件。不同的二元組之間的關系是邏輯與。而訂閱者可根據自身感興趣的內容提出訂閱請求，每條訂閱請求有一個唯一ID，同時包含一個或者多個謂詞，每個謂詞是一個三元組(屬性，操作符，值)，用于表達用戶所希望的屬性和值之間所滿足的約束關系。

在現有的事件匹配方案中，訂閱條件大多只能支持單純的邏輯與，極少數支持簡單的邏輯或，對于大規模的復雜邏輯表達式則無能為力。此外，當前多數發布訂閱系統只進行事件對大量訂閱的匹配，只將新的事件發布給需要的用戶。然而在某些情況下，尤其是在新型的內容中心網絡中，用戶會希望提出新的訂閱請求后，能夠立即收到滿足該訂閱條件的歷史事件，而不僅僅是新發生的事件，因此還需要進行訂閱請求對大量事件的匹配。

發明內容

發明目的：針對現有技術中存在的問題，本發明提供一種事件快速匹配方法，能夠實現對復雜邏輯表達式的進行處理，同時具有單訂閱多事件和單事件多訂閱兩種模式，在保證匹配準確性的同時，既可以對新出現的事件消息快速找出合適的接收者，也可以對新的訂閱請求快速找出對應的發布事件。

技術方案：為解決上述技術問題，本發明提供一種基于內容的發布訂閱系統中的事件快速匹配方法，包括以下步驟：

步驟一：事件匹配節點根據自身已有信息預先建立并維護事件多級索引樹和訂閱多級索引樹；通過事件多級索引樹和訂閱多級索引樹，既可以對新的事件消息快速找到合適的接收者，也可以對新的訂閱請求快速找到匹配的歷史事件。

步驟二：用戶在本地對數據進行編碼和排序，并將訂閱請求或發布事件發送給事件匹配節點；本發明中的事件匹配節點可以不直接存儲消息正文，而事件描述信息和訂閱請求所占空間都很小，因此只要有良好的網絡數據傳輸能力和一定的計算能力，一般的PC甚至手機終端也可以成為事件匹配節點。

步驟三：事件匹配節點將接收到的發布事件插入到事件多級索引樹中；

步驟四：根據事件多級索引樹對訂閱表達式進行簡化處理，將得到的簡化后的謂詞插入訂閱多級索引樹中；