[發(fā)明專利]一種基于事件處理的煤礦報(bào)警系統(tǒng)及方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201110417512.4
• 申請(qǐng)日: 2011-12-14
• 公開（公告）號(hào): CN102562162A
• 公開（公告）日: 2012-07-11
• 發(fā)明（設(shè)計(jì)）人: 程渤;章洋;吳步丹;陳俊亮;周鵬
• 申請(qǐng)（專利權(quán)）人: 北京郵電大學(xué)
• 主分類號(hào): E21F17/18
• 分類號(hào): E21F17/18;H04L29/08
• 代理公司: 北京匯澤知識(shí)產(chǎn)權(quán)代理有限公司 11228
• 代理人: 劉淑敏

1.一種基于事件處理的煤礦報(bào)警系統(tǒng)，其特征在于，該報(bào)警系統(tǒng)包括：事件處理模塊、發(fā)布和訂閱模塊、報(bào)警流程處理模塊、控制服務(wù)器模塊、客戶端顯示模塊；其中，

所述事件處理模塊，用于接收并處理煤礦傳感器監(jiān)測(cè)到的原始數(shù)據(jù)流，通過(guò)事件處理引擎獲取系統(tǒng)關(guān)心的事件并以特定的主題發(fā)布到所述發(fā)布和訂閱模塊；

所述發(fā)布和訂閱模塊，用以實(shí)現(xiàn)發(fā)布、訂閱服務(wù)引擎，以及處理消息的交互；

所述報(bào)警處理流程模塊，其基于業(yè)務(wù)流程執(zhí)行語(yǔ)言BPEL，用以描述報(bào)警處理流程，調(diào)用該報(bào)警處理流程中的相應(yīng)web服務(wù)；

所述控制服務(wù)器模塊，用于訂閱系統(tǒng)關(guān)注的主題事件，在接收到報(bào)警事件時(shí)觸發(fā)報(bào)警流程，并作為流程與人交互的代理與流程進(jìn)行交互，同時(shí)對(duì)報(bào)警狀態(tài)進(jìn)行存儲(chǔ)，并主動(dòng)推送到客戶端顯示模塊進(jìn)行顯示；

所述客戶端顯示模塊，用于與控制服務(wù)器模塊通信，提供用戶交互界面及內(nèi)容顯示。

2.根據(jù)權(quán)利要求1所述的基于事件處理的煤礦報(bào)警系統(tǒng)，其特征在于，所述事件處理模塊進(jìn)一步用于通過(guò)事件建模建立事件模型，定義事件之間的關(guān)系；通過(guò)類數(shù)據(jù)庫(kù)語(yǔ)言的事件處理語(yǔ)言，描述事件之間的關(guān)系和事件處理規(guī)則；通過(guò)事件處理引擎，解析事件模型和事件處理語(yǔ)言，對(duì)事件進(jìn)行過(guò)濾，以篩選出符合規(guī)則的事件并發(fā)布到所述發(fā)布和訂閱模塊。

3.根據(jù)權(quán)利要求1所述的基于事件處理的煤礦報(bào)警系統(tǒng)，其特征在于，所述發(fā)布和訂閱模塊，基于web服務(wù)-通知規(guī)范，實(shí)現(xiàn)JAVA業(yè)務(wù)集成JBI規(guī)范的接口，實(shí)現(xiàn)發(fā)布、訂閱服務(wù)引擎，以熱部署到系統(tǒng)的企業(yè)服務(wù)總線ESB上，主要負(fù)責(zé)處理消息的交互；并提供定義消息主題、訂閱消息和發(fā)布消息的接口，其他應(yīng)用能夠通過(guò)訂閱消息接口訂閱自身關(guān)注的主題，或通過(guò)發(fā)布消息接口將消息發(fā)布出去。

4.根據(jù)權(quán)利要求1所述的基于事件處理的煤礦報(bào)警系統(tǒng)，其特征在于，所述報(bào)警處理流程模塊，進(jìn)一步用于當(dāng)報(bào)警事件發(fā)生時(shí)，控制服務(wù)器模塊通過(guò)發(fā)布和訂閱模塊監(jiān)測(cè)報(bào)警事件，然后將調(diào)用其定義的報(bào)警處理流程，通過(guò)控制服務(wù)器的代理作用與人進(jìn)行交互，觸發(fā)流程向下執(zhí)行。

5.根據(jù)權(quán)利要求1所述的基于事件處理的煤礦報(bào)警系統(tǒng)，其特征在于，所述控制服務(wù)器模塊，進(jìn)一步用于訂閱系統(tǒng)關(guān)注的主題事件，在獲得報(bào)警狀態(tài)改變時(shí)觸發(fā)報(bào)警流程，并作為流程與人交互的代理與流程進(jìn)行交互，同時(shí)對(duì)報(bào)警狀態(tài)進(jìn)行存儲(chǔ)，并主動(dòng)推送到客戶端顯示模塊進(jìn)行顯示。

6.根據(jù)權(quán)利要求1所述的基于事件處理的煤礦報(bào)警系統(tǒng)，其特征在于，所述控制服務(wù)器模塊訂閱系統(tǒng)關(guān)注的主題事件，包括系統(tǒng)預(yù)警、系統(tǒng)報(bào)警和數(shù)據(jù)比對(duì)。

7.根據(jù)權(quán)利要求1所述的基于事件處理的煤礦報(bào)警系統(tǒng)，其特征在于，所述客戶端顯示模塊，用以與所述控制服務(wù)器模塊進(jìn)行交互，當(dāng)接收到控制服務(wù)器模塊推送過(guò)來(lái)的狀態(tài)改變消息，查詢數(shù)據(jù)庫(kù)進(jìn)行顯示狀態(tài)的更新，并提供用戶操作界面以等待用戶操作與BPEL處理流程進(jìn)行交互，并且提供報(bào)警流程配置，數(shù)據(jù)比對(duì)，以及歷史數(shù)據(jù)查詢的功能。

8.一種基于事件處理的煤礦報(bào)警方法，其特征在于，該方法包括：

A、獲得該報(bào)警流程需要處理的步驟數(shù)，將變量totalStep設(shè)置為需要處理的總步驟數(shù)，并且將變量當(dāng)前所在的處理步驟curStep初始化為1；

B、判斷所述curStep是否小于等于總步驟數(shù)totalStep，如果是，則執(zhí)行步驟C，否則，返回錯(cuò)誤消息并結(jié)束本輪報(bào)警過(guò)程；

C、如果所述curStep等于1，即當(dāng)流處理程處于第一步時(shí)，執(zhí)行步驟H；否則，執(zhí)行步驟D；

D、采用BPEL規(guī)范中的活動(dòng)pick的方式等待上一步驟的處理結(jié)果，流程處于等待狀態(tài)，同時(shí)啟動(dòng)計(jì)時(shí)器，當(dāng)pick超時(shí)，則執(zhí)行步驟F；否則，執(zhí)行步驟E；

E、當(dāng)收到所述pick返回的結(jié)果時(shí)，執(zhí)行步驟G；

F、返回超時(shí)信息，然后結(jié)束本輪報(bào)警過(guò)程；

G、如果pick返回確認(rèn)消息并且該消息中的結(jié)束標(biāo)志endFlag等于1，則執(zhí)行步驟J；否則進(jìn)入步驟H；

H、獲取預(yù)設(shè)的聯(lián)絡(luò)人的通訊聯(lián)系方式，并向該聯(lián)絡(luò)人的通訊工具發(fā)送短信的web?服務(wù)；

I、將該變量curStep加1，返回步驟B；

J、返回該報(bào)警過(guò)程正常結(jié)束消息。