{"id":221,"date":"2017-05-10T03:42:35","date_gmt":"2017-05-10T03:42:35","guid":{"rendered":""},"modified":"2020-09-29T16:38:39","modified_gmt":"2020-09-29T08:38:39","slug":"esper%e5%ad%a6%e4%b9%a0%e6%96%87%e7%ab%a0%e6%94%b6%e9%9b%86","status":"publish","type":"post","link":"http:\/\/weizn.net\/?p=221","title":{"rendered":"Esper\u5b66\u4e60\u6587\u7ae0\u6536\u96c6"},"content":{"rendered":"<h4><strong>\u4e4b\u524d\u6536\u96c6\u4e2aP\uff0c\u518d\u591a\u7684\u6587\u6863\u4e5f\u6ca1\u5b98\u65b9\u6587\u6863\u597d\uff1a<\/strong><\/h4>\n<p><a href=\"http:\/\/esper.espertech.com\/\">http:\/\/esper.espertech.com\/<\/a><\/p>\n<blockquote class=\"wp-embedded-content\" data-secret=\"xLA3xdwkhM\"><p><a href=\"https:\/\/www.espertech.com\/esper\/solution-patterns\/\">Solution Patterns<\/a><\/p><\/blockquote>\n<p><iframe loading=\"lazy\" class=\"wp-embedded-content\" sandbox=\"allow-scripts\" security=\"restricted\" style=\"position: absolute; clip: rect(1px, 1px, 1px, 1px);\" title=\"&#8220;Solution Patterns&#8221; &#8212; EsperTech\" src=\"https:\/\/www.espertech.com\/esper\/solution-patterns\/embed\/#?secret=xLA3xdwkhM\" data-secret=\"xLA3xdwkhM\" width=\"600\" height=\"338\" frameborder=\"0\" marginwidth=\"0\" marginheight=\"0\" scrolling=\"no\"><\/iframe><\/p>\n<p>&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;<\/p>\n<p><span style=\"font-size: 14px;\">Esper\u4e13\u680f\u4ecb\u7ecd\uff1ahttp:\/\/blog.csdn.net\/luonanqin\/article\/details\/21300263<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u590d\u6742\u4e8b\u4ef6\u5904\u7406\u5f15\u64ce\u4ecb\u7ecd\uff1ahttp:\/\/www.cnblogs.com\/aking1988\/<\/span><\/p>\n<p><span style=\"font-size: 14px;\">Esper Reference\uff1ahttp:\/\/www.espertech.com\/esper\/release-6.0.1\/esper-reference\/pdf\/esper_reference.pdf<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u00a0<\/span><\/p>\n<p><span style=\"font-size: 14px;\">Demo:<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\/*&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;HelloEsper&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;-*\/<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\/**<br \/>\n* Created by weizinan on 2017\/5\/10.<br \/>\n*\/<br \/>\nimport com.espertech.esper.client.Configuration;<br \/>\nimport com.espertech.esper.client.EPAdministrator;<br \/>\nimport com.espertech.esper.client.EPRuntime;<br \/>\nimport com.espertech.esper.client.EPServiceProvider;<br \/>\nimport com.espertech.esper.client.EPServiceProviderManager;<br \/>\nimport com.espertech.esper.client.EPStatement;<br \/>\nimport java.util.Random;<\/span><\/p>\n<p>public class HelloEsper {<br \/>\nprivate static Random generator=new Random();<\/p>\n<p>private static void GenerateRandomTick(EPRuntime cepRT) {<br \/>\ndouble price = (double) generator.nextInt(10);<br \/>\nlong timeStamp = System.currentTimeMillis();<br \/>\nString symbol = &#8220;AAPL&#8221;;<br \/>\nTick tick = new Tick(symbol, price, timeStamp);<br \/>\nSystem.out.println(&#8220;Sending tick:&#8221; + tick);<br \/>\ncepRT.sendEvent(tick); \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \/\/\u5411CEP\u53d1\u9001\u4e8b\u4ef6<br \/>\n}<\/p>\n<p>public static void main(String[] args) {<br \/>\n\/* \u8bbe\u7f6e\u914d\u7f6e\u4fe1\u606f *\/<br \/>\nConfiguration cepConfig = new Configuration();<br \/>\ncepConfig.addEventType(&#8220;StockTick&#8221;, Tick.class.getName()); \/\/\u6dfb\u52a0\u4e8b\u4ef6\u7c7b\u578b\u5b9a\u4e49<\/p>\n<p>\/* \u521b\u5efa\u5f15\u64ce\u5b9e\u4f8b *\/<br \/>\nEPServiceProvider cepProvider = EPServiceProviderManager.getProvider(&#8220;myCEPEngine&#8221;,cepConfig);<\/p>\n<p>\/* \u521b\u5efastatement\u7684\u7ba1\u7406\u63a5\u53e3\u5b9e\u4f8b *\/<br \/>\nEPAdministrator cepAdmin = cepProvider.getEPAdministrator();<br \/>\nEPStatement cepStatement = cepAdmin.createEPL(&#8220;select * from &#8221; +<br \/>\n&#8220;StockTick(symbol=&#8217;AAPL&#8217;).win:length(2) &#8221; +<br \/>\n&#8220;having avg(price) &gt; 6.0&#8221;); \u00a0 \u00a0 \u00a0\/\/\u5b9a\u4e49\u4e8b\u4ef6\u89e6\u53d1\u7b56\u7565<\/p>\n<p>\/*\u7ed1\u5b9a\u4e8b\u4ef6\u5904\u7406\u5bf9\u8c61*\/<br \/>\ncepStatement.addListener(new CEPListener());<\/p>\n<p>\/* \u5f15\u64ce\u5b9e\u4f8b\u8fd0\u884c\u63a5\u53e3\uff0c\u8d1f\u8d23\u4e3a\u5f15\u64ce\u5b9e\u4f8b\u63a5\u6536\u6570\u636e\u5e76\u53d1\u9001\u7ed9\u5f15\u64ce\u5904\u7406 *\/<br \/>\nEPRuntime cepRT = cepProvider.getEPRuntime(); \u00a0 \/\/\u542f\u52a8CEP\u5f15\u64ce<\/p>\n<p>while(true) {<br \/>\nGenerateRandomTick(cepRT); \u00a0 \u00a0\/\/\u751f\u6210\u968f\u673a\u4e8b\u4ef6<br \/>\ntry {<br \/>\nThread.sleep(1000);<br \/>\n}catch (InterruptedException e){<br \/>\ne.printStackTrace();<br \/>\nbreak;<br \/>\n}<br \/>\n}<br \/>\n}<\/p>\n<p>}<\/p>\n<p>&nbsp;<\/p>\n<p><span style=\"font-size: 14px;\">\/*&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;CEPListener&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8211;*\/<br \/>\n<\/span><\/p>\n<p>import com.espertech.esper.client.EventBean;<br \/>\nimport com.espertech.esper.client.UpdateListener;<\/p>\n<p>\/**<br \/>\n* Created by weizinan on 2017\/5\/10.<br \/>\n*\/<br \/>\npublic class CEPListener implements UpdateListener {<br \/>\n@Override<br \/>\npublic void update(EventBean[] newData, EventBean[] oldData) {<br \/>\nSystem.out.println(&#8220;Event received: &#8221; + newData[0].getUnderlying());<br \/>\n}<br \/>\n}<\/p>\n<div style=\"white-space: nowrap;\"><\/div>\n<p>\/*&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8211;<span style=\"white-space: normal;\">Tick<\/span>&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;-*\/<\/p>\n<p>\/**<br \/>\n* Created by weizinan on 2017\/5\/10.<br \/>\n*\/<br \/>\nimport java.util.Date;<\/p>\n<p>public class Tick {<br \/>\nprivate String symbol;<br \/>\nprivate Double price;<br \/>\nprivate Date timeStamp;<\/p>\n<p>Tick(String s, double p, long t) {<br \/>\nsymbol = s;<br \/>\nprice = p;<br \/>\ntimeStamp = new Date(t);<br \/>\n}<br \/>\npublic double getPrice() {return price;}<br \/>\npublic String getSymbol() {return symbol;}<br \/>\npublic Date getTimeStamp() {return timeStamp;}<\/p>\n<p>@Override<br \/>\npublic String toString() {<br \/>\nreturn &#8220;Price: &#8221; + price.toString() + &#8221; time: &#8221; + timeStamp.toString();<br \/>\n}<br \/>\n}<\/p>\n<p>\/*&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;-END&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;&#8212;-*\/<\/p>\n<p>&nbsp;<\/p>\n<p>&nbsp;<\/p>\n<p><span style=\"font-size: 14px;\">5\u5206\u949f\u5f00\u542fEsper\u4e4b\u65c5<\/span><\/p>\n<p><span style=\"font-size: 14px;\">http:\/\/www.cnblogs.com\/Binhua-Liu\/p\/4646308.html<br \/>\n<\/span><\/p>\n<p><span style=\"font-size: 14px;\">=================================================<\/span><br \/>\n<span style=\"font-size: 14px;\">\u539f\u4f5c\u8005\uff1aCoffeeOneSugar<\/span><br \/>\n<span style=\"font-size: 14px;\">\u7ffb\u8bd1\uff1a\u5218\u658c\u534e<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u5728\u6211\u4e4b\u524d\u53d1\u8868\u7684\u6587\u7ae0\u4e2d\uff0c\u6211\u63d0\u5230\u6211\u6700\u8fd1\u70ed\u8877\u4e8eComplex Event Processing (CEP) \uff08\u590d\u6742\u4e8b\u4ef6\u5904\u7406\uff09\u3002\u7b80\u5355\u6765\u8bf4\uff0cCEP\u628a\u6570\u636e\u6d41\u4f5c\u4e3a\u8f93\u5165\uff0c\u6839\u636e\u4e00\u7cfb\u5217\u9884\u5b9a\u4e49\u7684\u89c4\u5219\uff0c\u628a\u6570\u636e\uff08\u6216\u90e8\u5206\u6570\u636e\uff09\u91cd\u5b9a\u5411\u7ed9\u76d1\u542c\u8005\u4eec\uff1b\u53c8\u6216\u8005\u662f\u5f53\u53d1\u73b0\u6570\u636e\u4e2d\u7684\u9690\u542b\u7684\u6a21\u5f0f\uff08Pattern\uff09\u65f6\uff0c\u89e6\u53d1\u4e8b\u4ef6\u3002\u5728\u5927\u91cf\u6570\u636e\u88ab\u4ea7\u751f\u51fa\u6765\u5e76\u9700\u8981\u8fdb\u884c\u5b9e\u65f6\u5730\u5206\u6790\u7684\u573a\u666f\u4e0b\uff0cCEP\u7279\u522b\u6709\u7528\u3002<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u6709\u4e00\u4e2a\u5f88\u4e0d\u9519\u7684\u8f6f\u4ef6\u9879\u76ee\uff0c\u53ef\u4ee5\u8ba9\u4f60\u505a\u5230\u8fd9\u4e00\u70b9\uff0c\u53eb\u505aESPER\u3002\u4f60\u53ef\u4ee5\u5728\u8fd9\u91cc\u627e\u5230\u8be5\u9879\u76ee\u7684\u7f51\u7ad9\u3002Esper\u5411\u7a0b\u5e8f\u5458\u63d0\u4f9b\u4e00\u4e2a\u79f0\u4e3aEPL\u7684\u8bed\u8a00\uff0c\u6709\u4e9b\u7c7b\u4f3c\u4e8eSQL\u8bed\u8a00\uff0c\u5b83\u53ef\u4ee5\u5f88\u597d\u5730\u7528\u4e8e\u5bf9\u89c4\u5219\u548c\u6a21\u5f0f\u7684\u914d\u7f6e\uff0c\u8fd9\u4e9b\u89c4\u5219\u548c\u6a21\u5f0f\u5c06\u88ab\u5e94\u7528\u5230\u6570\u636e\u6d41\u4e0a\u3002<\/span><\/p>\n<p><span style=\"font-size: 14px;\">Esper\u9644\u5e26\u7684\u6587\u6863\u662f\u76f8\u5f53\u5b8c\u6574\u7684\uff0c\u4f46\u7f3a\u4e4f\u5b9e\u9645\u7684\u4f8b\u5b50\uff0c\u8fd9\u4f7f\u5f97\u5b83\u770b\u8d77\u6765\u96be\u4ee5\u88ab\u4f7f\u7528\u3002\u6240\u4ee5\u8fd9\u91cc\u7ed9\u51fa\u4e00\u4e2aEsper\u76845\u5206\u949f\u6307\u5bfc\u3002\u867d\u7136\u4e0b\u9762\u7684\u4f8b\u5b50\u662f\u7528Java\u7f16\u5199\uff0c\u4f46\u662f\u5176\u5b9eEsper\u662f\u540c\u65f6\u652f\u6301Java\u548cC#\u7684\u3002\u6211\u8fd9\u91cc\u5047\u8bbe\u4f60\u5df2\u7ecf\u4e0b\u8f7d\u4e86Esper\uff0c\u5982\u679c\u6ca1\u6709\uff0c\u53ef\u4ee5\u901a\u8fc7\u70b9\u51fb\u8fd9\u4e2a\u94fe\u63a5\u6765\u5b8c\u6210\u3002\u89e3\u538b\u521a\u624d\u4e0b\u8f7d\u7684\u6587\u4ef6\u540e\uff0c\u4f60\u5e94\u8be5\u5728\u4f60\u78c1\u76d8\u7684\u67d0\u4e2a\u5730\u65b9\u53ef\u4ee5\u627e\u5230\u4e00\u4e2a\u53ebesper-3.1.0\u7684\u6587\u4ef6\u5939\u3002\uff08\u8bd1\u8005\uff1a\u8fd9\u7bc7\u6587\u7ae0\u6bd4\u8f83\u65e9\u4e86\uff0c\u73b0\u5728esper\u6700\u65b0\u7248\u672c\u662f5.2.0\uff09<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u5728\u5f00\u59cb\u524d\uff0c\u4f60\u9700\u8981\u6dfb\u52a0\u51e0\u4e2a\u5e93\u6587\u4ef6\u5230\u4f60\u7684\u5de5\u7a0b\u4e2d\uff0c\u5f53\u7136\uff0cesper-3.1.0.jar\u662f\u5176\u4e2d\u4e4b\u4e00\uff0c\u4f60\u4e5f\u9700\u8981\u53e6\u5916\u5176\u4ed64\u4e2a\u7b2c\u4e09\u65b9\u7684\u5e93\u6587\u4ef6\uff0c\u4ed6\u4eec\u53ef\u4ee5\u5728esper-3.1.0.jar\/esper\/lib\u6587\u4ef6\u5939\u4e2d\u627e\u5230\u3002<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u73b0\u5728\u5f00\u59cb\u6211\u4eec\u76845\u5206\u949f\u5427\u3002\u5728\u4f60\u628a\u9700\u8981\u5206\u6790\u7684\u6570\u636e\u4e22\u5230CEP\u5f15\u64ce\u7684\u7ba1\u9053\u4e2d\u4e4b\u524d\uff0c\u9700\u8981\u628a\u8fd9\u4e9b\u6570\u636e\u7ed3\u6784\u5316\u5230\u5bf9\u8c61\u5f53\u4e2d\u53bb\u3002\u8ba9\u6211\u4eec\u7528\u4e00\u4e2a\u7b80\u5355\u7684\u4f8b\u5b50\uff0c\u5199\u4e00\u4e2a\u7c7b\uff08\u6216\u8005\u53eb\u5b83bean\uff09\u6765\u63cf\u8ff0\u7ed9\u5b9a\u65f6\u95f4\u7684\u67d0\u4e2a\u80a1\u7968\u7684\u4ef7\u683c\uff1a<\/span><\/p>\n<p><span style=\"font-size: 14px;\">import java.util.Date;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 public static class Tick {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 String symbol;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 Double price;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 Date timeStamp;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public Tick(String s, double p, long t) {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 symbol = s;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 price = p;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 timeStamp = new Date(t);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public double getPrice() {return price;}<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public String getSymbol() {return symbol;}<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public Date getTimeStamp() {return timeStamp;}<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 @Override<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public String toString() {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 return &#8220;Price: &#8221; + price.toString() + &#8221; time: &#8221; + timeStamp.toString();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 }<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u5b83\u67093\u4e2a\u5c5e\u6027\uff1a\u80a1\u7968\u4ee3\u7801\uff0c\u4ef7\u683c\u548c\u65f6\u95f4\u6233\u3002\u5728\u6211\u4eec\u5f00\u59cb\u751f\u6210\u6570\u4ee5\u4ebf\u8ba1\u7684\u6570\u636e\u524d\uff0c\u6211\u4eec\u9700\u8981\u901a\u77e5\u5f15\u64ce\u5b83\u9700\u8981\u5904\u7406\u54ea\u4e9b\u5bf9\u8c61\uff0c\u8fd9\u662f\u901a\u8fc7\u5728\u5b9e\u4f8b\u5316CEP\u5f15\u64ce\u65f6\uff0c\u4f7f\u7528\u4e00\u4e2aConfiguration\u5bf9\u8c61\u6765\u5b9e\u73b0\u7684\uff1a<\/span><\/p>\n<p><span style=\"font-size: 14px;\">import com.espertech.esper.client.*;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">public class main {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0public static void main(String [] args){<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \/\/The Configuration is meant only as an initialization-time object.<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 Configuration cepConfig = new Configuration();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \/\/ We register Ticks as objects the engine will have to handle<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 cepConfig.addEventType(&#8220;StockTick&#8221;,Tick.class.getName());<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0\/\/ We setup the engine<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 EPServiceProvider cep = EPServiceProviderManager.getProvider(&#8220;myCEPEngine&#8221;,cepConfig);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0}<\/span><br \/>\n<span style=\"font-size: 14px;\">}<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u4f5c\u4e3a\u6d4b\u8bd5\u76ee\u7684\uff0c\u6211\u4eec\u73b0\u5728\u521b\u5efa\u4e00\u4e2a\u51fd\u6570\u6765\u751f\u6210\u968f\u673a\u7684\u6570\u636e\uff0c\u5e76\u4e14\u628a\u5b83\u4eec\u4e22\u5230CEP\u5f15\u64ce\u5f53\u4e2d\uff0c\u6211\u4eec\u628a\u8fd9\u4e2a\u51fd\u6570\u53eb\u505a\u201cGenerateRandomTick\u201d\uff0c\u5b83\u628aEPRuntime\u5bf9\u8c61\u4f5c\u4e3a\u53c2\u6570\uff0c\u8fd9\u4e2a\u5bf9\u8c61\u7528\u4e8e\u628a\u4e8b\u4ef6\u4f20\u9012\u7ed9CEP\u5f15\u64ce\uff1a<\/span><\/p>\n<p><span style=\"font-size: 14px;\">import java.util.Random;<\/span><br \/>\n<span style=\"font-size: 14px;\">import com.espertech.esper.client.*;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">public class exampleMain {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0private static Random generator=new Random();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0public static void GenerateRandomTick(EPRuntime cepRT){<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 double price = (double) generator.nextInt(10);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 long timeStamp = System.currentTimeMillis();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 String symbol = &#8220;AAPL&#8221;;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 Tick tick= new Tick(symbol,price,timeStamp);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 System.out.println(&#8220;Sending tick:&#8221; + tick);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 cepRT.sendEvent(tick);<\/span><br \/>\n<span style=\"font-size: 14px;\">}<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 public static void main(String[] args) {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0\/\/The Configuration is meant only as an initialization-time object.<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 Configuration cepConfig = new Configuration();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0cepConfig.addEventType(&#8220;StockTick&#8221;,Tick.class.getName());<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 EPServiceProvider cep=EPServiceProviderManager.getProvider(&#8220;myCEPEngine&#8221;,cepConfig);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 EPRuntime cepRT = cep.getEPRuntime();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">}<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u73b0\u5728\uff0c\u6211\u4eec\u6709\u4e86\u4e00\u4e2a\u53ef\u4ee5\u5de5\u4f5c\u7684CEP\u5f15\u64ce\uff0c\u548c\u4e0d\u65ad\u8f93\u5165\u7684\u865a\u5047\u7684\u6570\u636e\uff0c\u662f\u65f6\u5019\u6765\u521b\u5efa\u6211\u4eec\u7684\u7b2c\u4e00\u6761\u89c4\u5219\u4e86\uff0c\u7528Esper\u7684\u8bf4\u6cd5\uff0c\u6211\u4eec\u7684\u7b2c\u4e00\u6761EPL\u8bed\u53e5\u3002\u8981\u8fd9\u4e48\u505a\uff0c\u6211\u4eec\u9700\u8981\u8bf7\u5f15\u64ce\u7684\u7ba1\u7406\u5458\u8bb0\u5f55\u6211\u4eec\u7684\u8bed\u53e5\u3002\u7136\u540e\uff0cCEP\u5f15\u64ce\u4f1a\u6839\u636eEPL\u8bed\u53e5\u7684\u5b9a\u4e49\uff0c\u8fc7\u6ee4\u5b83\u6536\u5230\u7684\u6570\u636e\uff0c\u5f53\u6570\u636e\u6ee1\u8db3\u8bed\u53e5\u4e2d\u7684\u9009\u62e9\u6761\u4ef6\u6216\u8005\u6a21\u5f0f\u65f6\uff0c\u89e6\u53d1\u4e8b\u4ef6\u3002<\/span><\/p>\n<p><span style=\"font-size: 14px;\">public static void main(String[] args) {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \/\/The Configuration is meant only as an initialization-time object.<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 Configuration cepConfig = new Configuration();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 cepConfig.addEventType(&#8220;StockTick&#8221;,Tick.class.getName());<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 EPServiceProvider cep = EPServiceProviderManager.getProvider(&#8220;myCEPEngine&#8221;,cepConfig);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 EPRuntime cepRT = cep.getEPRuntime();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \/\/ We register an EPL statement<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 EPAdministrator cepAdm = cep.getEPAdministrator();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 EPStatement cepStatement = cepAdm.createEPL(&#8220;select * from &#8221; +<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 &#8220;StockTick(symbol=&#8217;AAPL&#8217;).win:length(2) &#8221; +<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 &#8220;having avg(price) &gt; 6.0&#8221;);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u8fd9\u91cc\uff0c\u6211\u4eec\u7684\u89c4\u5219\u8bbe\u7f6e\u4e3a\uff1a\u6bcf\u5f53\u6700\u8fd1\u76842\u6b21\u6570\u636e\u7684\u5e73\u5747\u503c\u5927\u4e8e6.0\u65f6\uff0c\u89e6\u53d1\u4e8b\u4ef6\u3002<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u4e0b\u4e00\u6b65\uff0c\u4e3b\u8981\u662f\u521b\u5efa\u4e00\u4e2a\u76d1\u542c\u8005\u5e76\u628a\u5b83\u548c\u6211\u4eec\u7684\u9009\u62e9\u89c4\u5219\u4ea7\u751f\u7684\u4e8b\u4ef6\u5173\u8054\u8d77\u6765\u3002\u53ef\u4ee5\u8fd9\u4e48\u505a\uff1a<\/span><\/p>\n<p><span style=\"font-size: 14px;\">cepStatement.addListener(new CEPListener());<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u8fd9\u91cc\u6709\u4e0d\u540c\u7684\u65b9\u5f0f\u6765\u5b9e\u73b0\u76d1\u542c\u8005\uff0c\u4e0b\u9762\u7684\u662f\u5176\u4e2d\u6700\u7b80\u5355\u7684\u4e00\u79cd\u3002\u8fd9\u91cc\u76d1\u542c\u8005\u53ea\u662f\u7b80\u5355\u5730\u628a\u5b83\u4ece\u5f15\u64ce\u4e2d\u6536\u5230\u7684\u5bf9\u8c61\u6253\u5370\u51fa\u6765\uff1a<\/span><\/p>\n<p><span style=\"font-size: 14px;\">public static class CEPListener implements UpdateListener {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0public void update(EventBean[] newData, EventBean[] oldData) {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0System.out.println(&#8220;Event received: &#8220;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 + newData[0].getUnderlying());<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">}<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u5230\u76ee\u524d\u4e3a\u6b62\uff0c\u770b\u4e0a\u53bb\u8fd8\u4e0d\u9519\u3002\u73b0\u5728\u662f\u6d4b\u8bd5\u6211\u4eec\u7684\u4ee3\u7801\u7684\u65f6\u5019\u4e86\u3002\u8ba9\u6211\u4eec\u751f\u6210\u4e00\u4e9b\u6570\u636e\uff0c\u770b\u4e00\u5207\u80fd\u5426\u6b63\u5e38\u5de5\u4f5c\u3002\u53ef\u4ee5\u5728main\u51fd\u6570\u4e2d\u6dfb\u52a0\u4e00\u4e0b\u884c\u6765\u505a\u5230\uff1a<\/span><\/p>\n<p><span style=\"font-size: 14px;\">for(int i = 0; i&lt; 5; i++)<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 GenerateRandomTick(cepRT);<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u73b0\u5728\u6240\u6709\u7684\u4ee3\u7801\u770b\u4e0a\u53bb\u5982\u4e0b\u6240\u793a\uff08\u6211\u628aTick\u7c7b\u548c\u5165\u53e3\u51fd\u6570\u653e\u5728\u4e00\u8d77\uff0c\u8fd9\u6837\u4f60\u5c31\u80fd\u628a\u5b83\u4eec\u590d\u5236\u7c98\u8d34\u5230\u4e00\u4e2a\u6587\u4ef6\u5e76\u8fd0\u884c\u5b83\u4eec\uff09<\/span><\/p>\n<p><span style=\"font-size: 14px;\">import com.espertech.esper.client.*;<\/span><br \/>\n<span style=\"font-size: 14px;\">import java.util.Random;<\/span><br \/>\n<span style=\"font-size: 14px;\">import java.util.Date;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">public class exampleMain {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 public static class Tick {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 String symbol;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 Double price;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 Date timeStamp;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public Tick(String s, double p, long t) {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 symbol = s;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 price = p;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 timeStamp = new Date(t);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public double getPrice() {return price;}<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public String getSymbol() {return symbol;}<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public Date getTimeStamp() {return timeStamp;}<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 @Override<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public String toString() {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 return &#8220;Price: &#8221; + price.toString() + &#8221; time: &#8221; + timeStamp.toString();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 private static Random generator = new Random();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 public static void GenerateRandomTick(EPRuntime cepRT) {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 double price = (double) generator.nextInt(10);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 long timeStamp = System.currentTimeMillis();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 String symbol = &#8220;AAPL&#8221;;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 Tick tick = new Tick(symbol, price, timeStamp);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 System.out.println(&#8220;Sending tick:&#8221; + tick);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 cepRT.sendEvent(tick);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 public static class CEPListener implements UpdateListener {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 public void update(EventBean[] newData, EventBean[] oldData) {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 System.out.println(&#8220;Event received: &#8221; + newData[0].getUnderlying());<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 public static void main(String[] args) {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\/\/The Configuration is meant only as an initialization-time object.<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 Configuration cepConfig = new Configuration();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 cepConfig.addEventType(&#8220;StockTick&#8221;, Tick.class.getName());<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 EPServiceProvider cep = EPServiceProviderManager.getProvider(&#8220;myCEPEngine&#8221;, cepConfig);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 EPRuntime cepRT = cep.getEPRuntime();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 EPAdministrator cepAdm = cep.getEPAdministrator();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 EPStatement cepStatement = cepAdm.createEPL(&#8220;select * from &#8221; +<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 &#8220;StockTick(symbol=&#8217;AAPL&#8217;).win:length(2) &#8221; +<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 &#8220;having avg(price) &gt; 6.0&#8221;);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 cepStatement.addListener(new CEPListener());<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0\/\/ We generate a few ticks&#8230;<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 for (int i = 0; i &lt; 5; i++) {<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 GenerateRandomTick(cepRT);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 }<\/span><br \/>\n<span style=\"font-size: 14px;\">}<\/span><\/p>\n<p><span style=\"font-size: 14px;\">Output:<\/span><br \/>\n<span style=\"font-size: 14px;\">log4j:WARN No appenders could be found for logger (com.espertech.esper.epl.metric.MetricReportingPath).<\/span><br \/>\n<span style=\"font-size: 14px;\">log4j:WARN Please initialize the log4j system properly.<\/span><br \/>\n<span style=\"font-size: 14px;\">Sending tick:Price: 6.0 time: Tue Jul 21 01:11:15 CEST 2009<\/span><br \/>\n<span style=\"font-size: 14px;\">Sending tick:Price: 0.0 time: Tue Jul 21 01:11:15 CEST 2009<\/span><br \/>\n<span style=\"font-size: 14px;\">Sending tick:Price: 7.0 time: Tue Jul 21 01:11:15 CEST 2009<\/span><br \/>\n<span style=\"font-size: 14px;\">Sending tick:Price: 4.0 time: Tue Jul 21 01:11:15 CEST 2009<\/span><br \/>\n<span style=\"font-size: 14px;\">Sending tick:Price: 9.0 time: Tue Jul 21 01:11:15 CEST 2009<\/span><br \/>\n<span style=\"font-size: 14px;\">Event received: Price: 9.0 time: Tue Jul 21 01:11:15 CEST 2009<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u6b63\u5982\u4f60\u770b\u5230\u7684\uff0c\u53ea\u6709\u6700\u540e\u4e24\u884c\u6570\u636e\u5e73\u5747\u503c\u5927\u4e8e6\uff0c\u56e0\u6b64\u53ea\u6709\u4e00\u4e2a\u4e8b\u4ef6\u6700\u7ec8\u88ab\u5f15\u64ce\u89e6\u53d1\u4e86\u3002\u76f8\u5f53\u4e0d\u9519\uff01<\/span><\/p>\n<p><span style=\"font-size: 14px;\">Oh\uff0c\u4f60\u6216\u8bb8\u62c5\u5fc3\u8f93\u51fa\u4e2d\u7684\u7b2c\u4e00\u884c\uff0c\u662f\u7684\uff0c\u8fd9\u91cc\u8fd8\u6709\u4e00\u70b9\u5c0f\u95ee\u9898\u3002\u4e8b\u5b9e\u4e0a\uff0cEsper\u4f7f\u7528\u7684\u65e5\u5fd7\u751f\u6210\u5305log4j\u5bfc\u81f4\u4e86\u8fd9\u4e2a\u8b66\u544a\u3002\u5b83\u662f\u53ef\u4ee5\u901a\u8fc7\u4e00\u4e2a\u53eblog4j.xml\u7684\u6587\u4ef6\u6765\u914d\u7f6e\u7684\uff0c\u4f60\u53ef\u4ee5\u5728esper-3.1.0\/examples\u4e0b\u7684\u67d0\u4e2a\u4f8b\u5b50\u4e2d\u7684\/etc\u76ee\u5f55\u4e0b\u627e\u5230\u5b83\u3002\u6211\u4e0d\u8ba4\u4e3a\u7ed9\u6211\u4eec\u6240\u6709\u7684\u7a0b\u5e8f\u90fd\u5f04\u4e00\u4e2axml\u914d\u7f6e\u6587\u4ef6\u662f\u4e2a\u597d\u4e3b\u610f\uff0c\u6240\u4ee5\u6211\u4eec\u5728\u4ee5\u4e0b\u4ee3\u7801\u4e2d\uff0c\u7528\u70b9\u6280\u5de7\u6765\u914d\u7f6e\u6211\u4eec\u7684logger\uff0c\u5728\u4f60\u7684\u6587\u4ef6\u5f00\u59cb\u5904\u52a0\u5165\u4e9bimport\u548c\u4ee3\u7801\uff1a<\/span><\/p>\n<p><span style=\"font-size: 14px;\">import org.apache.log4j.ConsoleAppender;<\/span><br \/>\n<span style=\"font-size: 14px;\">import org.apache.log4j.SimpleLayout;<\/span><br \/>\n<span style=\"font-size: 14px;\">import org.apache.log4j.Level;<\/span><br \/>\n<span style=\"font-size: 14px;\">import org.apache.log4j.Logger;<\/span><br \/>\n<span style=\"font-size: 14px;\">\/\/and this in the main function before the rest of your code:<\/span><\/p>\n<p><span style=\"font-size: 14px;\">public static void main(String [] args){<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 SimpleLayout layout = new SimpleLayout();<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 ConsoleAppender appender = new ConsoleAppender(new SimpleLayout());<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 Logger.getRootLogger().addAppender(appender);<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0 \u00a0 \u00a0 Logger.getRootLogger().setLevel((Level) Level.WARN);<\/span><br \/>\n<span style=\"font-size: 14px;\">(&#8230;)<\/span><br \/>\n<span style=\"font-size: 14px;\">\u00a0<\/span><br \/>\n<span style=\"font-size: 14px;\">5\u5206\u949f\u5230\u6b64\u7ed3\u675f\u3002<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u4e0b\u4e00\u7bc7\u6587\u7ae0\u4e2d\uff0c\u6211\u5c06\u66f4\u6df1\u5165\u4e00\u4e9b\u6765\u63a2\u7d22EPL\u8bed\u53e5\uff0c\u63d0\u4f9b\u4e00\u4e9b\u4ee3\u7801\u6765\u8fde\u63a5\u4e24\u4e2a\u5f15\u64ce\u5b9e\u73b0\u6240\u8c13\u7684\u201c\u4e8b\u4ef6\u7cbe\u5316\u201d\uff08event refinement\uff09\uff08\u8bd1\u8005\uff1a\u597d\u50cf\u4e4b\u540e\u4f5c\u8005\u518d\u4e5f\u6ca1\u6709\u66f4\u65b0\u8fc7\u4e86\uff0c\u6240\u4ee5\uff0c\u4e0d\u8981\u6307\u671b\u540e\u7eed\u4e86\uff1a\uff09\uff09<\/span><\/p>\n<p><span style=\"font-size: 14px;\">\u539f\u6587\u5730\u5740\uff1ahttps:\/\/coffeeonesugar.wordpress.com\/2009\/07\/21\/getting-started-with-esper-in-5-minutes\/<\/span><\/p>\n<p>&nbsp;<\/p>\n","protected":false},"excerpt":{"rendered":"<p style=\"margin:10px auto;padding:0px;color:#333333;font-family:Verdana, Arial, Helvetica, sans-serif;font-size:13.3333px;white-space:normal;background-color:#FFFFFF;\">\n\t\u539f\u4f5c\u8005\uff1a<a href=\"https:\/\/coffeeonesugar.wordpress.com\/\" style=\"margin:0px;padding:0px;text-decoration:none;color:#000000;border-bottom:1px dotted #333333;\">CoffeeOneSugar<\/a>\n<\/p>\n<p style=\"margin:10px auto;padding:0px;color:#333333;font-family:Verdana, Arial, Helvetica, sans-serif;font-size:13.3333px;white-space:normal;background-color:#FFFFFF;\">\n\t\u7ffb\u8bd1\uff1a<a href=\"http:\/\/cnblogs.com\/binhua-liu\" style=\"margin:0px;padding:0px;text-decoration:none;color:#000000;border-bottom:1px dotted #333333;\">\u5218\u658c\u534e<\/a>\n<\/p>\n<p style=\"margin:10px auto;padding:0px;color:#333333;font-family:Verdana, Arial, Helvetica, sans-serif;font-size:13.3333px;white-space:normal;background-color:#FFFFFF;\">\n\t&nbsp;\n<\/p>\n<p style=\"margin:10px auto;padding:0px;color:#333333;font-family:Verdana, Arial, Helvetica, sans-serif;font-size:13.3333px;white-space:normal;background-color:#FFFFFF;\">\n\t\u5728\u6211\u4e4b\u524d\u53d1\u8868\u7684\u6587\u7ae0\u4e2d\uff0c\u6211\u63d0\u5230\u6211\u6700\u8fd1\u70ed\u8877\u4e8eComplex Event Processing (CEP) \uff08\u590d\u6742\u4e8b\u4ef6\u5904\u7406\uff09\u3002\u7b80\u5355\u6765\u8bf4\uff0cCEP\u628a\u6570\u636e\u6d41\u4f5c\u4e3a\u8f93\u5165\uff0c\u6839\u636e\u4e00\u7cfb\u5217\u9884\u5b9a\u4e49\u7684\u89c4\u5219\uff0c\u628a\u6570\u636e\uff08\u6216\u90e8\u5206\u6570\u636e\uff09\u91cd\u5b9a\u5411\u7ed9\u76d1\u542c\u8005\u4eec\uff1b\u53c8\u6216\u8005\u662f\u5f53\u53d1\u73b0\u6570\u636e\u4e2d\u7684\u9690\u542b\u7684\u6a21\u5f0f\uff08Pattern\uff09\u65f6\uff0c\u89e6\u53d1\u4e8b\u4ef6\u3002\u5728\u5927\u91cf\u6570\u636e\u88ab\u4ea7\u751f\u51fa\u6765\u5e76\u9700\u8981\u8fdb\u884c\u5b9e\u65f6\u5730\u5206\u6790\u7684&#8230;<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[337],"tags":[],"class_list":["post-221","post","type-post","status-publish","format-standard","hentry"],"yoast_head":"<!-- This site is optimized with the Yoast SEO plugin v16.9 - https:\/\/yoast.com\/wordpress\/plugins\/seo\/ -->\n<title>Esper\u5b66\u4e60\u6587\u7ae0\u6536\u96c6 - Wayne&#039;s Blog<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"http:\/\/weizn.net\/?p=221\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Esper\u5b66\u4e60\u6587\u7ae0\u6536\u96c6 - Wayne&#039;s Blog\" \/>\n<meta property=\"og:description\" content=\"\u539f\u4f5c\u8005\uff1aCoffeeOneSugar    \u7ffb\u8bd1\uff1a\u5218\u658c\u534e    &nbsp;    \u5728\u6211\u4e4b\u524d\u53d1\u8868\u7684\u6587\u7ae0\u4e2d\uff0c\u6211\u63d0\u5230\u6211\u6700\u8fd1\u70ed\u8877\u4e8eComplex Event Processing (CEP) \uff08\u590d\u6742\u4e8b\u4ef6\u5904\u7406\uff09\u3002\u7b80\u5355\u6765\u8bf4\uff0cCEP\u628a\u6570\u636e\u6d41\u4f5c\u4e3a\u8f93\u5165\uff0c\u6839\u636e\u4e00\u7cfb\u5217\u9884\u5b9a\u4e49\u7684\u89c4\u5219\uff0c\u628a\u6570\u636e\uff08\u6216\u90e8\u5206\u6570\u636e\uff09\u91cd\u5b9a\u5411\u7ed9\u76d1\u542c\u8005\u4eec\uff1b\u53c8\u6216\u8005\u662f\u5f53\u53d1\u73b0\u6570\u636e\u4e2d\u7684\u9690\u542b\u7684\u6a21\u5f0f\uff08Pattern\uff09\u65f6\uff0c\u89e6\u53d1\u4e8b\u4ef6\u3002\u5728\u5927\u91cf\u6570\u636e\u88ab\u4ea7\u751f\u51fa\u6765\u5e76\u9700\u8981\u8fdb\u884c\u5b9e\u65f6\u5730\u5206\u6790\u7684...\" \/>\n<meta property=\"og:url\" content=\"http:\/\/weizn.net\/?p=221\" \/>\n<meta property=\"og:site_name\" content=\"Wayne&#039;s Blog\" \/>\n<meta property=\"article:published_time\" content=\"2017-05-10T03:42:35+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2020-09-29T08:38:39+00:00\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"zinan\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"5 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebSite\",\"@id\":\"http:\/\/weizn.net\/#website\",\"url\":\"http:\/\/weizn.net\/\",\"name\":\"Wayne&#039;s Blog\",\"description\":\"\",\"publisher\":{\"@id\":\"http:\/\/weizn.net\/#\/schema\/person\/e88bc12c590502d8b6249326f960b264\"},\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"http:\/\/weizn.net\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"WebPage\",\"@id\":\"http:\/\/weizn.net\/?p=221#webpage\",\"url\":\"http:\/\/weizn.net\/?p=221\",\"name\":\"Esper\\u5b66\\u4e60\\u6587\\u7ae0\\u6536\\u96c6 - Wayne&#039;s Blog\",\"isPartOf\":{\"@id\":\"http:\/\/weizn.net\/#website\"},\"datePublished\":\"2017-05-10T03:42:35+00:00\",\"dateModified\":\"2020-09-29T08:38:39+00:00\",\"breadcrumb\":{\"@id\":\"http:\/\/weizn.net\/?p=221#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"http:\/\/weizn.net\/?p=221\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"http:\/\/weizn.net\/?p=221#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\\u9996\\u9875\",\"item\":\"http:\/\/weizn.net\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Esper\\u5b66\\u4e60\\u6587\\u7ae0\\u6536\\u96c6\"}]},{\"@type\":\"Article\",\"@id\":\"http:\/\/weizn.net\/?p=221#article\",\"isPartOf\":{\"@id\":\"http:\/\/weizn.net\/?p=221#webpage\"},\"author\":{\"@id\":\"http:\/\/weizn.net\/#\/schema\/person\/e88bc12c590502d8b6249326f960b264\"},\"headline\":\"Esper\\u5b66\\u4e60\\u6587\\u7ae0\\u6536\\u96c6\",\"datePublished\":\"2017-05-10T03:42:35+00:00\",\"dateModified\":\"2020-09-29T08:38:39+00:00\",\"mainEntityOfPage\":{\"@id\":\"http:\/\/weizn.net\/?p=221#webpage\"},\"wordCount\":987,\"commentCount\":0,\"publisher\":{\"@id\":\"http:\/\/weizn.net\/#\/schema\/person\/e88bc12c590502d8b6249326f960b264\"},\"articleSection\":[\"\\u6570\\u636e\\u5206\\u6790\"],\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"CommentAction\",\"name\":\"Comment\",\"target\":[\"http:\/\/weizn.net\/?p=221#respond\"]}]},{\"@type\":[\"Person\",\"Organization\"],\"@id\":\"http:\/\/weizn.net\/#\/schema\/person\/e88bc12c590502d8b6249326f960b264\",\"name\":\"zinan\",\"logo\":{\"@id\":\"http:\/\/weizn.net\/#personlogo\"}}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"Esper\u5b66\u4e60\u6587\u7ae0\u6536\u96c6 - Wayne&#039;s Blog","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"http:\/\/weizn.net\/?p=221","og_locale":"zh_CN","og_type":"article","og_title":"Esper\u5b66\u4e60\u6587\u7ae0\u6536\u96c6 - Wayne&#039;s Blog","og_description":"\u539f\u4f5c\u8005\uff1aCoffeeOneSugar    \u7ffb\u8bd1\uff1a\u5218\u658c\u534e    &nbsp;    \u5728\u6211\u4e4b\u524d\u53d1\u8868\u7684\u6587\u7ae0\u4e2d\uff0c\u6211\u63d0\u5230\u6211\u6700\u8fd1\u70ed\u8877\u4e8eComplex Event Processing (CEP) \uff08\u590d\u6742\u4e8b\u4ef6\u5904\u7406\uff09\u3002\u7b80\u5355\u6765\u8bf4\uff0cCEP\u628a\u6570\u636e\u6d41\u4f5c\u4e3a\u8f93\u5165\uff0c\u6839\u636e\u4e00\u7cfb\u5217\u9884\u5b9a\u4e49\u7684\u89c4\u5219\uff0c\u628a\u6570\u636e\uff08\u6216\u90e8\u5206\u6570\u636e\uff09\u91cd\u5b9a\u5411\u7ed9\u76d1\u542c\u8005\u4eec\uff1b\u53c8\u6216\u8005\u662f\u5f53\u53d1\u73b0\u6570\u636e\u4e2d\u7684\u9690\u542b\u7684\u6a21\u5f0f\uff08Pattern\uff09\u65f6\uff0c\u89e6\u53d1\u4e8b\u4ef6\u3002\u5728\u5927\u91cf\u6570\u636e\u88ab\u4ea7\u751f\u51fa\u6765\u5e76\u9700\u8981\u8fdb\u884c\u5b9e\u65f6\u5730\u5206\u6790\u7684...","og_url":"http:\/\/weizn.net\/?p=221","og_site_name":"Wayne&#039;s Blog","article_published_time":"2017-05-10T03:42:35+00:00","article_modified_time":"2020-09-29T08:38:39+00:00","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"zinan","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"5 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebSite","@id":"http:\/\/weizn.net\/#website","url":"http:\/\/weizn.net\/","name":"Wayne&#039;s Blog","description":"","publisher":{"@id":"http:\/\/weizn.net\/#\/schema\/person\/e88bc12c590502d8b6249326f960b264"},"potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"http:\/\/weizn.net\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"WebPage","@id":"http:\/\/weizn.net\/?p=221#webpage","url":"http:\/\/weizn.net\/?p=221","name":"Esper\u5b66\u4e60\u6587\u7ae0\u6536\u96c6 - Wayne&#039;s Blog","isPartOf":{"@id":"http:\/\/weizn.net\/#website"},"datePublished":"2017-05-10T03:42:35+00:00","dateModified":"2020-09-29T08:38:39+00:00","breadcrumb":{"@id":"http:\/\/weizn.net\/?p=221#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["http:\/\/weizn.net\/?p=221"]}]},{"@type":"BreadcrumbList","@id":"http:\/\/weizn.net\/?p=221#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"http:\/\/weizn.net\/"},{"@type":"ListItem","position":2,"name":"Esper\u5b66\u4e60\u6587\u7ae0\u6536\u96c6"}]},{"@type":"Article","@id":"http:\/\/weizn.net\/?p=221#article","isPartOf":{"@id":"http:\/\/weizn.net\/?p=221#webpage"},"author":{"@id":"http:\/\/weizn.net\/#\/schema\/person\/e88bc12c590502d8b6249326f960b264"},"headline":"Esper\u5b66\u4e60\u6587\u7ae0\u6536\u96c6","datePublished":"2017-05-10T03:42:35+00:00","dateModified":"2020-09-29T08:38:39+00:00","mainEntityOfPage":{"@id":"http:\/\/weizn.net\/?p=221#webpage"},"wordCount":987,"commentCount":0,"publisher":{"@id":"http:\/\/weizn.net\/#\/schema\/person\/e88bc12c590502d8b6249326f960b264"},"articleSection":["\u6570\u636e\u5206\u6790"],"inLanguage":"zh-Hans","potentialAction":[{"@type":"CommentAction","name":"Comment","target":["http:\/\/weizn.net\/?p=221#respond"]}]},{"@type":["Person","Organization"],"@id":"http:\/\/weizn.net\/#\/schema\/person\/e88bc12c590502d8b6249326f960b264","name":"zinan","logo":{"@id":"http:\/\/weizn.net\/#personlogo"}}]}},"_links":{"self":[{"href":"http:\/\/weizn.net\/index.php?rest_route=\/wp\/v2\/posts\/221","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/weizn.net\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/weizn.net\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/weizn.net\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/weizn.net\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=221"}],"version-history":[{"count":5,"href":"http:\/\/weizn.net\/index.php?rest_route=\/wp\/v2\/posts\/221\/revisions"}],"predecessor-version":[{"id":438,"href":"http:\/\/weizn.net\/index.php?rest_route=\/wp\/v2\/posts\/221\/revisions\/438"}],"wp:attachment":[{"href":"http:\/\/weizn.net\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=221"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/weizn.net\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=221"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/weizn.net\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=221"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}