[發(fā)明專(zhuān)利]一種基于并行分布式架構(gòu)的復(fù)雜事件處理的方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201410697724.6
• 申請(qǐng)日: 2014-11-26
• 公開(kāi)（公告）號(hào): CN104394149B
• 公開(kāi)（公告）日: 2017-12-12
• 發(fā)明（設(shè)計(jì)）人: 廉海明;郭旭東;謝小明;胡佳;胡大正;郭江;沈艷林;石波;沈德峰;吳朝雄;王紅艷
• 申請(qǐng)（專(zhuān)利權(quán)）人: 中國(guó)航天科工集團(tuán)第二研究院七〇六所
• 主分類(lèi)號(hào): H04L29/06
• 分類(lèi)號(hào): H04L29/06;H04L29/08
• 代理公司: 中國(guó)兵器工業(yè)集團(tuán)公司專(zhuān)利中心11011
• 代理人: 張然

1.一種基于并行分布式架構(gòu)的復(fù)雜事件處理的方法，其特征在于：

把復(fù)雜事件處理技術(shù)對(duì)事件進(jìn)行處理的操作分解成幾個(gè)元操作，并把元操作分為兩類(lèi)：無(wú)狀態(tài)操作和有狀態(tài)操作；所謂無(wú)狀態(tài)操作，即對(duì)后面的事件的處理操作和前面的事件的處理操作無(wú)關(guān)聯(lián)；所謂有狀態(tài)操作，對(duì)后面事件的處理操作需要依據(jù)結(jié)合前面事件的處理操作進(jìn)行處理操作，通過(guò)滑動(dòng)窗口實(shí)現(xiàn)；劃分的無(wú)狀態(tài)操作包括：映射、轉(zhuǎn)換操作，過(guò)濾操作或聯(lián)合操作；有狀態(tài)操作包括：聚合操作或連接操作；

具體步驟如下：

步驟1：獲取用于關(guān)聯(lián)分析的查詢語(yǔ)句；

步驟2：把查詢語(yǔ)句按照上文定義的有狀態(tài)操作和無(wú)狀態(tài)操作分解成一串操作序列；

步驟3：按照有狀態(tài)操作把操作序列即查詢語(yǔ)句分解成子操作序列即子查詢語(yǔ)句，即有多少個(gè)有狀態(tài)操作就劃分成多少個(gè)子操作序列；其中劃分的第一個(gè)子操作序列至少包括無(wú)狀態(tài)的操作，或者僅僅由無(wú)狀態(tài)的操作組成，且該子操作序列包含了第一個(gè)有狀態(tài)操作之前的所有無(wú)狀態(tài)操作；包含有狀態(tài)操作的子操作序列其第一個(gè)操作一定是有狀態(tài)操作，該子操作也包含下一個(gè)有狀態(tài)操作之前的所有無(wú)狀態(tài)操作；

步驟4：依照步驟3查詢語(yǔ)句劃分成子查詢語(yǔ)句的數(shù)量，把集群按照該數(shù)量等分成相同數(shù)量的子群，把查詢語(yǔ)句按照步驟2劃分成的子操作序列分布式部署到劃分好的每個(gè)子群上，子群中的每個(gè)機(jī)器都部署相應(yīng)的子操作。