Redian新闻
>
Spring Boot + 规则引擎Drools,强!

Spring Boot + 规则引擎Drools,强!

公众号新闻

点击上方“芋道源码”,选择“设为星标

管她前浪,还是后浪?

能浪的浪,才是好浪!

每天 10:33 更新文章,每天掉亿点点头发...

源码精品专栏

 
来源:JAVA旭阳

现在有这么个需求,网上购物,需要根据不同的规则计算商品折扣,比如VIP客户增加5%的折扣,购买金额超过1000元的增加10%的折扣等,而且这些规则可能随时发生变化,甚至增加新的规则。面对这个需求,你该怎么实现呢?难道是计算规则一变,就要修改业务代码,重新测试,上线吗。

其实,我们可以通过规则引擎来实现,Drools 就是一个开源的业务规则引擎,可以很容易地与 spring boot 应用程序集成,那本文就用Drools来实现一下上面说的需求吧。

引入依赖

我们创建一个spring boot应用程序,pom中添加drools相关的依赖,如下:

<dependency>
  <groupId>org.drools</groupId>
  <artifactId>drools-core</artifactId>
  <version>7.59.0.Final</version>
</dependency>
<dependency>
  <groupId>org.drools</groupId>
  <artifactId>drools-compiler</artifactId>
  <version>7.59.0.Final</version>
</dependency>
<dependency>
  <groupId>org.drools</groupId>
  <artifactId>drools-decisiontables</artifactId>
  <version>7.59.0.Final</version>
</dependency>

基于 Spring Boot + MyBatis Plus + Vue & Element 实现的后台管理系统 + 用户小程序,支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能

  • 项目地址:https://github.com/YunaiV/ruoyi-vue-pro
  • 视频教程:https://doc.iocoder.cn/video/

Drools配置类

创建一个名为DroolsConfig的配置 java 类。

@Configuration
public class DroolsConfig {
    // 制定规则文件的路径
    private static final String RULES_CUSTOMER_RULES_DRL = "rules/customer-discount.drl";
    private static final KieServices kieServices = KieServices.Factory.get();

    @Bean
    public KieContainer kieContainer() {
        KieFileSystem kieFileSystem = kieServices.newKieFileSystem();
        kieFileSystem.write(ResourceFactory.newClassPathResource(RULES_CUSTOMER_RULES_DRL));
        KieBuilder kb = kieServices.newKieBuilder(kieFileSystem);
        kb.buildAll();
        KieModule kieModule = kb.getKieModule();
        KieContainer kieContainer = kieServices.newKieContainer(kieModule.getReleaseId());
        return kieContainer;
    }
}
  • 定义了一个 KieContainerSpring BeanKieContainer用于通过加载应用程序的/resources文件夹下的规则文件来构建规则引擎。
  • 创建KieFileSystem实例并配置规则引擎并从应用程序的资源目录加载规则的 DRL 文件。
  • 使用KieBuilder实例来构建 drools 模块。我们可以使用KieSerive单例实例来创建 KieBuilder 实例。
  • 最后,使用 KieService 创建一个 KieContainer 并将其配置为 spring bean

基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 实现的后台管理系统 + 用户小程序,支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能

  • 项目地址:https://github.com/YunaiV/yudao-cloud
  • 视频教程:https://doc.iocoder.cn/video/

添加业务Model

创建一个订单对象OrderRequest,这个类中的字段后续回作为输入信息发送给定义的drools规则中,用来计算给定客户订单的折扣金额。

@Getter
@Setter
public class OrderRequest {
    /**
     * 客户号
     */

    private String customerNumber;
    /**
     * 年龄
     */

    private Integer age;
    /**
     * 订单金额
     */

    private Integer amount;
    /**
     * 客户类型
     */

    private CustomerType customerType;
}

此外,定义一个客户类型CustomerType 的枚举,规则引擎会根据该值计算客户订单折扣百分比,如下所示。

public enum CustomerType {
    LOYAL, NEW, DISSATISFIED;

    public String getValue() {
        return this.toString();
    }
}

最后,创建一个订单折扣类 OrderDiscount ,用来表示计算得到的最终的折扣,如下所示。

