使用 Maven 项目 (KieScanner) 的规则将事件处理设置为 STREAM

Question

我有一个在 .drl 文件中包含规则的 Maven 项目和另一个项目，它是一个 SpringBoot 网络服务器。这些规则可以通过 POST 请求发送到服务器，之后它们被添加到 Maven 项目并可以被激活，就像它们从一开始就在那里一样。

规则是 "noticed" 因为每次提交新规则时我都会更新 Maven 规则项目（通过调用它的 mvn clean install）。

我尝试了很多配置，最多 "logical" 镜头是下面这两个：

第一次尝试：

@Bean
public KieSession kieSession() {
    KieServices ks = KieServices.Factory.get();
    KieContainer kContainer = ks.newKieContainer(ks.newReleaseId("ftn.bsep9","drools-spring-kjar", "0.0.1-SNAPSHOT"));

    KieBaseConfiguration config = ks.newKieBaseConfiguration();
    config.setOption(EventProcessingOption.STREAM);

    KieBase kieBase = kContainer.newKieBase("myKBase", config);
    KieSession kSession = kieBase.newKieSession();

    KieScanner kScanner = ks.newKieScanner(kContainer);
    kScanner.start(10000); // check for rule changes every 10 seconds

    return kSession;
}

...

第 N 次尝试：

@Bean
public KieSession kieSession() {
    KieServices ks = KieServices.Factory.get();
    KieFileSystem kfs = ks.newKieFileSystem();
    KieModuleModel kModule = ks.newKieModuleModel();

    KieBaseModel baseModel = kModule.newKieBaseModel("defaultKieBase")
            .setDefault(true)
            .setEventProcessingMode(EventProcessingOption.STREAM);
    baseModel.newKieSessionModel("defaultKSession")
            .setDefault(true)
            .setClockType(ClockTypeOption.get("pseudo"));

    kfs.writeKModuleXML(kModule.toXML());
    KieBuilder kieBuilder = ks.newKieBuilder( kfs ).buildAll();
    System.out.println("ERRORS: " + kieBuilder.getResults().getMessages(Message.Level.ERROR).size());

    KieContainer kContainer = ks.newKieContainer(ks.newReleaseId(
            "ftn.bsep9","drools-spring-kjar", "0.0.1-SNAPSHOT"));
    KieSession kSession = kContainer.newKieSession();

    KieScanner kScanner = ks.newKieScanner(kContainer);
    kScanner.start(10000); // check for rule changes every 10 seconds

    return kSession;
}

感谢任何帮助，尤其是解释为什么您的代码有效而我的代码无效。 :)

注意： 下面的代码有效，但我不能使用 over window:time(5m) drools 的表达式，因为它需要 STREAM EventProcessing.

@Bean
    public KieSession kieSession() {
        KieServices ks = KieServices.Factory.get();
        KieContainer kContainer = ks.newKieContainer(ks.newReleaseId("ftn.bsep9","drools-spring-kjar", "0.0.1-SNAPSHOT"));
        KieScanner kScanner = ks.newKieScanner(kContainer);
        kScanner.start(10000);
        return kContainer.newKieSession();
}

Answer 1

我终于通过正确设置依赖关系解决了这个问题。我正在使用 kie-ci 和 kie-spring 工件的 6.2.0.Final 版本。我尝试了以下版本：7.7.0、7.2.0、6.5.0 和 6.4.0，但其中 none 有效。

KieSession Bean 正在创建如下：

@Bean
public KieSession kieSession() {
    final KieServices kieServices = KieServices.Factory.get();
    final ReleaseId releaseId = kieServices.newReleaseId(groupId, artifactId, version);
    final KieContainer kieContainer = kieServices.newKieContainer(releaseId);
    final KieSession kieSession = kieContainer.newKieSession();

    final KieScanner kieScanner = kieServices.newKieScanner(kieContainer);
    kieScanner.start(10000);

    log.warn(":) created a KIE Container - returning...");
    return kieSession;
}

包含 KIE 工件版本的 pom.xml 文件的一部分如下：

...
<properties>
    <kie.version>6.2.0.Final</kie.version>
</properties>
...
<dependencies>
...
<dependency>
    <groupId>org.kie</groupId>
    <artifactId>kie-ci</artifactId>
    <version>${kie.version}</version>
</dependency>
<dependency>
    <groupId>org.kie</groupId>
    <artifactId>kie-spring</artifactId>
    <version>${kie.version}</version>
</dependency>
...
</dependencies>

运行 mvn dependency:tree 并检查正在使用哪个版本的 artifacts/projects 对这个过程有帮助。

这是对我有用的 link 到 the complete pom.xml file。从 mvn dependency:tree 生成的依赖树可以找到 ||here||.

使用 Maven 项目 (KieScanner) 的规则将事件处理设置为 STREAM

Set event processing to STREAM with rules from a Maven project (KieScanner)

drools

spring-boot