Esper语句执行顺序管理及代码执行时机异常问题排查

问题产生的原因 #

你遇到的这个问题，核心是Esper引擎默认的语句执行顺序没有保证变量更新操作先于查询执行。具体来说：

• 你的代码里，变量更新的on pattern语句和最终的select查询语句，都是对EventCreated事件的响应。
• Esper在处理单个事件时，默认不会自动给这类语句排序——如果没有显式指定优先级，引擎可能会先执行筛选器驱动的select查询（因为它直接监听EventCreated事件，属于更基础的筛选器语句），而此时变量A的自增/自减操作还没完成，导致查询用了更新前的旧值。
• 另外，语句的注册顺序也会影响执行顺序：如果先注册了select语句，再注册变量更新的模式语句，同优先级下引擎会按注册顺序执行，同样会出现查询先跑的情况。

如何管理Esper语句的执行顺序 #

有几种可靠的方式来强制指定执行顺序，确保变量更新先完成再执行查询：

1. 显式设置语句优先级（最推荐） #

使用Esper的@Priority注解给语句设置优先级数值，数值越高，执行优先级越高。把变量更新的语句设为高优先级，查询语句设为低优先级，引擎就会先处理变量更新：

create variable Integer A=0;

// 给变量更新语句设置高优先级
@Priority(10)
on pattern[every a=EventCreated(a.type ='C')] set A= A+1;

@Priority(10)
on pattern[every a=EventCreated(a.type ='EOD')] set A= A-1;

// 查询语句设置低优先级
@Priority(0)
select "R" as type, "R" as text, e.time as time, e.source as source from EventCreated e where A=0 ;

2. 调整语句注册顺序 #

如果不想用注解，可以确保先注册变量更新的模式语句，再注册查询语句。Esper对同优先级的语句，会按照注册顺序依次执行，这样变量更新会先被处理。不过这种方式不如优先级注解可靠，后续新增语句时容易打乱顺序。

3. 使用事件处理阶段（适合复杂场景） #

如果你的业务逻辑有多个处理步骤，可以用@Stage注解把语句分配到不同的处理阶段，让变量更新在更早的阶段执行，查询在后续阶段。比如：

create variable Integer A=0;

// 变量更新在阶段1执行
@Stage(1)
on pattern[every a=EventCreated(a.type ='C')] set A= A+1;

@Stage(1)
on pattern[every a=EventCreated(a.type ='EOD')] set A= A-1;

// 查询在阶段2执行，确保阶段1的操作都完成
@Stage(2)
select "R" as type, "R" as text, e.time as time, e.source as source from EventCreated e where A=0 ;

内容的提问来源于stack exchange，提问作者rajmohan