问题描述
我在将 KieSession
序列化为 byte[]
时遇到了未实现的情况。我将规则保存在 byte[]
格式的数据库中。
这是我用来创建 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 和处置。这样,我可以重复使用我的 KieSession
,而无需在每个 HTTP 请求中插入我的 1K 永久事实,也无需在每个 HTTP 请求之后删除我的 1K 临时事实。这是我用来序列化我的 KieSession
的代码:
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();
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
我在方法 marshall
中收到以下异常:
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]
我遇到了哪些尚不支持的用例?谢谢。
解决方法
它根本没有为 CompositeDefaultAgenda
实现,而 CompositeDefaultAgenda
被 MultithreadEvaluationOption.YES
使用。因此,将其设置为 MultithreadEvaluationOption.NO
可以解决问题。
有趣的是,使用我的永久事实(我不想每次都重新插入)从 byte[]
反序列化到 KieSession
比缓存 {{1} },每次都生成一个新的 KieBase
并插入这些永久事实。