Drools-多个请求的相同KieSession

Question

我在项目中使用drools 6.3.0。我有大约3000条规则，分为两类。比如，类别1有1500条规则，类别2有1500条规则。有2万份订单具有不同的数据。每个订单都有一组不同的属性。现在，为每个请求创建kiesession需要时间，而且速度非常慢。因此，计划使用相同的kiesession执行所有订单，订单将使用多线程处理。

以下是我目前的做法。

 KieBase kieBase = null;
 KieServices kieServices = KieServices.Factory.get();
 KieRepository kieRepository = kieServices.getRepository();
        kieRepository.addKieModule(new KieModule() {
            @Override
            public ReleaseId getReleaseId() {
                return kieRepository.getDefaultReleaseId();
            }
        });

 KieFileSystem kfs = kieServices.newKieFileSystem();

 kfs.write(******);  // Load 3k rules in a for loop
 KieBuilder kb = kieServices.newKieBuilder(kfs);
            kb.buildAll();
 KieContainer kContainer = kieServices.newKieContainer(kieRepository.getDefaultReleaseId());
 kieBase = kContainer.getKieBase();

 kContainer = kieServices.newKieContainer(kieRepository.getDefaultReleaseId());
            kieBase = kContainer.getKieBase();
 KieSession kieSession = kieBase.newKieSession();

这就是我创建kiesession的方式，我想将此kiesession用于所有订单执行。

我想使用线程池并行执行订单。

这就是

//这里的条目基于类别和一些id。每个规则都有id和类别。对于每个id和类别，都有一组需要评估的规则。

流程就像，

1） 从DB获取20k个订单2）对于每个订单，获取要执行的id 3）对于每个id，设置入口点格式，如<代码>入口=id \u类别

4） 插入订单属性数据和fireRules。

final EntryPoint entryPoint = ksession.getEntryPoint(entry);
        if (entryPoint != null) {
            entryPoint.insert(data);
            ksession.fireAllRules();
        } else {
            log.warn("No rules to be executed");
        }

现在，由于我必须并行执行命令，

每个订单将并行调用以下代码，

entryPoint.insert(data);
ksession.fireAllRules();

由于每个订单都有不同的属性，并向入口点插入不同的数据，因此会导致问题，无法获得预期的结果。

有没有办法实现这一点？

谢谢

Answer 1

也许你应该使用原型会话。在K模块中。xml文件添加：

<ksession name="YourSessionName" type="stateful" default="false" clockType="realtime" scope="prototype"/>

Answer 2

我不是一个超级专家，但我正在研究类似的问题，我认为答案是要么将这些调用放入同步块中。。。它实际上根本不是并行执行，或者使用无状态KieSession，它将创建一个常规的KieSession，它将使用自己的工作内存在execute调用的本地，因此它将只包含您传入的数据对象。执行（…） 。

令人惊讶的是，与重用单个常规会话并在触发规则之间清除其中的对象相比，使用无状态会话似乎并不花费太多时间。