@Getter
@Setter
public class OrderDiscount {

    /**
     * 折扣
     */

    private Integer discount = 0;
}

我们将使用上述响应对象返回计算出的折扣。

定义drools 规则

前面的DroolsConfig类中指定drools规则的目录,现在我们在/src/main/resources/rules目录下添加customer-discount.drl文件,在里面定义对应的规则。

这个drl文件虽然不是java文件,但还是很容易看懂的。

  • 我们使用了一个名为orderDiscount 的全局参数,可以在多个规则之间共享。关注工众号:码猿技术专栏,回复关键词:1111 获取阿里内部java性能调优手册!
  • drl 文件可以包含一个或多个规则。我们可以使用mvel语法来指定规则。此外,每个规则使用rule关键字进行描述。
  • 每个规则when-then语法来定义规则的条件。
  • 根据订单请求的输入值,我们正在为结果添加折扣。如果规则表达式匹配,每个规则都会向全局结果变量添加额外的折扣。

完整的规则源码如下:

import com.alvin.drools.model.OrderRequest;
import com.alvin.drools.model.CustomerType;
global com.alvin.drools.model.OrderDiscount orderDiscount;

dialect "mvel"

// 规则1: 根据年龄判断
rule "Age based discount"
    when
        // 当客户年龄在20岁以下或者50岁以上
        OrderRequest(age < 20 || age > 50)
    then
        // 则添加10%的折扣
        System.out.println("==========Adding 10% discount for Kids/ senior customer=============");
        orderDiscount.setDiscount(orderDiscount.getDiscount() + 10);
end

// 规则2: 根据客户类型的规则
rule "Customer type based discount - Loyal customer"
    when
        // 当客户类型是LOYAL
        OrderRequest(customerType.getValue == "LOYAL")
    then
        // 则增加5%的折扣
        System.out.println("==========Adding 5% discount for LOYAL customer=============");
        orderDiscount.setDiscount(orderDiscount.getDiscount() + 5);
end

rule "Customer type based discount - others"
    when
    OrderRequest(customerType.getValue != "LOYAL")
then
    System.out.println("==========Adding 3% discount for NEW or DISSATISFIED customer=============")
;
    orderDiscount.setDiscount(orderDiscount.getDiscount() + 3);
end

rule "Amount based discount"
    when
        OrderRequest(amount > 1000L)
    then
        System.out.println("==========Adding 5% discount for amount more than 1000$=============")
;
    orderDiscount.setDiscount(orderDiscount.getDiscount() + 5);
end

添加Service层

创建一个名为OrderDiscountService 的服务类,如下:。

@Service
public class OrderDiscountService {

    @Autowired
    private KieContainer kieContainer;

    public OrderDiscount getDiscount(OrderRequest orderRequest) {
        OrderDiscount orderDiscount = new OrderDiscount();
        // 开启会话
        KieSession kieSession = kieContainer.newKieSession();
        // 设置折扣对象
        kieSession.setGlobal("orderDiscount", orderDiscount);
        // 设置订单对象
        kieSession.insert(orderRequest);
        // 触发规则
        kieSession.fireAllRules();
        // 中止会话
        kieSession.dispose();
        return orderDiscount;
    }
}
  • 注入KieContainer实例并创建一个KieSession实例。
  • 设置了一个OrderDiscount类型的全局参数,它将保存规则执行结果。
  • 使用insert()方法将请求对象传递给 drl 文件。
  • 调用fireAllRules()方法触发所有规则。
  • 最后通过调用KieSessiondispose()方法终止会话。

添加Controller

创建一个名为OrderDiscountControllerController类,具体代码如下:

@RestController
public class OrderDiscountController {

    @Autowired
    private OrderDiscountService orderDiscountService;

    @PostMapping("/get-discount")
    public ResponseEntity<OrderDiscount> getDiscount(@RequestBody OrderRequest orderRequest) {
        OrderDiscount discount = orderDiscountService.getDiscount(orderRequest);
        return new ResponseEntity<>(discount, HttpStatus.OK);
    }
}

测试一下

