基于 Drools Fusion 时间滑动 windows

Question

我无法理解 JBoss Drools 推理引擎如何处理复杂的事件（drools 融合）。实际上，我创建了一条规则，以便在 5 秒内发生超过 2 笔交易时拒绝交易。这是规则

rule "more than 2 transaction in 5 seconds"
  when
    $transaction : Transaction( $id : id )
    Number(intValue > 2) from accumulate(
        $t : Transaction() over window:time(5s),
        count($t))

then
   $transaction.setDenied(true);
end

我使用伪会话时钟将会话设置为流模式。这里是java代码

SessionPseudoClock clock = kSession.getSessionClock();
Transaction tx1 = new Transaction(new BigInteger("10000"), TransactionType.CREDIT_CARD, 1L);
Transaction tx2 = new Transaction(new BigInteger("2000"), TransactionType.CREDIT_CARD,2L);
Transaction tx3 = new Transaction(new BigInteger("50000"), TransactionType.DEPOSIT,3L);
Transaction tx4 = new Transaction(new BigInteger("100"), TransactionType.WITHDRAW,4L);

assertTransaction(kSession, tx1);

clock.advanceTime(6, TimeUnit.SECONDS);
assertTransaction(kSession, tx2);

clock.advanceTime(3, TimeUnit.SECONDS);
assertTransaction(kSession, tx3);

clock.advanceTime(1800, TimeUnit.MILLISECONDS);
assertTransaction(kSession, tx4);

其中 assertTransaction simple 包含以下代码：

kSession.insert(tx);
kSession.fireAllRules();

触发规则匹配的事务是 tx4，因为 tx2 发生在 tx1 之后 6 秒，并且 tx1 超出了定时 window。奇怪的是规则的动作对working memory中的所有交易都执行，即使是tx1。

是否应该以这种方式工作？

提前致谢

Answer 1

主要问题是引擎没有机会执行未决激活并根据（伪）时钟的当前读数处理事实。此外，该规则将针对当前在工作内存中的每个事务触发，而您希望它仅针对最新事务触发。

对于 CEP、测试或生产，我建议运行引擎在单独的线程中调用 fireUntilHalt。然后，对于测试或生产，可以使用真实时钟并插入事实，因为它们来自或来自在插入之间暂停的线程。而且伪时钟也可以用，几乎不用改动代码。

要确保规则仅针对最近的线程触发，请将规则更改为

rule "more than 2 transaction in 5 seconds"
when
    $transaction : Transaction( $id : id )
    not Transaction( this after $transaction )
    Number(intValue > 2) from accumulate(
        $t : Transaction() over window:time(5s),
        count($t))
then
    System.out.println( "denied: " + $transaction );
end

基于 Drools Fusion 时间滑动 windows

Drools Fusion time sliding based windows

drools

redhat

business-rules

complex-event-processing

drools-fusion