esper简单入门之demo
采用maven项目管理模式
pom配置如下:
代码如下:package org.wolf.esper;import org.wolf.esper.event.OrderEvent;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;/** * esper 特性: * 监听的事件源:包括简单的pojo,http,socket,db等, * 监听的语法:语法规范类似于sql语法 * @author Administrator * */[color=green]public class EPServiceProviderMain {public static void handlerEpser(){EPServiceProvider epServiceProvider =EPServiceProviderManager.getDefaultProvider();String expression ="select avg(price) from org.wolf.esper.event.OrderEvent.win:time(30 sec)";EPStatement epStatement =epServiceProvider.getEPAdministrator().createEPL(expression);epStatement.addListener(new UpdateListener() {public void update(EventBean[] arg0, EventBean[] arg1) {System.out.println("==========="+arg0);}});OrderEvent orderEvent = new OrderEvent();orderEvent.setPrice(34.98f);epServiceProvider.getEPRuntime().sendEvent(orderEvent);}public static void main(String[] args) {handlerEpser();}}[/color]