drools的简单入门案例场景分析

2022-07-15,,,,

一、背景

最近在学习规则引擎drools,此处简单记录一下drools入门案例

1.drools介绍

drools是一款由jboss组织提供的基于java语言开发的开源规则引擎,可以将复杂且多变的业务规则从硬编码中解放出来,以规则脚本的形式存放在文件或特定的存储介质中(例如存放在数据库中),使得业务规则的变更不需要修改项目代码、重启服务器就可以在线上环境立即生效。

drools官网地址:https://drools.org/

drools源码下载地址:https://github.com/kiegroup/drools
-----------------------------------
drools:概述和入门案例:

二、为什么要学习drools

假设我们存在如下场景
在我们到商店购买衣服的时候,经常会发生这样的事情,购买1件不打折,购买2件打0.98折,购买3件级以上打0.85折。
那么我们在代码中如果要实现上述功能,是不是就需要编写if ... else语句,假设后期规则变了,是不是就需要修改这些if ... else语句,然后程序重新部署。这样是可以实现,但是不够优雅。那么我们是否可以将这些业务规则写入到规则文件中,以后规则变更直接修改规则文件即可?而drools就可以实现这个功能。

三、实现上方这个简单的打折案例

1、引入jar包

<dependencymanagement>
    <dependencies>
        <dependency>
            <groupid>org.drools</groupid>
            <artifactid>drools-bom</artifactid>
            <type>pom</type>
            <version>7.69.0.final</version>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencymanagement>

<dependencies>
    <dependency>
       <groupid>org.drools</groupid>
        <artifactid>drools-compiler</artifactid>
    </dependency>
    <dependency>
        <groupid>org.drools</groupid>
        <artifactid>drools-mvel</artifactid>
    </dependency>
    <dependency>
        <groupid>ch.qos.logback</groupid>
        <artifactid>logback-classic</artifactid>
        <version>1.2.11</version>
    </dependency>
</dependencies>

2、编写kmodule.xml配置文件

此配置文件需要放置在resources/meta-inf目录下。

<kmodule xmlns="http://www.drools.org/xsd/kmodule">
    <!--
        kbase 可以存在多个
        name: 指定kbase的名字,需要是唯一的
        packages: 包名,可以理解为到src/main/resources目录下查找这个包名下的规则文件,多个包使用逗号分割
        default: 当前kbase是否是默认的kbase
    -->
    <kbase name="shop-kabse" packages="com.huan.shop" default="false">
        <!--
            ksession 可以存在多个
            name: 指定ksession 的名字,需要唯一
            defalut: 当前ksession在这个kbase下是否是默认的
            type: 指定当前ksession是否是有状态的 stateless表示是无状态的
        -->
        <ksession name="shop-ksession" default="false" type="stateless"/>
        <ksession name="shop-ksession-stateful" default="false" type="stateful"/>
    </kbase>
</kmodule>

此处我们需要关注一下 kbasepackage的值,这个值需要和规则文件中的package值一致,否则会找不到规则,具体看下方。

3、编写规则文件

1、规则文件的语法

包名,必须放置在第一行
package
// 引入java中的类,需要些全限定名
import
// 定义function ,可选
function  // optional
// 定义 query ,可选
query  // optional
declare   // optional
global   // optional
// rule 关键字 "rule name" 规则的名字
rule "rule name"
    // attributes 属性可选
    when  // 关键字
        // conditions  条件,可为空
    then
        // actions // 匹配后执行的结果
end // 关键字

2、编写规则文件

规则文件的名字无所谓,比如: book-discount.drl

// 包名,必须防止到第一行,这个名字需要和 kbase中package属性的值一致
package com.huan.shop
/**
 * 倒入类
 */
import com.huan.drools.customerorder
// 定义规则
rule "shop-rule-01"
    when
        // 模式匹配:到工作内存中查找customerorder,并且这个对象的purchasequantity值需要是1,
        // 如果条件成立,$order是绑定变量名,一般以$开头,和fact对象区分开
        $order:customerorder(purchasequantity == 1)
    then
        system.out.println("匹配规则 shop-rule-01");
        // 赋值,此处赋值后,在java代码中获取获取到赋值后的值
        $order.setdiscount(1d);
end
rule "shop-rule-02"
    when
        $order:customerorder(purchasequantity == 2)
    then
        system.out.println("匹配规则 shop-rule-02");
        $order.setdiscount(0.98);
end
rule "shop-rule-03"
    when
        $order:customerorder(purchasequantity >= 3)
    then
        system.out.println("匹配规则 shop-rule-03");
        $order.setdiscount(0.85);
end

3、解释一下包名

如果 shop-discount.drl的包名修改为com.huan.shop1则会提示如下警告:

