码迷，mamicode.com
首页 > 其他好文 > 详细

Esper学习之十五：Pattern（二）

时间：2014-09-16 20:40:31      阅读：393      评论：0      收藏：0      [点我收藏+]

标签：cep   esper   开源   

转载请注明出处：http://blog.csdn.net/luonanqin



       上一篇开始了新一轮语法——Pattern的讲解，一开始为大家普及了几个基础知识，其中有说到操作符。当时只是把它们都列举出来了，所以今天这篇就是专门详解这些操作符的，但是由于篇幅限制，本篇先会讲几个，剩余的后面几篇会逐个讲解。


1. Followed-by
       如果各位有看过官方文档，应该会发现Followed-by的讲解是在比较靠后的位置，而放在第一的是Every关键字。我把它提前主要是因为其他的关键字结合Followed-by能更好的说明那个关键字的特点。如果不习惯我这样的顺序硬要跟着文档学习的朋友，可以跳过这一节先看后面的内容。

       Followed-by，顾名思义就是“紧跟，跟随”的意思，通常用于事件之间的关联。举个现实生活中的例子：比如下班了，我用钥匙把家门打开，这是一个事件，紧接着我打开了浴室的灯，这也是一个事件，由于我之前在中央控制系统里设定了一个规则：打开家门后如果开了浴室的灯，热水就会放好，我一会儿就能洗澡了。所以我之前的一系列操作就触发了放热水这个动作。可能这个例子不是比较实际，但是应该能很清楚的说明这个关键字的含义吧。

       Followed-by的操作符用减号和大于号组成，即->，和C语言里的指针一模一样。操作符两边是事件名称，表示右边的事件跟随左边的事件发生之后发生，即进入引擎。如果只是简单的事件follow，在操作符的两边写上事先定义的事件名或者类全名。例如：

AppleEvent -> BananaEvent

// or

com.xxx.Benz -> com.yyy.Audi
但是如果前后事件之间有关联，那事件名或者类全名就需要设置一个别名。例如：

a=AppleEvent -> b=BananaEvent(b.price = a.price)		// equals: a=AppleEvent -> b=BananaEvent(price = a.price)
       设置别名的原因很简单，就是为了方便描述事件之间的关联信息。但是有意思的是，对于前两个简单follow不设置别名esper不会报语法错误，但是实际运行时你无法通过api获取满足条件的事件，而带上别名的事件是可以正常获取的。

先上一个简单的例子：

package example;

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;

/**
 * Created by Luonanqin on 9/5/14.
 */
class FollowedEvent {

	private int size;

	public int getSize() {
		return size;
	}

	public void setSize(int size) {
		this.size = size;
	}

	public String toString() {
		return "FollowedEvent{" + "size=" + size + '}';
	}
}

class PatternFollowedListener implements UpdateListener {

	public void update(EventBean[] newEvents, EventBean[] oldEvents) {
		if (newEvents != null) {
			for (int i = 0; i < newEvents.length; i++) {
				System.out.println();
				EventBean event = newEvents[i];
				System.out.println("Result:");
				System.out.println(event.get("a") + " " + event.get("b"));
			}
		}
	}
}

public class PatternFollowedTest {

	public static void main(String[] args) {
		EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();
		EPAdministrator admin = epService.getEPAdministrator();
		EPRuntime runtime = epService.getEPRuntime();

		String followed = FollowedEvent.class.getName();

		String epl = "select * from pattern[every a=" + followed + " -> b=" + followed + "(size < a.size)]";
		System.out.println("EPL: " + epl+"\n");
		EPStatement stat = admin.createEPL(epl);
		stat.addListener(new PatternFollowedListener());

		FollowedEvent f1 = new FollowedEvent();
		f1.setSize(1);
		System.out.println("Send Event1: " + f1);
		runtime.sendEvent(f1);
		System.out.println();

		FollowedEvent f2 = new FollowedEvent();
		f2.setSize(3);
		System.out.println("Send Event2: " + f2);
		runtime.sendEvent(f2);
		System.out.println();

		FollowedEvent f3 = new FollowedEvent();
		f3.setSize(2);
		System.out.println("Send Event3: " + f3);
		runtime.sendEvent(f3);
	}
}
执行结果：

