当我有两个匹配不同事件的规则时，drools 中的伪时钟出错

Question

我想用场景测试drools 6.3，但是在特殊情况下我遇到了问题。 这是我的一个简单形式的场景： 我在生成事件的模拟网络中有两个系统，A 和 B。我想写两条规则来找出这些事件中的模式。测试此场景的两条规则是：

declare A
  @timestamp(timestampA)
end

declare B
  @timestamp(timestampB)
end

Rule “1”
When
    accumulate( A() over window:time( 10s ) ; s:count(1) ; s>1)
Then
    System.out.println( " Rule 1 matched " );

Rule “2”
When
    B()
Then
    System.out.println( " Rule 2 matched " );

每个事件的时间戳是每个系统中生成的日志的时间戳，当它被 drools 接收并插入工作内存时。 我正在使用带有伪时钟的 STREAM 模式，因为来自系统 B 的事件由于网络拥塞而延迟 25 分钟接收，我应该手动调整会话时钟。会话时钟设置为插入到会话中的每个事件的时间戳。并且在插入每个事件时都会触发所有规则。 当接收和插入事件的顺序如下正确匹配时。

Event A received at 10:31:21 – Session clock : 10:31:21 – insert A and fire
Event A received at 10:31:23 - Session clock : 10:31:23 – insert A and fire
Rule 1 matched
Event B received at 10:06:41 - Session clock : 10:06:41 – insert B and fire
Rule 2 matched

但是当接收和插入事件的顺序如下所示时匹配不正确：

Event A received at 10:31:21 – Session clock : 10:31:21 – insert A and fire
Event B received at 10:06:41 - Session clock : 10:06:41 – insert B and fire
Rule 2 matched
Event A received at 10:31:23 - Session clock : 10:31:23 – insert A and fire

当第二个 A 事件插入时，最后 10 秒的两个 A 事件在工作内存中，但规则 1 不匹配。为什么？

Answer 1

您所做的与 Drools 的 CEP（连续事件处理）的假设有些冲突。 STREAM 模式意味着事件应该按照它们的时间戳顺序插入，而不管它们的来源。在大跳跃中来回设置伪时钟是另一种混淆引擎的好方法。

不要使用 STREAM 模式、window:time 并忘记会话时钟。

您有包含时间戳的事实，您可以通过引用这些时间戳轻松编写规则，或者使用简单的旧算术或应用时间运算符（它们只不过是用于测试 long 关系的语法糖（如在 java.lang) 值。