Spring boot集成Drools规则引擎

r囧r小猫 2022-03-08 10:50 669阅读 0赞

**因公司项目业务需求，所以考虑了下集成规则引擎,最终考虑使用Drools规则引擎。所以此次学习使用了SpringBoot结合Drools7.14.0.Final版本**

**- Drools引入依赖jar包**

<dependency>
        <groupId>org.drools</groupId>
        <artifactId>drools-core</artifactId>
        <version>7.14.0.Final</version>
    </dependency>
    <dependency>
        <groupId>org.kie</groupId>
        <artifactId>kie-spring</artifactId>
        <version>7.14.0.Final</version>
    </dependency>

**- 创建代码配置类**

@Configuration
    public class DroolsAutoConfiguration {
        private static final String RULES_PATH = "rules/";
    
        @Bean
        @ConditionalOnMissingBean(KieFileSystem.class)
        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();
            return resourcePatternResolver.getResources("classpath*:" + RULES_PATH + "**/*.*");
        }
    
        @Bean
        @ConditionalOnMissingBean(KieContainer.class)
        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());
        }
    
    
        @Bean
        @ConditionalOnMissingBean(KieBase.class)
        public KieBase kieBase() throws IOException {
            return kieContainer().getKieBase();
        }
    
        @Bean
        @ConditionalOnissingBean(KieSession.class)
        public KieSession kieSession() throws IOException {
            KieSession kieSession = kieContainer().newKieSession();
            return kieSession;
        }
    
        @Bean
        @ConditionalOnMissingBean(KModuleBeanFactoryPostProcessor.class)
        public KModuleBeanFactoryPostProcessor kiePostProcessor() {
            return new KModuleBeanFactoryPostProcessor();
        }
        public KieServices getKieServices() {
            System.setProperty("drools.dateformat","yyyy-MM-dd");
            return KieServices.Factory.get();
        }
    }

基本环境已经搭建好了，接下来我们一起来学习Drools了

*  **创建规则文件**  
    Drools的规则文件是以\*.drl结尾的文件，我们来看一个最简单的规则文件中都是包含什么。  
    通常来说，我们会把规则文件放在resources资源文件夹下，这里呢我们在resources文件夹下新建一个rules文件夹，然后再新建一个HelloWord.drl文件

package rules;
    import cn.org.entity.User;
    import java.lang.String;
    import java.util.List;
    
    rule "hello,word"
        when
            eval(true)
        then
            System.err.println("hello,word!");
    end

规则文件，就是我们新建的这个HelloWord.drl可以理解为一个Java类

1.  package，这个跟Java中的包名是差不多的
2.  import，此文件中需要的类。
3.  rule，可以理解为给这个规则起的一个名字，一个规则文件中可以包含多个rule。
4.  when，when下面可以放置一些条件判断的表达式以及定义一些变量什么的。如果里面内容为空的话则会默认添加一个eval(true)代表一个为true的表达式
5.  then，当when下面的表达式为true是then下方的代码才会执行，在这里可以直接编写Java代码（代码所需要的类通过import引入），当然也可以使用when模块定义的一些变量
6.  end 代表规则hello,word的结束。

\*\*

*  Java调用Drools引擎规则

\*\*  
新建一个测试类DroolsApplicationHelloWordTests

@RunWith(SpringRunner.class)
    @SpringBootTest
    public class DroolsApplicationHelloWordTests {
    
        @Autowired
        KieSession kieSession;
    
    }

注入的kieSession对象就是Drools最常用的一个对象了，通过它可以直接操作在配置类kieFileSystem方法中加载的所有的规则文件

*  **编写测试代码**

@Test
    public void testHelloWord() {
        kieSession.fireAllRules();
    }

kieSession.fireAllRules方法是执行所有的规则，在运行了这个测试方法之后我们应该就可以看到控制台打印的一句hello,word!了

*  **向规则文件传参,在entity包下新增一个User的实体类**

public class User {
        private String name;
        private int age;
    
        public User(String name, int age) {
            this.name = name;
            this.age = age;
        }
        //省略getter，setter
    }

*  **在hello,word规则下方再次新建一个规则user**

rule "user"
        when
          $u:User(name=="张三",age==18)
        then
            $u.setName("李四");
            System.err.println("hello,word："+$u.getName());
    end

注： u : U s e r ( n a m e = = “ 张 三 ” , a g e = = 18 ) 的 意 思 就 是 当 存 在 一 个 u s e r 对 象 ， 并 且 它 的 n a m e 属 性 等 于 张 三 a g e 等 于 18 时 就 把 这 个 对 象 赋 值 给 u:User(name==“张三”,age==18)的意思就是当存在一个user对象，并且它的name属性等于张三age等于18时就把这个对象赋值给 u:User(name==“张三”,age==18)的意思就是当存在一个user对象，并且它的name属性等于张三age等于18时就把这个对象赋值给u。在下方的then模块，如果上方的条件成立时就把$u的name属性更新一下，然后打印。

*  **编写测试代码**

@Test
        public void testOneRule() {
            User user=new User("张三",18);
            kieSession.insert(user);
            kieSession.fireAllRules(new RuleNameEndsWithAgendaFilter("user"));
        }