EPL: select * from pattern[every a=example.FollowedEvent -> b=example.FollowedEvent(size < a.size)]

Send Event1: FollowedEvent{size=1}

Send Event2: FollowedEvent{size=3}

Send Event3: FollowedEvent{size=2}

Result:
FollowedEvent{size=3} FollowedEvent{size=2}
       例子中的pattern是由every和followed-by两个结构组合而成，所实现的效果是针对每一个事件，都监听其follow后同类型的事件的size值小于follow前的事件。只要满足pattern定义，通过get对应的别名就可以获得触发时的具体事件。 并且满足触发条件的事件不会再次被监听。大家重点关注followed-by，every之后会有详细说明。

       以上面的例子来说，我们会监听所有进入引擎的FollowedEvent事件，并等待匹配规则的follow事件。但是如果满足条件的事件一直不发生，那么之前的等待事件就会一直存于引擎内，这势必会引起内存溢出，或者我们有某种需求，即只保留某一部分的事件用来等待匹配的follow事件。Esper为此提供了进阶的Followed-by语法：
lhs_expression -[limit_expression]> rhs_expression
       lhs_expression和rhs_expression就是之前所说的发生顺序有关联的两个事件，而中间的“->”被一个限制表达式分开了，这里的限制表达式需要返回一个int数值，也可以直接写一个数字。整体的含义是：当左边事件等待满足条件的右边事件时，最多只保留n个左边事件在引擎内等待触发，其余事件不留在引擎内。而这个n就是限制表达式的返回值。无论左边事件数量是否达到n，只要满足条件的右边事件到达并触发后，引擎便重新等待新的左边事件并重新计数，直到超过n。。。这个过程会不断循环。完整示例如下：

package example;

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;

/**
 * Created by Luonanqin on 9/10/14.
 */
class LimitEvent {

	private int age;

	public int getAge() {
		return age;
	}

	public void setAge(int age) {
		this.age = age;
	}

	public String toString() {
		return "LimitEvent{" + "age=" + age + '}';
	}
}

class LimitFollowedListener implements UpdateListener {

	public void update(EventBean[] newEvents, EventBean[] oldEvents) {
		if (newEvents != null) {
			System.out.println("\nResult: ");
			for (int i = 0; i < newEvents.length; i++) {
				EventBean event = newEvents[i];
				System.out.println("a=" + event.get("a") + " b=" + event.get("b"));
			}

			System.out.println();
		}
	}
}

public class LimitFollowedTest {

	public static void main(String[] args) {
		EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();
		EPAdministrator admin = epService.getEPAdministrator();
		EPRuntime runtime = epService.getEPRuntime();

		String limit = LimitEvent.class.getName();
		String follow = FollowedEvent.class.getName();

		/* 在每次触发完成前最多只保留2个a事件，触发条件为b的size值大于a的age */
		String epl = "every a=" + limit + " -[2]> b=" + follow + "(size > a.age)";
		System.out.println("EPL: " + epl + "\n");

		EPStatement stat = admin.createPattern(epl);
		stat.addListener(new LimitFollowedListener());

		System.out.println("First Send!\n");

		LimitEvent l1 = new LimitEvent();
		l1.setAge(1);
		System.out.println("Send Event: " + l1);
		runtime.sendEvent(l1);

		LimitEvent l2 = new LimitEvent();
		l2.setAge(2);
		System.out.println("Send Event: " + l2);
		runtime.sendEvent(l2);

		LimitEvent l3 = new LimitEvent();
		l3.setAge(0);
		System.out.println("Send Event: " + l3);
		runtime.sendEvent(l3);

		FollowedEvent f1 = new FollowedEvent();
		f1.setSize(3);
		System.out.println("Send Event: " + f1);
		runtime.sendEvent(f1);

		FollowedEvent f2 = new FollowedEvent();
		f2.setSize(4);
		System.out.println("Send Event: " + f2);
		runtime.sendEvent(f2);

		System.out.println();
		System.out.println("Second Send!\n");
		System.out.println("Send Event: "+l1);
		runtime.sendEvent(l1);
		System.out.println("Send Event: " + l2);
		runtime.sendEvent(l2);
		System.out.println("Send Event: " + l3);
		runtime.sendEvent(l3);
		System.out.println("Send Event: " + f1);
		runtime.sendEvent(f1);
	}
}
执行结果：

