esper（复杂事件处理引擎）简介

Esper是一个复杂事件处理引擎，用于对同一类型的多个对象进行统计分析。

要统计的多个事件（一个事件通常对应着一个对象）会存储在一个队列中，这里叫它EQueue。

获得

 <dependency>
       <groupId>com.espertech</groupId>
       <artifactId>esper</artifactId>
       <version>4.9.0</version>
 </dependency>

我的入门DEMO在  点击打开我的GitHub

EPL

EPL，Event Process Language，事件处理语言。类似于SQL，描述了esper要分析的内容。

详见该分类下的其他博文。

事件类型

javaPojo

可以发送javaPojo，也可以发送map。
发送javaPojo时，直接创建epl = "select avg(price) from " + javaPojo.class.getName() + ".win:length_batch(2)";即可。
map

发送map时，可以注册表的类型，见下：

//发送map时，可以注册表的类型
// Person定义
Map<String, Object> personTable = new HashMap<String, Object>();
personTable.put("name", String.class);
personTable.put("age", Integer.class);
// 注册Person到Esper
admin.getConfiguration().addEventType("personEventTypeName",personTable);

发送map时，也可以通过epl语句建立。

//发送map时，也可以通过epl语句建立。
String createEpl="create schema appTable as (`id` int, `price` int, `color` string)";
admin.createEPL(createEpl);

注意：如果把schema看成一张表，我们发送的map中列数少了不报错，列数多了不报错（esper只用能匹配得上的元素），列名对应的数据类型不匹配也不报错（esper不会帮你转换）。

例子

package test;
import com.espertech.esper.client.EPAdministrator;
import com.espertech.esper.client.EPRuntime;
import com.espertech.esper.client.EPServiceProvider;
import com.espertech.esper.client.EPServiceProviderManager;
import com.espertech.esper.client.EPStatement;
import com.espertech.esper.client.EventBean;
import com.espertech.esper.client.UpdateListener;


class Apple
{
	private int id;
	private int price;

	public int getId()
	{return id;}

	public void setId(int id)
	{this.id = id;}

	public int getPrice()
	{return price;}

	public void setPrice(int price)
	{this.price = price;}
}

class AppleListener implements UpdateListener
{

	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);
		}
	}

}
public class Test {

	public static void main(String[] args) throws InterruptedException {
		EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();

		EPAdministrator admin = epService.getEPAdministrator();

		String product = Apple.class.getName();
		//统计窗口限定为：事件个数为2。每攒够2个就计算一次，然后清空队列。
		String epl = "select avg(price) from " + product + ".win:length_batch(2)";

		EPStatement state = admin.createEPL(epl);
		state.addListener(new AppleListener());

		EPRuntime runtime = epService.getEPRuntime();

		Apple apple1 = new Apple();
		apple1.setPrice(5);
		runtime.sendEvent(apple1);

		Apple apple2 = new Apple();
		apple2.setPrice(2);
		runtime.sendEvent(apple2);

		Apple apple3 = new Apple();
		apple3.setPrice(5);
		runtime.sendEvent(apple3);
		
		Apple apple4 = new Apple();
		apple4.setPrice(7);
		runtime.sendEvent(apple4);
		
	}
}
/**Apple's average price is 3.5
Apple's average price is 6.0
*/