一、规则引擎是什么
Esper的官网：http://esper.codehaus.org/
参考文档：https://www.cnblogs.com/yudar/tag/esper/
小明历险记：规则引擎Drools教程：http://www.ibloger.net/article/3166.html
二、复杂事件处理 CEP
CEP 即 Complex Event Process，中文意思就是“复杂事件处理”
CEP 的类 SQL 语句，可以理解为处理模型的定义与描述。这是运行在 CEP引擎 中的特殊语句，之所以叫他类SQL，是因为它和SQL确实很像，除了 select，insert，delete，update，而且也有 avg，count 等函数。所以对于会SQL的人来说，他的语法结构大致还是能猜出一二的。在Esper中，这个句子叫做 EPL，即 Event Process Language。
三、Esper 简单示例
需求：计算 3 个苹果的平均价格。
1、引入依赖包
<dependency> <groupId>com.espertech</groupId> <artifactId>esper</artifactId> <version>7.1.0</version> </dependency>
2、定义事件模型
import lombok.Data;
/**
* 定义事件模型
*/
@Data
public class Apple {
private int id;
private int price;
}3、事件模型监听
/**
* 事件模型监听
*
* 实现UpdateListener接口，来定义事件的后置处理过程
*/
public class AppleListener implements UpdateListener {
@Override
public void update(EventBean[] newEvents, EventBean[] oldEvents) {
if (newEvents != null) {
Double avg = (Double) newEvents[0].get("avg(price)");
System.out.println("Apple's average price is " + avg);
}
}
}4、测试类
public static void main(String[] args) {
EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();
EPAdministrator admin = epService.getEPAdministrator();
// 指定事件模型
String apple = Apple.class.getName();
// 描述复杂事件
String epl = "select avg(price) from " + apple + ".win:length_batch(3)";
// 添加事后处理
EPStatement state = admin.createEPL(epl);
state.addListener(new AppleListener());
EPRuntime runtime = epService.getEPRuntime();
// 模拟事件发生
Apple apple1 = new Apple();
apple1.setId(1);
apple1.setPrice(5);
runtime.sendEvent(apple1);
Apple apple2 = new Apple();
apple2.setId(2);
apple2.setPrice(2);
runtime.sendEvent(apple2);
Apple apple3 = new Apple();
apple3.setId(3);
apple3.setPrice(5);
runtime.sendEvent(apple3);
}执行结果
Apple's average price is 4.0
5、为了简化代码，可以使用 lambda 表达式方式创建。
// state.addListener(new AppleListener());
state.addListener((newEvents, oldEvents) -> {
if (newEvents != null) {
Double avg = (Double) newEvents[0].get("avg(price)");
System.out.println("Apple's average price is " + avg);
}
});Esper 对事件有特殊的数据结构约定。能处理的事件结构有：POJO，java.util.Map，Object Array，XML。
接下来第二章介绍，事件类型
未经允许请勿转载：程序喵 » Esper教程 —— Esper 入门介绍（1）
