通过Esper探索事件驱动架构

作者 Ian Roughley 译者 陈俊 发布于 2007年5月31日 下午11时59分

社区

Java

主题

消息传送

标签

事件流处理 ,

Esper ,

Java One

在Java One上Thomas Bernhardt和Alexandre Vasseur向我们解说了事件驱动应用服务器（Event Driven Application Server）的概念，并介绍了Esper项目 。

事件驱动应用服务器是一种新型的服务器，为每秒需要处理超过100,000个事件的服务器提供一个运行时和多种支撑基础设施服务（如传输、安全、事 件日志、高可靠性和连接器等）。除了事件处理以外，事件驱动服务器还可以将事件信息和长时间存在的数据（通常从关系数据库查询中获取）结合起来，以及在事 件流上执行临时的关联关系和匹配操作。

事件系统（Event System）存在两个概念，可使之与消息传送系统（Messaging System）区分开来：

• 事件流处理（Event Stream Processing，ESP）——检测事件数据流，分析出那些符合条件的事件，然后通知监听器
• 复杂事件处理（Complex Event Processing，CEP）——可以监察各事件间的模式

全功能的事件驱动服务器尚需数年时间方可实现，但现在开发者就可通过来自Codehaus的Esper，在独立应用、Java企业级应用和Spring应用中实现事件驱动架构。Esper的1.0版本（InfoQ曾报道过 ）是在2006年6月发布的，它是一个轻量级、可嵌入的ESP和CEP的开源实现。

把Esper集成到独立应用中其实很简单。步骤如下：

• 获取一个Esper引擎实例
• 生成一个Statement（用Esper的查询语言）
• 使用引擎注册这个Statement
• 生成一个Listener（通过实现一个Java接口，该接口在Statement所得值为true会被触发），并把它跟Statement绑定起来

事件能以Java对象、XML或Map的形式展现，当它们通过系统的时候，系统会评估Statement的值，并执行Listener中的逻辑。

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

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

虽然事件驱动应用服务器的面世尚需时日，Esper目前已经可以投入产品级应用了。你很简单就可以把Esper集成到你的应用中，将帮助你先人一着提供符合业务和客户在实时性方面需求的功能。

查看英文原文： Exploring Event Driven Architectures with Esper