运行 spring boot 应用程序并通过发送客户订单请求 JSON 来访问 REST API 端点。

  • 对于年龄 < 20 且金额 > 1000 的 LOYAL 客户类型,我们应该根据我们定义的规则获得 20% 的折扣。

总结

我们通过drools规则引擎简单实现了这样一个折扣的业务,现在产品经理说要你加一条规则,比如地址是杭州的折扣加10%,你就直接改这个drl文件,其他时间用来摸鱼就好了,哈哈~~。更多关于drools的用法大家可以去官网探索。



欢迎加入我的知识星球,一起探讨架构,交流源码。加入方式,长按下方二维码噢

已在知识星球更新源码解析如下:

最近更新《芋道 SpringBoot 2.X 入门》系列,已经 101 余篇,覆盖了 MyBatis、Redis、MongoDB、ES、分库分表、读写分离、SpringMVC、Webflux、权限、WebSocket、Dubbo、RabbitMQ、RocketMQ、Kafka、性能测试等等内容。

提供近 3W 行代码的 SpringBoot 示例,以及超 4W 行代码的电商微服务项目。

获取方式:点“在看”,关注公众号并回复 666 领取,更多内容陆续奉上。

文章有帮助的话,在看,转发吧。

谢谢支持哟 (*^__^*)

微信扫码关注该文公众号作者

戳这里提交新闻线索和高质量文章给我们。
相关阅读
“伊基稀奇睨”,日威比肩斯科奇和 if else说再见,SpringBoot 这样做参数校验才足够优雅!妥了...还是SpringBoot够牛逼!Shanghai Eases Driving License Process for Deaf DriversSpring breakSpringBoot 插件化开发模式,强烈推荐!Spring Boot 接口加解密,新姿势!SpringBoot 多数据源及事务解决方案SpringBoot + 规则引擎 URule,真的很强!Spring Boot 操作 Redis 的各种实现SpringBoot + Druid,完美监控 MySQL 性能SpringBoot 启动优化实践!最新数据!澳洲巨头们都在高通胀下赚大了!Qantas,WWS,Coles,Kmart,Bunnings...全部利润狂飙!SpringBoot 中的自带工具类,开发效率增加一倍!Spring循环依赖那些事儿(含Spring详细流程图)人工智能与中国菜名使用 Netty+SpringBoot 打造的 TCP 长连接通讯方案SpringBoot 统一功能处理:用户登录权限校验-拦截器、异常处理、数据格式返回字节:SpringBoot 启动流程Agustín Hernández:中美洲建筑背景下的未来主义巨构七律 捶丸愿,望月叹Spring Boot + 规则引擎 URule,太强了!SpringBoot 实现 MySQL 百万级数据量导出并避免 OOM 的解决方案SpringBoot 我随手封装了一个万能的导出excel工具,传什么都能导出别只会 SpringMVC 了!Spring 又官宣了一个更牛逼的替代框架!【周末综艺会6期】Spring Garden Show 和板蓝花儿开SpringBoot 整合 ChatGPT API 项目实战规则引擎深度对比,LiteFlow vs Drools!Spring Boot 实现跨域的 5 种方式,总有一种适合你,建议收藏共济会的沙俄 信仰的颠覆(七十九)Spring Boot |如何让你的 bean 在其他 bean 之前完成加载Spring Boot 如何防护 XSS + SQL 注入攻击 ?终于懂了![电脑] 又见幽绿——W02华擎DESKMINI定制机箱分享!MacBook Pro 13in 2018 A1989 keep rebooting ( screen/battery/othe英国伦敦爱丁堡带孩子游记 Spring 2023一文详解Prompt学习和微调(Prompt Learning & Prompt Tuning)如何调整自己的心态使自己慢老打卡,Goodbye Spring Break公司新入职一位大佬,把SpringBoot项目启动时间从7分钟降到了40秒!
logo
联系我们隐私协议©2024 redian.news
Redian新闻
Redian.news刊载任何文章,不代表同意其说法或描述,仅为提供更多信息,也不构成任何建议。文章信息的合法性及真实性由其作者负责,与Redian.news及其运营公司无关。欢迎投稿,如发现稿件侵权,或作者不愿在本网发表文章,请版权拥有者通知本网处理。