esper語(yǔ)法

Esper引擎是為了滿足對(duì)事件進(jìn)行分析并做出反應(yīng)等這些應(yīng)用需求而產(chǎn)生的。這些應(yīng)用要求事實(shí)或接近事實(shí)處理 事件（或消息）。有時(shí)候是為了應(yīng)對(duì)復(fù)雜事件處理(CEP)和事件流分析的。關(guān)鍵要考慮這些類型應(yīng)用的（高）吞吐量、（低）響應(yīng)時(shí)間和需求邏輯的復(fù)雜程度 （復(fù)雜計(jì)算）。esper可以用在股票系統(tǒng)、風(fēng)險(xiǎn)監(jiān)控系統(tǒng)等等要求實(shí)時(shí)性比較高的系統(tǒng)中。

這個(gè)Esper引擎工作起來(lái)有點(diǎn)像數(shù)據(jù)庫(kù)的倒置。Esper 引擎允許應(yīng)用存儲(chǔ)查詢并運(yùn)行數(shù)據(jù)通過(guò)，來(lái)代替存儲(chǔ)數(shù)據(jù)并且執(zhí)行查詢存儲(chǔ)數(shù)據(jù)的工作方式。esper提供兩種機(jī)制來(lái)處理事件：
1、Esper提供了一個(gè)事件模式語(yǔ)言去指定基于表達(dá)式的事件模式匹配。這個(gè)模式匹配引擎是通過(guò)一個(gè)狀態(tài)機(jī)來(lái)實(shí)現(xiàn)的。這個(gè)事件處理的方法匹配期望存在的隊(duì)列或者不存在的事件或者事件的組合。它包括以時(shí)間為基礎(chǔ)的各個(gè)事件之間的關(guān)系。
2、 Esper還提供事件流查詢。這個(gè)樣可以使事件流分析CEP應(yīng)用的需求。事件流查詢提供窗口、聚合、連接和分析的函數(shù)來(lái)處理事件流。這些查詢是通過(guò)EPL 語(yǔ)句來(lái)實(shí)現(xiàn)的。EPL用于視圖。視圖表示需要將構(gòu)造的數(shù)據(jù)放入到一個(gè)事件流中并且去驅(qū)動(dòng)數(shù)據(jù)的流動(dòng)。在數(shù)據(jù)流動(dòng)的過(guò)程中對(duì)數(shù)據(jù)進(jìn)行處理，來(lái)得到我們最后所 需要的結(jié)果。

下面是在網(wǎng)上找到的資料,覺(jué)得總結(jié)的挺好的:
Esper提供這兩種方法作為互補(bǔ)是通過(guò)相同的API來(lái)實(shí)現(xiàn)的
1.4事件驅(qū)動(dòng)應(yīng)用服務(wù)器（Event Driven Application Server）
事 件驅(qū)動(dòng)應(yīng)用服務(wù)器是一種新型的服務(wù)器，為每秒需要處理超過(guò)100,000個(gè)事件的服務(wù)器提供一個(gè)運(yùn)行時(shí)和多種支撐基礎(chǔ)設(shè)施服務(wù)（如傳輸、安全、事件日志、 高可靠性和連接器等）。除了事件處理以外，事件驅(qū)動(dòng)服務(wù)器還可以將事件信息和長(zhǎng)時(shí)間存在的數(shù)據(jù)（通常從關(guān)系數(shù)據(jù)庫(kù)查詢中獲�。┙Y(jié)合起來(lái)，以及在事件流上執(zhí) 行臨時(shí)的關(guān)聯(lián)關(guān)系和匹配操作。
事件系統(tǒng)（Event System）存在兩個(gè)概念，可使之與消息傳送系統(tǒng)（Messaging System）區(qū)分開(kāi)來(lái)：
1、事件流處理（Event Stream Processing，ESP）——檢測(cè)事件數(shù)據(jù)流，分析出那些符合條件的事件，然后通知監(jiān)聽(tīng)器
2、復(fù)雜事件處理（Complex Event Processing，CEP）——可以監(jiān)察各事件間的模式
全 功能的事件驅(qū)動(dòng)服務(wù)器尚需數(shù)年時(shí)間方可實(shí)現(xiàn)，但現(xiàn)在開(kāi)發(fā)者就可通過(guò)來(lái)自Codehaus的Esper，在獨(dú)立應(yīng)用、Java企業(yè)級(jí)應(yīng)用和Spring應(yīng)用 中實(shí)現(xiàn)事件驅(qū)動(dòng)架構(gòu)。Esper的1.0版本（InfoQ曾報(bào)道過(guò)）是在2006年6月發(fā)布的，它是一個(gè)輕量級(jí)、可嵌入的ESP和CEP的開(kāi)源實(shí)現(xiàn)。

把Esper集成到獨(dú)立應(yīng)用中其實(shí)很簡(jiǎn)單。

步驟如下：

1、獲取一個(gè)Esper引擎實(shí)例
2、生成一個(gè)Statement（用Esper的查詢語(yǔ)言）
3、使用引擎注冊(cè)這個(gè)Statement
4、生成一個(gè)Listener（通過(guò)實(shí)現(xiàn)一個(gè)Java接口，該接口在Statement所得值為true會(huì)被觸發(fā)），并把它跟Statement綁定起來(lái)
事件能以Java對(duì)象、XML或Map的形式展現(xiàn)，當(dāng)它們通過(guò)系統(tǒng)的時(shí)候，系統(tǒng)會(huì)評(píng)估Statement的值，并執(zhí)行Listener中的邏輯。
Esper查詢語(yǔ)言提供了豐富的語(yǔ)法，這些語(yǔ)法可以表達(dá)復(fù)雜的臨時(shí)邏輯，此外還有如下的一些特征：
1、事件過(guò)濾
2、滑動(dòng)窗口和聚集（計(jì)算在最近30秒內(nèi)所有報(bào)告的有意義的信息）
3、分組窗口和對(duì)輸出率的限制（獲取最近10分鐘內(nèi)每個(gè)區(qū)域的信息數(shù)量）
4、連接和外連接（允許事件流之間的連接）
5、與歷史數(shù)據(jù)或引用數(shù)據(jù)集成（訪問(wèn)關(guān)系型數(shù)據(jù)庫(kù)）
6、生成所有Statement都可以訪問(wèn)的虛擬流