java - Drools KModule 持久化配置

Question

我正在尝试设置一个具有持久性的kmodule。我在内部使用 guice，所以 spring 示例对我来说不是很有帮助。

我当前的设置如下:

• 我有一个管理我的 session 的核心项目
• 我还有多个其他项目通过 META-INF/kmodule.xml 文件贡献 session

这工作正常，但是我只是以编程方式完成了此操作(设置环境的 EntityManager 和 TransactionManager)。现在我想在 kmodule 中拥有此配置，以便模块本身可以定义它们是否想要持久化。

问题是，我不知道如何为此创建 session ，也不知道如何配置模块。例如，我能找到的最简单的代码片段如下所示:

<kmodule
        xmlns="http://jboss.org/kie/6.0.0/kmodule">

    <kbase name="kbase1">
        <ksession name="ksession1"/>
    </kbase>

</kmodule>

此时 session 创建如下:

    KieServices ks = KieServices.Factory.get();
    KieContainer kContainer = ks.getKieClasspathContainer();
    KieSession kSession = kContainer.newKieSession(name);

但是，如何在模块中配置持久性，或者如果不可能，如何在编程设置中传递正确的 session 名称。我所拥有的是:

        // Guice inject Entitymanager and TransactionManager and setup the Environment variable env
        KieSessionConfiguration ksconf = ks.newKieSessionConfiguration();
        ksconf.setOption(ClockTypeOption.get("realtime"));
        JPAKnowledgeService.newStatefulKnowledgeSession(kbase, ksconf, env);

我在想也许有一种方法可以通过 KieSessionConfiguraton 将 session 名称传递给 JPAKnowledgeService 类，但我似乎找不到任何方法。

或者，在 kmodule 本身中配置它会更酷。我可以使用 Spring 方法，但我有点怀疑注入(inject)会像那样工作。据我所知， Spring 的后处理器会进行持久性注入(inject)。我不认为即使我提供了 guice 也能做到这一点？

谢谢

Answer 1

所以我研究了它并挖掘了很多令人流口水的代码来尝试解决这个问题。

KieContainer#newSession 所做的就是查询模型，然后向基础请求一个具有 session 配置的新 session :

public KieSession newKieSession(String kSessionName, Environment environment, KieSessionConfiguration conf) {
    KieSessionModelImpl kSessionModel = (KieSessionModelImpl) getKieSessionModel(kSessionName);
    if ( kSessionModel == null ) {
        log.error("Unknown KieSession name: " + kSessionName);
        return null;
    }
    if (kSessionModel.getType() == KieSessionModel.KieSessionType.STATELESS) {
        throw new RuntimeException("Trying to create a stateful KieSession from a stateless KieSessionModel: " + kSessionName);
    }
    KieBase kBase = getKieBase( kSessionModel.getKieBaseModel().getName() );
    if ( kBase == null ) {
        log.error("Unknown KieBase name: " + kSessionModel.getKieBaseModel().getName());
        return null;
    }

    KieSession kSession = kBase.newKieSession( conf != null ? conf : getKnowledgeSessionConfiguration(kSessionModel), environment );
    wireListnersAndWIHs(kSessionModel, kSession);
    registerLoggers(kSessionModel, kSession);
    kSessions.put(kSessionName, kSession);
    return kSession;
}

同时，这也正是 StoreService 实现所做的事情，使用一些高级的哈利波特代码来使事情持久化。然而，它忽略了 session 的配置，我几乎会说这是一个错误..(可能会在此之后提出一个)

无论如何，KieContainer 创建的配置只考虑 2 个选项:

private KieSessionConfiguration getKnowledgeSessionConfiguration(KieSessionModelImpl kSessionModel) {
    KieSessionConfiguration ksConf = KnowledgeBaseFactory.newKnowledgeSessionConfiguration();
    ksConf.setOption( kSessionModel.getClockType() );
    ksConf.setOption( kSessionModel.getBeliefSystem() );
    return ksConf;
}

这意味着，我有两个选择来解决这个问题:

要么编写我自己的 KieContainerImpl 来执行正确的操作(为什么要麻烦...)，要么模拟 session 配置。我决定做第二个。

public KieSession createJPASession(final String kieBaseId, Optional<String> clockType, Optional<String> beliefSystem) {
    log.info(String.format("Creating JPA Session for kieBase %s, clockType %s, beliefSystem %s", kieBaseId, clockType, beliefSystem));
    KieBase kieBase = kContainer.getKieBase(kieBaseId);
    KieSessionConfiguration ksConf = ks.newKieSessionConfiguration();

    // Set this thing up manually. Looking at the impl/docs these are the only two options available to set.
    // The Storage service will remove those options from a default session for whatever reason, however we can set this manually
    // This means we can use the base configuration and have things run in a normal way

    if (clockType.isPresent()) {
        ksConf.setOption(ClockTypeOption.get(clockType.get()));
    }
    if (beliefSystem.isPresent()) {
        ksConf.setOption(BeliefSystemTypeOption.get(beliefSystem.get()));
    }

    KieSession jpaSession = ks.getStoreServices().newKieSession(kieBase, ksConf, env);
    sessions.put(jpaSession.getIdentifier(), jpaSession);
    return jpaSession;
}

最后一个代码片段将创建配置的 session ，同时使其持久化。

或者，通过将 KieContainer 转换为 KieContainerImpl，可以访问查询 KieModule 中的 KieSession 对象所需的公共(public)方法。 (这是很多 Kie 的)这样人们就可以使用相同的方法并访问 XML 配置。我的方法是混合使用(使用 KieBase/Module 的 xml 配置，同时以编程方式设置信念系统和时钟类型)。原因是我不想依赖内部实现，也不想费心实现我自己的 KieContainer 并将其连接起来。

我希望这可以帮助别人。如果其他人知道“正确”的方法，请发布。