EPL: every a=example.LimitEvent -[2]> b=example.FollowedEvent(size > a.age)

First Send!

Send Event: LimitEvent{age=1}
Send Event: LimitEvent{age=2}
Send Event: LimitEvent{age=0}
Send Event: FollowedEvent{size=3}

Result: 
a=LimitEvent{age=1} b=FollowedEvent{size=3}
a=LimitEvent{age=2} b=FollowedEvent{size=3}

Send Event: FollowedEvent{size=4}

Second Send!

Send Event: LimitEvent{age=1}
Send Event: FollowedEvent{size=3}

Result: 
a=LimitEvent{age=1} b=FollowedEvent{size=3}
       例子中的epl已经给了注释说明含义，从运行结果中也可以看出，第一次发送时，FollowedEvent只触发了前两个age为1和2的LimitEvent，说明-[2]>起到了限制等待的LimitEvent事件数量为2的效果。第二次发送时，可以看到第一次触发之后-[2]>重新开始计数，FollowedEvent到达后就直接触发了。

关于限制左边事件的内容，有些是通过配置完成。比如说针对所有的pattern语句都限制，不必每次都写在句子中。这个在之后的配置章节会有讲解。

2.Every
这个操作符想必大家已经不陌生了。例子也看了这么多，顾名思义也能想到它代表的就是“每一个”的意思。实际上他表示的是，为操作符后的事件或者子pattern表达式建立一个监听实例，只要满足触发条件这个实例就到此结束。比如：

1).
select * from pattern[every LimitEvent]
// equals to
select * from LimitEvent

2).
every FollowedEvent(size > 2)

3).
every a=LimitEvent -> b=FollowedEvent(size > a.age)
       第一个例子是针对每一个LimitEvent事件都监听，所以等同于另一个非pattern写法。第二个例子监听每一个FollowedEvent，且事件的size要大于2，也就是一个filter。第三个例子我在之前有讲过，->的左右组合在一起可以算是一个子表达式（即followed-by），但是every真的是针对这个子表达式么？其实不然，every的优先级要大于->，所以every为每一个LimitEvent建立监听实例，并根据一定条件等待FollowedEvent。

我之所以先讲Followed-by，就是因为every和->的不同优先级会把各位弄晕，所以先让大家把->搞清楚再来看各种组合情况。

我把文档里的一个优先级例子放在这里专门讲解下，完整例子我就不写了。

假设事件传入引擎的顺序是这样的：

A1 B1 C1 B2 A2 D1 A3 B3 E1 A4 F1 B4

注意：every优先级高于->，但是圆括号优先级高于所有操作符

Pattern 1:
every ( A -> B )

匹配结果：
{A1, B1}
{A2, B3}
{A4, B4}

说明：因为有括号，所以every针对的是每一个A->B。A2后面的B3到达前，出现了A3，但是B3到达后并未匹配A3，说明every只有在一个完整的匹配发生后再对A进行新的监听，因此A3不会被监听。比如说：A1 A2 A3 A4 B1这样的发生顺序只会导致A1->B1

Pattern 2:
every A -> B

匹配结果：
{A1, B1}
{A2, B3} {A3, B3}
{A4, B4}

说明：由于没有括号，所以every的优先级大于->，所以every针对的是A，而不是A->B。也就是说，引擎每进入一个A，every都为其新建一个pattern实例等待B事件的发生。所以可以从结果中可以看出，B3进入引擎后同时触发了A2和A3

