Drools流模式负模式

Question

我对Drools中的流模式有一个问题。我在用这个规则

declare MetaMessage
        @role(event)
end
 
rule 'rule1' ruleflow-group 'default'  
    when  
        $inMess : MetaMessage() from entry-point 'default'
        not(MetaMessage(this != $inMess, this after [0s,10s] $inMess) from entry-point 'default')
    then  
        //do things
end

如果我发送MetaMessage，我希望规则在指定的10秒后执行，但不会附加任何内容。如果我发送新的MetaMessage，10秒后，规则将执行。

编辑：如果我改变规则并去掉not，它就像一个符咒

我不知道我做错了什么。

这就是我创建KieBase的方式

KieBaseConfiguration config = KieServices.Factory.get().newKieBaseConfiguration();
config.setOption(EventProcessingOption.STREAM);
KieBase kieBase = kieHelper.build(config);
KieSession kieSession = kieBase.newKieSession();

编辑2每次在Kafka队列中插入新的元消息时，我都会使用fireAllRules（）触发规则。因此，我让一个消费者收集消息，并像这样将其插入会话中

EntryPoint ep = kieSession.getEntryPoint("default");
ep.insert(metaMessage);
kieSession.fireAllRules();

编辑3我有另一个简单的规则，与前一个规则一起执行

rule "AccumulatedTest"

    when
        accumulate(MetaMessage( timestamp > 0 ); $cnt: count(1))
    then
        log.info("Message n: "+$cnt);
end

第一次插入消息时（新创建kieSession时），我会得到信息“消息n:0”。但这条规则不再生效了。

如果在会话中插入任何其他消息，则规则不会触发

Answer 1

好的，多亏了@EstebanAliverti和@Mike，我已经解决了这个问题。

让我详细说明一下：

• 我必须创建一个每1s运行一次的计划fire All规则（）（正如@EstebanAliverti建议的那样）
• 我从规则中删除了ruleflow-group，因为（正如@Mike建议的那样）焦点切换回默认议程组，并且在我的实现中，我无法从计划执行中传递议程组

因此，现在fireAllRules（）每隔1s运行一次，没有规则流或议程组

现在规则看起来是这样的，并且它按预期工作

declare MetaMessage
        @role(event)
end
 
rule 'rule1'
    when  
        $inMess : MetaMessage() 
        not(MetaMessage(this != $inMess, this after [0s,10s] $inMess) )
    then  
        //do things
end

最后但并非最不重要的是，由于我没有使用功能性，因此我删除了入口点，因此我现在直接在Kie会话中插入消息

kieSession.insert(metaMessage);
kieSession.fireAllRules();

Answer 2

您使用ruleflow-group'default'，因此您必须将焦点设置为议程组才能执行规则，例如get会话（）. get议程（）. getAgendaGroup（“默认”）. setFocus（）；

很可能您在事件插入之前或之后设置了焦点。插入第一条消息后，您设置了焦点，但当时没有将规则添加到议程中（规则还没有资格执行），焦点被重置为主议程组。10秒后，您声明没有触发任何规则，尽管该规则已添加到“默认”议程中（因为主组有焦点）。您插入第二条消息并将焦点设置为“默认”议程，该议程执行由第一条消息触发的议程中的规则。

规则将被执行，如果你

1. 删除规则流组（最新文档提升议程组）
2. 将自动对焦true添加到规则中
3. 10秒后设置议程组焦点

查看议程组的工作方式