无法将具有多个流规则的Kie会话序列化到字节[]

Question

将我的KieSession序列化为字节[]时，我遇到了一个未实现的情况。我以字节[]格式将规则保存在数据库中。

下面是我用来创建KieSession的一段代码：

KieServices kServices = KieServices.Factory.get();

KieFileSystem kFileSystem = kServices.newKieFileSystem();

for(byte[] arr : myRules) {
    String fileName = "/src/main/resources/" + generateRandomRuleName();
    kFileSystem.write(fileName , new ByteArrayResource(arr ));
}

kServices.newKieBuilder(kFileSystem).buildAll();

我有大约1K个永久事实，当向我的Spring Boot应用程序发出HTTP请求时，我需要复制我的KieSession字节，将其反序列化为KieSession，插入大约1K个临时事件、fireAllRules和dispose。这样，我就可以重用我的KieSession，而无需在每个HTTP请求上插入我的1K永久事实，也无需在每个HTTP请求后删除我的1K临时事实。下面是我用来序列化会话的代码：

KieBaseConfiguration configuration = KieServices.Factory.get().newKieBaseConfiguration();
configuration.setOption(MultithreadEvaluationOption.YES);
configuration.setOption(EqualityBehaviorOption.EQUALITY);
configuration.setOption(EventProcessingOption.STREAM);

KieBase kBase = kServices
        .newKieContainer(kServices.getRepository().getDefaultReleaseId())
        .getKieContainer()
        .newKieBase(configuration);

final KieSession kSession = kBase.newKieSession();

// myListOfPermanentFacts is an array of serializable Java objects, but not declared with @role ( fact )
kSession.execute((Command<?>) CommandFactory.newInsertElements(myListOfPermanentFacts));

final ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
MarshallerFactory.newMarshaller(kBase).marshall(outputStream, kSession);
outputStream.close();
byte[] kSessionBytes = outputStream.toByteArray();

当我使用collect中的单个规则时，如下所示：

rule "Rule_1"
    dialect "java"
    no-loop true
    when
        obj : MyObj( field1: field1 )
        List( size >= 3 ) from collect ( MyObj( field1 == field1, this before obj ) )
    then
        obj.someMethod( "string1" );
end

上述用例按预期工作。然而，当我有第二条规则（非常相似）时：

rule "Rule_2"
    dialect "java"
    no-loop true
    when
        obj : MyObj( field2: field2 )
        List( size >= 3 ) from collect ( MyObj( field2 == field2, this before obj ) )
    then
        obj.someMethod( "string2" );
end

我在方法马歇尔中收到以下异常：

java.lang.UnsupportedOperationException: org.drools.core.common.CompositeDefaultAgenda.getActivations -> TODO
    at org.drools.core.common.CompositeDefaultAgenda.getActivations(CompositeDefaultAgenda.java:386) ~[drools-core-7.28.0.Final.jar:7.28.0.Final]
    at org.drools.core.marshalling.impl.ProtobufOutputMarshaller.evaluateRuleActivations(ProtobufOutputMarshaller.java:268) ~[drools-core-7.28.0.Final.jar:7.28.0.Final]
    at org.drools.core.marshalling.impl.ProtobufOutputMarshaller.serializeSession(ProtobufOutputMarshaller.java:135) ~[drools-core-7.28.0.Final.jar:7.28.0.Final]
    at org.drools.core.marshalling.impl.ProtobufOutputMarshaller.writeSession(ProtobufOutputMarshaller.java:115) ~[drools-core-7.28.0.Final.jar:7.28.0.Final]
    at org.drools.core.marshalling.impl.ProtobufMarshaller.marshall(ProtobufMarshaller.java:120) ~[drools-core-7.28.0.Final.jar:7.28.0.Final]
    at org.drools.core.marshalling.impl.ProtobufMarshaller.marshall(ProtobufMarshaller.java:104) ~[drools-core-7.28.0.Final.jar:7.28.0.Final]

我遇到了什么还不受支持的用例？非常感谢。

Answer 1

它只是不为复合故障议程（CompositeDefaultAgenda）实现，而复合故障议程（CompositeDefaultAgenda）由多线程评估选项（multi-threadevaluationoption）使用。是。因此，将其设置为多线程评估选项。否解决此问题。

有趣的是，从byte[]到具有我的永久事实（我不希望每次都重新插入）的Kiesion的反序列化比缓存KieBase慢得多，生成一个新的Kiesion并每次都插入这些永久事实。