[發明專利]一種可級聯的復雜事件處理引擎及列車檢修自動記錄方法

無效

• 申請號: 201110009619.5
• 申請日: 2011-01-17
• 公開（公告）號: CN102156799A
• 公開（公告）日: 2011-08-17
• 發明（設計）人: 侯迪;齊勇;鮑軍鵬;何暉;常曉佳;劉硯清;陶斌;段爭爭;侯衛鳳;陳娟;張丹
• 申請（專利權）人: 西安交通大學
• 主分類號: G06F19/00
• 分類號: G06F19/00;G06K17/00
• 代理公司: 西安通大專利代理有限責任公司 61200
• 代理人: 汪人和

1.一種可級聯的復雜事件處理引擎，其特征在于，所述復雜事件處理引擎能夠接收底層原始事件，對用戶所提交的查詢規則生成相應的查詢計劃，按照查詢計劃對原始事件進行檢測，將生成的復雜事件報告給上層應用；該引擎包括事件預處理模塊、事件壓縮模塊、事件調度模塊和事件檢測模塊；

所述事件預處理模塊將引擎所接收到的各種不同類型的原始事件流轉換為引擎所能處理的統一類型；

所述事件壓縮模塊采用無損壓縮算法，通過建立一個字符串表，用短的代碼來表示長的字符串來實現對事件流的壓縮；

所述事件調度模塊采用動態事件優先級策略和基于優先級的搶占式事件調度策略，按照事件優先級模型為原始事件分配優先級，并動態調整事件的優先級；

所述事件檢測模塊集成了奧普拉、葉子和Esper三種不同的檢測模型；所述奧普拉是基于有限狀態自動機的方法來檢測復雜事件；所述葉子是基于樹的算法來檢測復雜事件；集成的這三種不同的檢測模型，能夠單獨使用或者按照任意的方式進行級聯。

2.根據權利要求1所述的可級聯的復雜事件處理引擎，其特征在于，所述事件預處理模塊還采用管道設計模式依次對事件進行采集、平滑、過濾、合并、仲裁和格式化。

3.一種基于權利要求1可級聯的復雜事件處理引擎的列車檢修自動記錄方法，其特征在于，包括以下步驟：

1)啟動可級聯的復雜事件處理引擎；

2)由用戶選擇二級級聯的方式，對事件檢測模塊所集成的三個檢測模型進行配置，包括配置接收事件流的端口，發送復雜事件的地址以及檢測規則；

所述的二級級聯的方式為：由Esper檢測列車入庫和正在檢修兩個復雜事件，由奧普拉檢修列車出庫事件，葉子作為級聯引擎中的第二級，接收Esper和奧普拉檢測到的復雜事件作為輸入事件流，來檢測最終的復雜事件-列車檢修完成，然后將事件報告給上層；

3)配置完成后，當代表列車當前狀態的事件流到達可級聯的復雜事件處理引擎時，可級聯的復雜事件處理引擎按照步驟2)中的配置，處理所接收的事件流，以檢測列車入庫、出庫、檢修中和檢修完成的復雜事件，如果引擎成功檢測到所要求的復雜事件，則繼續步驟4)，如果沒有檢測到，則繼續對輸入事件流進行檢測；

4)將檢測到的復雜事件即列車檢修完成事件輸出，從而完成列車檢修的記錄。

4.根據權利要求3所述的列車檢修自動記錄方法，其特征在于，所述代表列車當前狀態的事件流的采集是通過無線射頻技術實現。

5.根據權利要求4所述的列車檢修自動記錄方法，其特征在于，所述無線射頻技術是在列車上設有RFID標簽，在檢修站設有RFID標簽讀寫裝置，所述RFID標簽讀寫裝置將采集到的數據傳送給復雜事件處理引擎。