12:43:01.589 [main] warn org.drools.compiler.kie.builder.impl.kiebuilderimpl - file 'com/huan/shop/shop-discount.drl' is in folder 'com/huan/shop' but declares package 'com.huan.shop1'. it is advised to have a correspondance between package and folder names.

四、编写java代码

1、编写一个订单对象

此对象保存的是用户购买了几件衣服和对应的折扣。

/**
 * 客户购买衣服的订单,省略 getter 和 setter 方法
 *
 * @author huan.fu
 * @date 2022/5/12 - 11:27
 */
public class customerorder {
    /**
     * 购买了几件衣服
     */
    private integer purchasequantity;
    /**
     * 最终打多少折
     */
    private double discount;
    public customerorder(integer purchasequantity) {
        this.purchasequantity = purchasequantity;
    }
}

2、编写测试代码

1、无状态测试方法statelesssessiontest规则规则2,即最终打0.98折。
2、有状态测试方法statefulsessiontest规则规则3,即最终打0.85折。

package com.huan.drools;
import org.kie.api.kieservices;
import org.kie.api.event.rule.debugruleruntimeeventlistener;
import org.kie.api.runtime.kiecontainer;
import org.kie.api.runtime.kiesession;
import org.kie.api.runtime.statelesskiesession;
/**
 * drools 测试类
 */
public class droolsapplication {
    public static void main(string[] args) throws interruptedexception {
        // 无状态session测试
        statelesssessiontest();
        // 有状态session测试
        statefulsessiontest();
    }
    private static void statelesssessiontest() {
        // 获取kie services
        kieservices kieservices = kieservices.get();
        // 获取kie容器对象
        kiecontainer kiecontainer = kieservices.getkieclasspathcontainer();
        // 获取kie session , 此处获取的是无状态的session,因为 <ksession name="shop-ksession" default="false" type="stateless"/>
        // 中type="stateless"就是无状态的session
        statelesskiesession kiesession = kiecontainer.newstatelesskiesession("shop-ksession");
        // 创建一个对象,可以理解为 fact对象,即事实对象
        customerorder customerorder = new customerorder(2);
        // 添加监听器,便于观察日志
        kiesession.addeventlistener(new debugruleruntimeeventlistener());
        // 无状态的session只需要执行 execute 方法即可。
        kiesession.execute(customerorder);
        system.err.println("通过规则后,获取到的折扣为:" + customerorder.getdiscount());
    }
    private static void statefulsessiontest() {
        // 获取kie services
        kieservices kieservices = kieservices.get();
        // 获取kie容器对象
        kiecontainer kiecontainer = kieservices.getkieclasspathcontainer();
        // 获取kie session , 此处获取的是有状态的session
        kiesession kiesession = kiecontainer.newkiesession("shop-ksession-stateful");
        // 创建一个对象,可以理解为 fact对象,即事实对象
        customerorder customerorder = new customerorder(3);
        // 添加监听器,便于观察日志
        kiesession.addeventlistener(new debugruleruntimeeventlistener());
        // 将customerorder对象加入到工作内存中
        kiesession.insert(customerorder);
        // 触发所有的规则,如果只想触发指定的规则,则使用fireallrules(agendafilter agendafilter)方法
        kiesession.fireallrules();
        // 有状态的session一定需要调用dispose方法
        kiesession.dispose();
        system.err.println("通过规则后,获取到的折扣为:" + customerorder.getdiscount());
    }
}

此处需要注意有状态session无状态session写法的区别。

五、测试结果

到此,我们使用drools实现的一个简单的案例就实现了。

六、drools引擎的基本组件

1、rules:我们自己定义的业务规则,比如我们自己写的规则文件。所有规则必须至少包含触发规则的条件和规则规定的操作。
2、production memory:规则存储在 drools 引擎中的位置。
3、facts:输入或更改到 drools 引擎中的数据,drools 引擎匹配规则条件以执行适用规则。在规则中修改了fact对象的值,真实的javabean的数据也会发生改变。
比如:当我们调用ksession.insert(对象),那么插入的这个对象就可以理解成facts对象。
4、working memory:facts 在 drools 引擎中存储的位置。
5、pattern matcher:匹配器,将rule base中所有的规则与working memory中的fact对象进行模式匹配,匹配成功的规则将被激活并放入到agenda中。
6、agenda:议程,执行agenda中被激活的排好序的规则。

七、完整代码

https://gitee.com/huan1993/spring-cloud-parent/tree/master/drools/drools-quickstart

八、参考文档

1、https://docs.drools.org/7.69.0.final/drools-docs/html_single/index.html#decision-engine-con_decision-engine

到此这篇关于drools的简单入门案例的文章就介绍到这了,更多相关drools入门案例内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!

《drools的简单入门案例场景分析.doc》

下载本文的Word格式文档,以方便收藏与打印。