面向物聯(lián)網(wǎng)的復(fù)雜事件處理方法的研究.pdf

1、物聯(lián)網(wǎng)是新一代信息技術(shù)的重要組成部分，其應(yīng)用范圍幾乎覆蓋了各行各業(yè)。物聯(lián)網(wǎng)獲得廣泛應(yīng)用需要解決的一個關(guān)鍵問題是物聯(lián)網(wǎng)中間件中的信息處理部分，而復(fù)雜事件處理是物聯(lián)網(wǎng)中間件的核心任務(wù)之一。物聯(lián)網(wǎng)環(huán)境下的事件具有異構(gòu)、分散、海量和不確定性等特征，以往的復(fù)雜事件處理模型大都假設(shè)每個事件發(fā)生的時間已知，或所有來自不同數(shù)據(jù)源的事件能合并成有序事件流;而在實(shí)際應(yīng)用中事件發(fā)生時間和次序往往是未知或不確定的。
　　 為了解決復(fù)雜事件處理的上述問題

2、，本文提出了一種高效的解決不確定事件的復(fù)雜事件處理方法。同時，針對物聯(lián)網(wǎng)分布式應(yīng)用的特點(diǎn)，提出基于SOA的分布式復(fù)雜事件處理體系架構(gòu)，并在此基礎(chǔ)上提出了分布式和并行的處理方法(Distrbuted Parallel Complex Event Processing，DPCEP)。本文的主要工作包括:
　　 (1)針對物聯(lián)網(wǎng)應(yīng)用中事件流特點(diǎn)及目前面向物聯(lián)網(wǎng)的復(fù)雜事件處理方法的不足，提出一種解決不確定事件的時態(tài)不確定模型，給每個事件

3、分配一個不確定間隔表示其所有可能發(fā)生的時間。基于該模型提出復(fù)雜事件檢測算法，即Interval-based方法。加入K-Slack緩沖機(jī)制應(yīng)對無序事件流。為了更加有效的處理海量事件流，本文對Interval-based進(jìn)行優(yōu)化，提出Optlnterval-based方法，該方法可以盡早丟棄無用的偏序事件，降低了計(jì)算復(fù)雜性。最后實(shí)驗(yàn)表明了該方法在處理不確定事件流時的有效性。
　　 (2)針對物聯(lián)網(wǎng)分布式應(yīng)用的特點(diǎn)，提出基于SOA的

4、分布式復(fù)雜事件處理系統(tǒng)，系統(tǒng)中設(shè)置輕量級的CEP引擎，嵌入到底層設(shè)備或物聯(lián)網(wǎng)網(wǎng)關(guān)中，對底層的原始事件進(jìn)行初步處理，減少了上層處理。在此基礎(chǔ)上，將Optlnterval-based方法擴(kuò)展為分布式并行DPCEP方法，將來自不同事件源的事件根據(jù)用戶查詢進(jìn)行劃分，采用全局并行和局部并行的方式進(jìn)行處理。并選擇中間結(jié)果集大的從節(jié)點(diǎn)作為主節(jié)點(diǎn)，由主節(jié)點(diǎn)將局部并行中產(chǎn)生的局部結(jié)果通過合并規(guī)則進(jìn)行合并并輸出到查詢接口。實(shí)驗(yàn)結(jié)果表明，該分布式并行方法能實(shí)