對(duì)海量事件分布式關(guān)聯(lián)匹配的方法及系統(tǒng)

基本信息

申請(qǐng)?zhí)?/td> CN201710672543.1 申請(qǐng)日 -
公開（公告）號(hào) CN107506408A 公開（公告）日 2017-12-22
申請(qǐng)公布號(hào) CN107506408A 申請(qǐng)公布日 2017-12-22
分類號(hào) G06F17/30(2006.01)I;G06F9/54(2006.01)I 分類 計(jì)算；推算；計(jì)數(shù);
發(fā)明人 郜小亮 申請(qǐng)（專利權(quán)）人 北京盛華安信息技術(shù)有限公司
代理機(jī)構(gòu) 北京思創(chuàng)大成知識(shí)產(chǎn)權(quán)代理有限公司 代理人 北京盛華安信息技術(shù)有限公司
地址 100085 北京市海淀區(qū)上地東路35號(hào)院1號(hào)樓4層3-508
法律狀態(tài) -

摘要

摘要 本發(fā)明公開了一種對(duì)海量事件分布式關(guān)聯(lián)匹配的方法及系統(tǒng)，包括：管理中心存儲(chǔ)并將規(guī)則配置信息同步發(fā)送到分布式數(shù)據(jù)處理節(jié)點(diǎn)；分布式數(shù)據(jù)處理節(jié)點(diǎn)接收規(guī)則配置信息和事件流；分布式數(shù)據(jù)處理節(jié)點(diǎn)的規(guī)則匹配引擎根據(jù)規(guī)則配置信息判斷使用的規(guī)則類型；分布式數(shù)據(jù)處理節(jié)點(diǎn)的關(guān)聯(lián)匹配引擎根據(jù)規(guī)則類型對(duì)事件流進(jìn)行關(guān)聯(lián)匹配生成關(guān)聯(lián)事件。本發(fā)明提出的對(duì)海量事件分布式關(guān)聯(lián)匹配的方法，對(duì)事件流分布式處理，大大提高規(guī)則匹配性能，同時(shí)將部分規(guī)則匹配成功后的后續(xù)處理工作也交給分布式節(jié)點(diǎn)處理，充分利用分布式節(jié)點(diǎn)的計(jì)算資源，實(shí)現(xiàn)了對(duì)海量事件的分布式關(guān)聯(lián)匹配。