规则引擎Drools的应用介绍_F11 - 专业站长和开发者的学习网站

分享到

规则引擎Drools的应用介绍

java 来源：互联网作者：佚名发布时间：2023-06-12 21:49:16 人浏览

摘要

现在有这么个需求，网上购物，需要根据不同的规则计算商品折扣，比如VIP客户增加5%的折扣，购买金额超过1000元的增加10%的折扣等，而且这些规则可能随时发生变化，甚至增加新的规

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

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

引入依赖

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

<groupId>org.drools</groupId>

<artifactId>drools-core</artifactId>

<version>7.59.0.Final</version>

</dependency>

<groupId>org.drools</groupId>

<artifactId>drools-compiler</artifactId>

<version>7.59.0.Final</version>

</dependency>

<groupId>org.drools</groupId>

<artifactId>drools-decisiontables</artifactId>

<version>7.59.0.Final</version>

</dependency>

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;

}

定义了一个 KieContainer的Spring Bean ，KieContainer用于通过加载应用程序的/resources文件夹下的规则文件来构建规则引擎。
创建KieFileSystem实例并配置规则引擎并从应用程序的资源目录加载规则的 DRL 文件。
使用KieBuilder实例来构建 drools 模块。我们可以使用KieSerive单例实例来创建 KieBuilder 实例。
最后，使用 KieService 创建一个 KieContainer 并将其配置为 spring bean。

添加业务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 的全局参数，可以在多个规则之间共享。
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()方法触发所有规则。
最后通过调用KieSession 的dispose()方法终止会话。

添加Controller

创建一个名为OrderDiscountController 的Controller类，具体代码如下：

@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的用法大家可以去官网探索。

您可能感兴趣的文章 :

Java规则引擎Easy Rules的使用

原文链接 :

Tag :

RocketMQ的存储模型全介绍

RocketMQ有Producer、Consumer、NameSrv、Broker四个部分。其中Broker用于存储消息，维护消息队列和订阅关系，是RocketMQ四个部分中最重要的一个部分
规则引擎Drools的应用介绍

现在有这么个需求，网上购物，需要根据不同的规则计算商品折扣，比如VIP客户增加5%的折扣，购买金额超过1000元的增加10%的折扣等，而且
Spring populateBean属性赋值和自动注入

protected void populateBean(String beanName, RootBeanDefinition mbd, @Nullable BeanWrapper bw) { if (bw == null) { if (mbd.hasPropertyValues()) { throw new BeanCreationException( mb
ThreadPoolExecutor参数的用法及说明

一、ThreadPoolExecutor核心参数说明 1、corePoolSize：核心线程数 * 核心线程会一直存活，及时没有任务需要执行 * 当线程数小于核心线程数时，即
springcloud gateway无法路由问题的解决

现在企业微服务架构基本上都是用springcloud体系了，在国内基本上新项目都用springcloud alibaba，而且基本上都是所有服务聚合在一个父项目中
RocketMQ broker 消息投递流程处理PULL_MESSAGE请求解析

RocketMq消息处理整个流程如下：本系列RocketMQ4.8注释github地址，希望对大家有所帮助，要是觉得可以的话麻烦给点一下Star哈消息接收：消息
idea搭建SSM框架遇踩的坑(附完整过程)

首先说明这是我一个不熟悉idea和SSM框架的新手小白遇到的坑，适合用idea搭建SSM框架的小伙伴看一看，老鸟就不用看了。以下为详细步骤（傻
java实现文件夹上传功能的代码(SpringBoot框架)

有时我们后台管理等服务可能会有这样一个简单需求，就是根据文件夹将整个文件夹下的所有资源都上传到我们的服务器上，本人也是搜索
Mybatis批量插入大量数据的最优方式

Mybatis批量插入的方式有三种 1. 普通插入 2. foreach 优化插入 3. ExecutorType.BATCH插入下面对这三种分别进行比较: 1.普通插入默认的插入方式是
手把手教学Win10同时安装两个版本的JDK并随时切换

若是只需要知道如何切换两个JDK的同学，可以直接移步至第三部分一，官网下载两个版本的JDK 官网下载地址：https://www.oracle.com/java/technol

规则引擎Drools的应用介绍

引入依赖

Drools配置类

添加业务Model

定义drools 规则

添加Service层

添加Controller

测试一下

总结

您可能感兴趣的文章 :

RocketMQ的存储模型全介绍

规则引擎Drools的应用介绍

Spring populateBean属性赋值和自动注入

ThreadPoolExecutor参数的用法及说明

springcloud gateway无法路由问题的解决

RocketMQ broker 消息投递流程处理PULL_MESSAGE请求解析

idea搭建SSM框架遇踩的坑(附完整过程)

java实现文件夹上传功能的代码(SpringBoot框架)

Mybatis批量插入大量数据的最优方式

手把手教学Win10同时安装两个版本的JDK并随时切换

Java对象创建的过程及内存布局的介绍

Java基础学习之集合底层原理的介绍

java实现PDF转HTML文档的示例代码

记录Java Log的几种方式

springboot整合RabbitMQ发送短信的实现