Esper入门介绍及热身（一）

一、什么是Esper

        Esper的官网定义： Esper is a component for CEP and ESP applications，中文意思是：Esper是用于CEP（复杂事件处理）和ESP（事件流处理）应用程序的组件。

        Esper是一个Java开发的事件流处理(ESP:Event Stream Processing)和复杂事件处理(CEP:Complex Event Processing)引擎。CEP：是一种实时事件处理并从大量事件数据流中挖掘复杂模式的技术。ESP：是一种从大量事件数据流中过滤，分析有意义的事件，并能够实时取得这些有意义的信息的技术。该引擎可应用于网络入侵探测，SLA监测，RFID读取，航空运输调控，金融方面(风险管理，欺诈探测)等领域。

        Esper是纯Java开源复杂事件和事件流引擎，可以监测事件流，并在特定事件发生时触发某些动作。    

        Esper引擎是为了满足事件进行分析并做出反应等这些应用需求而产生的。这些应用要求实时或者接近实时处理事件（或消息）。这类应用具有高吞吐量、低响应时间和复杂的计算等特点。              

 

二、Esper典型的应用：

1、 Esper可以用在股票系统、风险监控系统等等要求实时性比较高的系统中。

2、业务处理管理和自动化（处理监控，业务活动监控，异常报告，经营智能化等等） 

3、 财务（算法交易，欺诈检查，风险管理） 

4、 网络及应用程序监控（入侵检测，SLA(Service Level Agreement)监控） 

5、传感器网络应用（RFID 读取，生产线调度和控制，空中交通）

 

三、Esper的简单相关认识：

1、事件匹配规则：支持类似于通用sql语法规则。

2、提供事件监听

3、支持事件类型继承和多态。

4、一个简单的事件监听对象可以是xml(输入/输出流),java普通对象，以及map等。

5、支持复杂java对象图结构

6、可以动态进行属性设置

7、支持类似于数据库操作的，sql语句预处理

8、支持并发的查询

9、支持input/output io适配处理比如：数据的load，jms,db,http,socket等。

 

四、Esper和关系数据库

关系型数据库不适合每秒成百上千的数据量的查询
内存数据库与比传统的关系数据库相比，有更好的查询性能，更适合处理CEP应用。

 

五、Esper提供两种机制来处理事件

1、Esper提供了一个事件模式语言去指定基于表达式的事件模式匹配。这个模式匹配引擎是通过一个状态机来实现的。这个事件处理的方法匹配期望存在的队列或者不存在的事件或者事件的组合。它包括以时间为基础的各个事件之间的关系。

 

2、Esper还提供事件流查询。这样可以使事件流分析CEP应用的需求。事件流查询提供窗口、聚合、连接和分析的函数来处理事件流。这些查询是通过EPL 语句来实现的。EPL用于视图。视图表示需要将构造的数据放入到一个事件流中并且去驱动数据的流动。在数据流动的过程中对数据进行处理，来得到我们最后所需要的结果。

 

       在Esper中提供两种互补的方法（API）来处理事件

事件驱动应用服务器（Event Driven Application Server）

     事件驱动应用服务器是一种新型的服务器，为每秒需要处理超过100,000个事件的服务器提供一个运行时和多种支撑基础设施服务（如传输、安全、事件日志、 高可靠性和连接器等）。

     除了事件处理以外，事件驱动服务器还可以将事件信息和长时间存在的数据（通常从关系数据库查询中获取）结合起来，以及在事件流上执行临时的关联关系和匹配操作。
    事件系统（Event System）存在两个概念，可使之与消息传送系统（Messaging System）区分开来：
1、事件流处理（Event Stream Processing，ESP）——检测事件数据流，分析出那些符合条件的事件，然后通知监听器
2、复杂事件处理（Complex Event Processing，CEP）——可以监察各事件间的模式
     Esper可在独立应用、Java企业级应用和Spring应用中实现事件驱动架构。

 

 

六、怎样将Esper集成到独立应用中

1、获取一个Esper引擎实例
2、生成一个Statement（用Esper的查询语言）
3、使用引擎注册这个Statement

4、生成一个Listener（通过实现一个Java接口，该接口在Statement所得值为true时会被触发），并把它跟Statement绑定起来。 事件能以Java对象、XML或Map的形式展现，当它们通过系统的时候，Esper会评估Statement的值，并执行Listener中的逻辑。

 

七、Esper查询语言

 

Esper查询语言提供了丰富的语法，这些语法可以表达复杂的临时逻辑，此外还有如下的一些特征：

1、事件过滤
2、滑动窗口和聚集（计算在最近30秒内所有报告的有意义的信息）
3、分组窗口和对输出率的限制（获取最近10分钟内每个区域的信息数量）
4、连接和外连接（允许事件流之间的连接）
5、与历史数据或引用数据集成（访问关系型数据库）
6、生成所有Statement都可以访问的虚拟流

 

八、Esper Structure：

 

九、Esper事件流处理机制：

 

十、Esper JDBC事例图：

 

下一讲将讲解Esper的简单入门例子。