通过Esper探索事件驱动架构
2016-04-01 16:36
435 查看
在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集成到你的应用中,将帮助你先人一着提供符合业务和客户在实时性方面需求的功能。
事件驱动应用服务器是一种新型的服务器,为每秒需要处理超过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集成到你的应用中,将帮助你先人一着提供符合业务和客户在实时性方面需求的功能。
相关文章推荐
- C3P0数据库连接池的API网站
- 基于MPP架构的TERADATA技术预览
- 鸟哥?马哥?靠边站!今天猫哥带你玩千万PV级别运维架构实战
- hadoop_2_完全分布式高可用
- 网站收集
- Linux系统架构
- 三层架构(MVC)实现简单登陆注册验证(含验证码)
- x86架构
- Google工程师解析Android系统架构
- 网站文件系统发展
- 秒杀系统架构分析与实战
- 商品详情系统架构设计
- TrustZone软硬件架构
- 门店管理系统架构-(1)
- 网站如何整体换角度
- 大型网站架构技术一览
- 支付宝手机网站支付
- [转] 使用git自动部署简单网站
- Mysql router高可用和负载均衡测试
- 基于 infinitescroll、isotope、imagesLoaded 的瀑布流网站