SpringBoot整合Drools的实现步骤

<properties>
<drools.version>7.14.0.final</drools.version>
</properties>

<!-- drools -->
<dependency>
    <groupid>org.drools</groupid>
    <artifactid>drools-compiler</artifactid>
    <version>${drools.version}</version>
</dependency>

package com.springcloud.blog.admin.config;

import org.kie.api.kiebase;
import org.kie.api.kieservices;
import org.kie.api.builder.*;
import org.kie.api.runtime.kiecontainer;
import org.kie.api.runtime.kiesession;
import org.kie.internal.io.resourcefactory;
import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;
import org.springframework.core.io.resource;
import org.springframework.core.io.support.pathmatchingresourcepatternresolver;
import org.springframework.core.io.support.resourcepatternresolver;

import java.io.ioexception;


@configuration
public class kiasessionconfig {

    private static final string rules_path = "rules/";

    @bean
    public kiefilesystem kiefilesystem() throws ioexception {
        kiefilesystem kiefilesystem = getkieservices().newkiefilesystem();
        for (resource file : getrulefiles()) {
            kiefilesystem.write(resourcefactory.newclasspathresource(rules_path + file.getfilename(), "utf-8"));
        }
        return kiefilesystem;
    }

    private resource[] getrulefiles() throws ioexception {

        resourcepatternresolver resourcepatternresolver = new pathmatchingresourcepatternresolver();
        final resource[] resources = resourcepatternresolver.getresources("classpath*:" + rules_path + "**/*.*");
        return resources;

    }

    @bean
    public kiecontainer kiecontainer() throws ioexception {

        final kierepository kierepository = getkieservices().getrepository();
        kierepository.addkiemodule(new kiemodule() {
            public releaseid getreleaseid() {
                return kierepository.getdefaultreleaseid();
            }
        });

        kiebuilder kiebuilder = getkieservices().newkiebuilder(kiefilesystem());
        kiebuilder.buildall();
        return getkieservices().newkiecontainer(kierepository.getdefaultreleaseid());

    }

    private kieservices getkieservices() {
        return kieservices.factory.get();
    }

    @bean
    public kiebase kiebase() throws ioexception {
        return kiecontainer().getkiebase();
    }

    @bean
    public kiesession kiesession() throws ioexception {
        return kiecontainer().newkiesession();
    }
}

package com.springcloud.blog.admin.drools;

public class people {
    private int sex;

    private string name;

    private string drltype;

    public int getsex() {
        return sex;
    }

    public void setsex(int sex) {
        this.sex = sex;
    }

    public string getname() {
        return name;
    }

    public void setname(string name) {
        this.name = name;
    }

    public string getdrltype() {
        return drltype;
    }

    public void setdrltype(string drltype) {
        this.drltype = drltype;
    }
}

package com.springcloud.blog.admin.drools
import com.springcloud.blog.admin.drools.people
dialect  "java"

rule "man"
    when
        $p : people(sex == 1 && drltype == "people")
    then
        system.out.println($p.getname() + "是男孩");
end

package com.springcloud.blog.base.controller.test.task;

import com.springcloud.blog.admin.blogadminapplication;
import com.springcloud.blog.admin.drools.people;
import org.junit.test;
import org.junit.runner.runwith;
import org.kie.api.kiebase;
import org.kie.api.runtime.kiesession;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.boot.test.context.springboottest;
import org.springframework.test.context.junit4.springrunner;

@runwith(springrunner.class)
@springboottest(classes = blogadminapplication.class, webenvironment = springboottest.webenvironment.random_port)
public class droolsjunittest {

    @autowired
    private kiesession session;

    @test
    public void people() {

        people people = new people();
        people.setname("yc");
        people.setsex(1);
        people.setdrltype("people");
        session.insert(people);//插入
        session.fireallrules();//执行规则
    }


}