Pattern 3:
A -> every B

匹配结果：
{A1, B1}
{A1, B2}
{A1, B3}
{A1, B4}

说明：every的优先级大于->，且every只作用于B，所以->只会针对第一个A事件起作用，并且每一个B都可以匹配这个A。

Pattern 4:
every A -> every B

匹配结果：
{A1, B1}
{A1, B2}
{A1, B3} {A2, B3} {A3, B3}
{A1, B4} {A2, B4} {A3, B4} {A4, B4}

说明：A和B都用every修饰，every的优先级大于->，所以针对每一个A和B都可以匹配->。再说得通俗一点，只要A在B前进入引擎，那么A后面的B都可以和这个A匹配成功。
       上面的四个例子可以很清楚的表达出every的意思，更为复杂的例子就是将A和B替换成别的子pattern表达式，各位可以试着自己写写看一下效果。比如：every A->B->C

3. Every-Distinct
Every-Distinct和Every基本一样，唯一的区别是Every-Distinct会根据事件的某些属性过滤掉重复的，避免触发监听器。其余用法和Every相同。具体语法如下：

every-distinct(distinct_value_expr [, distinct_value_expr[...] [, expiry_time_period])
distinct_value_expr表示参与过滤的事件属性，比如：

every-distinct(a.num) a=A
并且可以多个属性联合在一起，就像联合主键那样。比如：

every-distinct(a.num, b.age) a=A -> b=B
       用于过滤的事件属性值在量很大的情况下会占用很多内存，所以我们需要给它设定一个过期值，也就是语法中的expiry_time_period。这个关键字表示的时间到达时，pattern重新匹配新的事件，而不受之前事件的用于过滤的属性值的影响。比如说：

EPL: every-distinct(a.num, 3 sec) a=A

Send: A1: {num=1}
Send: A2: {num=1}

After 3 seconds

Send: A3: {num=1}
       第一次发送num为1的A1事件会触发监听器，紧接着发送num为1的A2事件，不会触发，因为num=1已经出现过了，所以A2被过滤。3秒过后，pattern被重置，这时发送A3，监听器收到该事件。这个过程一直持续，即每3秒重置一次pattern，直到EPL实例被销毁。

语法讲解就这么多，以下几个点需要各位注意：
1）.语法后面跟的子表达式如果返回false，pattern也会被重置。这一点下面的例子会说明。
2）.无论多少个事件的属性参与过滤，其事件名必须设置别名，以“别名.属性名”的方式写在圆括号内。
3）.事件别名一定要在子表达式中定义，否则语法错误。比如：a=A -> every-distinct(a.aprop) b=B


总结上面的所有内容，我写了个完整的例子供大家参考。

package example;

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;

/**
 * Created by Luonanqin on 9/15/14.
 */
class EveryDistinctEvent {

	private int num;

	public int getNum() {
		return num;
	}

	public void setNum(int num) {
		this.num = num;
	}

	public String toString() {
		return "EveryDistinctEvent{" + "num=" + num + '}';
	}
}

class EveryDistinctListener implements UpdateListener {

	public void update(EventBean[] newEvents, EventBean[] oldEvents) {
		if (newEvents != null) {
			System.out.println("\nResult: ");
			for (int i = 0; i < newEvents.length; i++) {
				EventBean event = newEvents[i];
				System.out.println(event.get("a"));
			}
		}
	}
}

public class EveryDistinctTest {

	public static void main(String[] args) throws InterruptedException {
		EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider();
		EPAdministrator admin = epService.getEPAdministrator();
		EPRuntime runtime = epService.getEPRuntime();

		String everyDistinct = EveryDistinctEvent.class.getName();
		String limit = LimitEvent.class.getName();

		String epl1 = "every-distinct(a.num) a=" + everyDistinct;
		System.out.println("EPL1: " + epl1);
		EPStatement stat1 = admin.createPattern(epl1);
		stat1.addListener(new EveryDistinctListener());

		EveryDistinctEvent ed1 = new EveryDistinctEvent();
		ed1.setNum(1);

		EveryDistinctEvent ed2 = new EveryDistinctEvent();
		ed2.setNum(2);

		EveryDistinctEvent ed3 = new EveryDistinctEvent();
		ed3.setNum(1);

		System.out.println("\nSend Event: " + ed1);
		runtime.sendEvent(ed1);
		System.out.println("\nSend Event: " + ed2);
		runtime.sendEvent(ed2);
		System.out.println("\nSend Event: " + ed3);
		runtime.sendEvent(ed3);

		stat1.destroy();

		String epl2 = "every-distinct(a.num) (a=" + everyDistinct + " and not " + limit + ")";
		System.out.println("\nEPL2: " + epl2);
		EPStatement stat2 = admin.createPattern(epl2);
		stat2.addListener(new EveryDistinctListener());

		LimitEvent l1 = new LimitEvent();

		System.out.println("\nSend Event: " + ed1);
		runtime.sendEvent(ed1);
		System.out.println("\nSend Event: " + ed2);
		runtime.sendEvent(ed2);
		System.out.println("\nSend Event: " + l1);
		runtime.sendEvent(l1);
		System.out.println("\nSend Event: " + ed3);
		runtime.sendEvent(ed3);

		stat2.destroy();

		String epl3 = "every-distinct(a.num, 3 sec) a=" + everyDistinct;
		System.out.println("\nEPL3: " + epl3);
		EPStatement stat3 = admin.createPattern(epl3);
		stat3.addListener(new EveryDistinctListener());

		System.out.println("\nSend Event: " + ed1);
		runtime.sendEvent(ed1);
		System.out.println("\nSend Event: " + ed2);
		runtime.sendEvent(ed2);
		System.out.println("\nSleep 3 seconds!");
		Thread.sleep(3000);
		System.out.println("\nSend Event: " + ed3);
		runtime.sendEvent(ed3);
	}
}
执行结果：

EPL1: every-distinct(a.num) a=example.EveryDistinctEvent

Send Event: EveryDistinctEvent{num=1}

Result: 
EveryDistinctEvent{num=1}

Send Event: EveryDistinctEvent{num=2}

Result: 
EveryDistinctEvent{num=2}

Send Event: EveryDistinctEvent{num=1}

EPL2: every-distinct(a.num) (a=example.EveryDistinctEvent and not example.LimitEvent)

Send Event: EveryDistinctEvent{num=1}

Result: 
EveryDistinctEvent{num=1}

Send Event: EveryDistinctEvent{num=2}

Result: 
EveryDistinctEvent{num=2}

Send Event: LimitEvent{age=0}

Send Event: EveryDistinctEvent{num=1}

Result: 
EveryDistinctEvent{num=1}

EPL3: every-distinct(a.num, 3 sec) a=example.EveryDistinctEvent

Send Event: EveryDistinctEvent{num=1}

Result: 
EveryDistinctEvent{num=1}

Send Event: EveryDistinctEvent{num=2}

Result: 
EveryDistinctEvent{num=2}

Sleep 3 seconds!

Send Event: EveryDistinctEvent{num=1}

Result: 
EveryDistinctEvent{num=1}
       在EPL2中，every-distinct后面的子表达式是EveryDistinctEvent and not LimitEvent，所以在发送EveryDistinctEvent之后发送LimitEvent，就导致子表达式false，所以在此发送num=1的EveryDistinctEvent时监听器被触发。


       Pattern的操作符本篇只说了3个，内容虽然不多，但是大家一定要掌握好，特别是操作符之间的优先级，理解不透的话很容易出现意想不到的结果。下篇会接着讲几个我自己都很少用到操作符，敬请期待……



Esper学习之十五：Pattern（二）

标签：cep   esper   开源   

原文地址：http://blog.csdn.net/luonanqin/article/details/39321249
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！