Java规则引擎Drools急速入门
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Java规则引擎Drools急速入门相关的知识,希望对你有一定的参考价值。
文章目录
- 1.Drools规则引擎简介
- 2.Drools API开发步骤
- 3.SpringBoot整合Drools案例
- 4.Drools基础语法
- 5.Drools条件语法部分
- 6.Drools结果操作部分
- 7.Drools内置属性部分
- 8.Drools高级语法部分
1.Drools规则引擎简介
(1)什么是规则引擎
全称为业务规则管理系统,英⽂名为BRMS(即 Business Rule Management System)。规则引擎的主要思想是将应用程序中的业务决策部分分离出来,并使用预定义的语义模块编写业务决策(业务规则),由用户或开发者在需要时进行配置、管理。 需要注意的是规则引擎并不是一个具体的技术框架,而是指的⼀类系统,即业务规则管理系统。
目前市面上具体的规则引擎产品有:drools、VisualRules、iLog等,使用最为广泛并且开源的是Drools。
规则引擎实现了将业务决策从应用程序代码中分离出来,接收数据输入,解释业务规则,并根据业务规则做出业务决策。规则引擎其实就是一个输入输出的平台。
(2)规则引擎主要的应用场景
- 风险控制系统----风险贷款、风险评估
- 反欺诈项目----银行贷款、征信验证
- 决策平台系统----财务计算
- 促销平台系统----满减、打折、加价购
(3)Drools介绍
Drools是⼀款由JBoss组织提供的基于Java语⾔开发的开源规则引擎,可以将复杂且多变的业务规则从硬编码中解放出来,以规则脚本的形式存放在⽂件或特定的存储介质中(例如存放在数据库中),使得业务规则的变更不需要修改项目代码、不⽤重启服务器就可以在线上环境立即生效。
Drools官网地址:https://drools.org/
drools源码下载地址:https://github.com/kiegroup/drools
(4)使用规则引擎能解决什么问题
- 硬编码实现业务规则难以维护
- 硬编码实现业务规则难以应对变化
- 业务规则发⽣变化需要修改代码,重启服务后才能生效
(5)使用规则引擎的优势
- 业务规则与系统代码分离,实现业务规则的集中管理
- 在不重启服务的情况下可随时对业务规则进行扩展和维护
- 可以动态修改业务规则,从⽽快速响应需求变更
- 规则引擎是相对独立的,只关心业务规则,使得业务分析⼈员也可以参与编辑、维护系统的业务规则
- 减少了硬编码业务规则的成本和风险
- 使用规则引擎提供的规则编辑工具,使复杂的业务规则实现变得的简单
2.Drools API开发步骤
我们在操作Drools时经常使用的API以及它们之间的关系如下图:
Kie全称为Knowledge Is Everything,即“知识就是一切”的缩写,是Jboss一系列项目的总称。
规则引擎构成
drools规则引擎由以下三部分组成:
- Working Memory(工作内存)
- Rule Base(规则库)
- Inference Engine(推理引擎)
其中Inference Engine(推理引擎)又包括:
● Pattern Matcher(匹配器) 具体匹配哪⼀个规则,由这个完成
● Agenda(议程)
● Execution Engine(执行引擎)
相关概念说明
- **Working Memory:**工作内存,drools规则引擎会从Working Memory中获取数据和规则文件中定义的规则进行模式匹配,所以我们开发的应用程序只需要我们的数据插入到Working Memory中即可。
- **Fact:**事实,是指在drools规则应用中,将一个普通的JavaBean插入到Working Memory后的对象就是Fact对象。
- **Rule Base:**规则库,我们在规则文件中定义的规则都会被加载到规则库中。
- **Pattern Matcher:**匹配器,将Rule Base中的所有规则与Working Memory中的Fact对象进行模式匹配,匹配成功的规则将被激活并放入Agenda中。
- **Agenda:**议程,用于存放通过匹配器进行模式匹配后被激活的规则。
- **Execution Engine:**执行引擎,执行Agenda中被激活的规则。
规则引擎执行过程
3.SpringBoot整合Drools案例
(1)案例背景
某电商平台的促销活动,活动规则是根据⽤户购买订单的⾦额给⽤户送相应的积分,购买的越多送的积分越多
用户购买的金额和对应送多少积分的规则如下:
100元以下, 不加分
100元-500元 加100分
500元-1000元 加500分
1000元 以上 加1000分
按照常理,作为一个工作一两年的开发工程师来说,这不是分分钟搞定的事情,直接上午开发,下午提测。
/**
* 设置订单积分
*/
public void setOrderPoint(Order order)
if (order.getAmout() <= 100)
order.setScore(0);
else if(order.getAmout() > 100 && order.getAmout() <= 500)
order.setScore(100);
else if(order.getAmout() > 500 && order.getAmout() <= 1000)
order.setScore(500);
else
order.setScore(1000);
但是,假如说现在产品经理不想100元以下不送积分了,想要200元以下不送金额了,是不是又要重新改代码了。所以Drools帮我们解决在不改动原有代码的情况下修改规则的信息。
(2)创建Maven项目,加入SpringBoot依赖
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.5.12</version>
<relativePath/>
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
(3)resources下创建yml配置文件
server:
port: 8888
spring:
application:
name: drools-server
(4)创建SpringBoot启动主类
@SpringBootApplication
public class DroolsApplication
public static void main(String[] objArgs)
SpringApplication.run(DroolsApplication.class, objArgs);
(5)添加单元测试依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
(6)添加Drools和lombok依赖
<!--drools规则引擎-->
<dependency>
<groupId>org.drools</groupId>
<artifactId>drools-core</artifactId>
<version>7.6.0.Final</version>
</dependency>
<dependency>
<groupId>org.drools</groupId>
<artifactId>drools-compiler</artifactId>
<version>7.6.0.Final</version>
</dependency>
<dependency>
<groupId>org.drools</groupId>
<artifactId>drools-templates</artifactId>
<version>7.6.0.Final</version>
</dependency>
<dependency>
<groupId>org.kie</groupId>
<artifactId>kie-api</artifactId>
<version>7.6.0.Final</version>
</dependency>
<dependency>
<groupId>org.kie</groupId>
<artifactId>kie-spring</artifactId>
<version>7.6.0.Final</version>
</dependency>
<!--添加lombok-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.20</version>
<scope>compile</scope>
</dependency>
(7)创建订单实体类Order
/**
* @description 订单实体类
* @author lixiang
*/
@Data
public class Order
/**
* 订单金额
*/
private int amount;
/**
* 积分
*/
private int score;
(8)创建规则⽂件/resources/rules/score-rules.drl
package rules
import com.lixiang.domain.Order
//规则1:100元以下, 不加积分
rule "score_1"
when
$s : Order(amount <= 100)
then
$s.setScore(0);
System.out.println("消费100元以下, 不加积分 ");
end
//规则2:100元-500元 加100积分
rule "score_2"
when
$s : Order(amount > 100 && amount <= 500)
then
$s.setScore(100);
System.out.println("消费100元-500元 加100积分 ");
end
//规则3:500元-1000元 加500积分
rule "score_3"
when
$s : Order(amount > 500 && amount <= 1000)
then
$s.setScore(500);
System.out.println("消费500元-1000元 加500积分 ");
end
//规则4:1000元 以上 加1000积分
rule "score_4"
when
$s : Order(amount > 1000)
then
$s.setScore(1000);
System.out.println("消费1000元 以上 加1000积分 ");
end
(9)创建DroolsConfig配置类
/**
* @author lixiang
* @description Drools规则引擎配置类
*/
@Configuration
public class DroolsConfig
/**
* 定义规则路径
*/
private static final String RULES_PATH = "rules/";
private final KieServices kieServices = KieServices.Factory.get();
/**
* 获取规则文件
* @return
* @throws IOException
*/
@Bean
@ConditionalOnMissingBean
public KieFileSystem kieFileSystem() throws IOException
KieFileSystem kieFileSystem = kieServices.newKieFileSystem();
ResourcePatternResolver resourcePatternResolver = new PathMatchingResourcePatternResolver();
Resource[] files = resourcePatternResolver.getResources("classpath*:" + RULES_PATH + "*.*");
String path;
for (Resource file : files)
path = RULES_PATH + file.getFilename();
kieFileSystem.write(ResourceFactory.newClassPathResource(path, "UTF-8"));
return kieFileSystem;
/**
* 创建Kie容器
* @return
* @throws IOException
*/
@Bean
@ConditionalOnMissingBean
public KieContainer kieContainer() throws IOException
KieRepository kieRepository = kieServices.getRepository();
kieRepository.addKieModule(kieRepository::getDefaultReleaseId);
KieBuilder kieBuilder = kieServices.newKieBuilder(kieFileSystem());
kieBuilder.buildAll();
return kieServices.newKieContainer(kieRepository.getDefaultReleaseId());
@Bean
@ConditionalOnMissingBean
public KieBase kieBase() throws IOException
return kieContainer().getKieBase();
@Bean
@ConditionalOnMissingBean
public KModuleBeanFactoryPostProcessor kiePostProcessor()
return new KModuleBeanFactoryPostProcessor();
(10)编写测试类
@SpringBootTest
public class DroolsTest
@Autowired
private KieBase kieBase;
@Test
public void droolsTest()
Order order = new Order();
order.setAmount(200);
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
kieSession.insert(order);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
System.out.println("订单金额:"+order.getAmount()+",订单积分:"+order.getScore());
4.Drools基础语法
(1)规则文件的构成
drl是Drools Rule Language的缩写。在规则⽂件中编写具体的规则内容。
⼀套完整的规则文件内容构成如下:
- package:包名,package对应的不⼀定是真正的目录,可以任意写com.abc,同⼀个包下的drl文件可以相互访问
- import:用于导入类或者静态方法
- global:全局变量
- function:自定义函数
- query:查询
- rule end:规则体
(2)规则体语法构成
一个规则通常包括三个部分:属性部分(attribute)、条件部分(LHS)和结果部分(RHS)
rule "ruleName" //rule关键字,表示规则开始,参数为规则的唯⼀名称
attributes //规则属性,是rule与when之间的参数,为可选项
when //关键字,后⾯是规则的条件部分
LHS //Left Hand Side,是规则的条件部分
then //后⾯跟规则的结果部分
RHS //是规则的结果或⾏为
end //表示⼀个规则的结束
5.Drools条件语法部分
LHS(Left Hand Side):是规则的条件部分的通⽤名称。它由零个或多个条件元素组成。如果LHS为空,则它将被视为始终为true的条件元素。
(1)约束连接
- 在 LHS 当中,可以包含 0~n 个条件,多个pattern之间可以采⽤“&&” (and) 、 “||”(or)和“,”(and)来实现,也可以不写,默认连接为and。
rule "rule1"
when
$s : Order(amout > 100 && amout <= 500)
then
$s.setScore(100);
System.out.println("成功匹配到规则:100元-500元 加100积分 ");
end
- 测试代码
@Test
public void test1()
Order order = new Order();
order.setAmount(200);
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
kieSession.insert(order);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
(2)比较运算符
- 在 Drools当中共提供了⼗⼆种类型的⽐较操作符, 分别是: >、 >=、 <、 <=、 = =、 !=、contains、 not contains、memberof、not memberof、matches、not matches;在这⼗⼆种类型的比较操作符当中,前六个是⽐较常⻅也是⽤的⽐较多的⽐较操作符。
符号 | 说明 |
> | 大于 |
< | 小于 |
>= | 大于等于 |
<= | 小于等于 |
== | 等于 |
!= | 不等于 |
contains | 检查一个Fact对象的某个属性值是否包含一个指定的对象值 |
not contains | 检查⼀个Fact对象的某个属性值是否不包含⼀个指定的对象值 |
memberOf | 判断⼀个Fact对象的某个属性是否在⼀个或多个集合中 |
not memberOf | 判断⼀个Fact对象的某个属性是否不在⼀个或多个集合中 |
matches | 判断⼀个Fact对象的属性是否与提供的标准的Java正则表达式进⾏匹配 |
not matches | 判断⼀个Fact对象的属性是否不与提供的标准的Java正则表达式进⾏匹配 |
验证:
- 创建订单项实体类
/**
* @description 订单项
* @author lixiang
*/
@Data
public class OrderItem
/**
* 订单项名称
*/
private String name;
/**
* 订单项金额
*/
private int amount;
- 订单中加入订单项集合
/**
* @description 订单实体类
* @author lixiang
*/
@Data
public class Order
/**
* 订单金额
*/
private int amount;
/**
* 积分
*/
private int score;
List<OrderItem> orderItemList;
- 测试contains 规则
规则文件内容:
//测试contains规则
rule "rule1"
when
$orderItem:OrderItem();
$order:Order(orderItemList contains $orderItem);
then
System.out.println("测试 contains 规则触发:"+$order.getOrderItemList());
end
//java测试代码
@Test
public void test2()
Order order = new Order();
order.setAmount(200);
OrderItem orderItem = new OrderItem();
List<OrderItem> orderItemList = new ArrayList<>();
orderItemList.add(orderItem);
order.setOrderItemList(orderItemList);
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
kieSession.insert(order);
kieSession.insert(orderItem);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
- 测试not contains 规则
规则文件内容:
//测试not contains规则
rule "rule1"
when
$orderItem:OrderItem();
$order:Order(orderItemList contains $orderItem);
then
System.out.println("测试not contains 规则触发:"+$order.getOrderItemList());
end
//java测试代码
@Test
public void test3()
Order order = new Order();
order.setAmount(200);
OrderItem orderItem = new OrderItem();
List<OrderItem> orderItemList = new ArrayList<>();
orderItemList.add(orderItem);
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
kieSession.insert(order);
kieSession.insert(orderItem);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
- 测试matches规则
规则文件内容:
//测试⽐较操作符matches
rule "rule3"
when
OrderItem(name matches "订单*")
then
System.out.println("测试⽐较操作符matches触发...");
end
//java测试代码
@Test
public void test3()
OrderItem orderItem = new OrderItem();
orderItem.setName("订单项1");
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
kieSession.insert(orderItem);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("rule3"));
//关闭会话
kieSession.dispose();
- 测试not matches规则
规则文件内容:
//测试⽐较操作符not matches
rule "rule4"
when
OrderItem(name not matches "订单1.*")
then
System.out.println("测试⽐较操作符not matches触发...");
end
//java测试代码
@Test
public void test3()
OrderItem orderItem = new OrderItem();
orderItem.setName("订单项1");
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
kieSession.insert(orderItem);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("rule4"));
//关闭会话
kieSession.dispose();
- 测试memberOf规则
规则文件内容:
//测试⽐较操作符memberOf
rule "rule5"
when
Order(orderItemList memberOf list)
then
System.out.println("测试⽐较操作符memberOf触发...");
end
//java测试代码
@Test
public void test4()
Order order = new Order();
OrderItem orderItem = new OrderItem();
List<OrderItem> orderItemList = new ArrayList<>();
orderItemList.add(orderItem);
order.setOrderItemList(orderItemList);
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
kieSession.insert(order);
kieSession.insert(orderItem);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("rule5"));
//关闭会话
kieSession.dispose();
- 测试not memberOf规则
规则文件内容:
//测试⽐较操作符memberOf
rule "rule6"
when
$orderItem:OrderItem();
Order($orderItem not memberOf orderItemList);
then
System.out.println("测试⽐较操作符not memberOf触发...");
end
@Test
public void test4()
Order order = new Order();
OrderItem orderItem = new OrderItem();
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
kieSession.insert(order);
kieSession.insert(orderItem);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("rule6"));
//关闭会话
kieSession.dispose();
6.Drools结果操作部分
在Drools当中,在RHS里面,提供了一些对当前Working Memory实现快速操作的宏函数或对象,比如insert/insertLogical、update和retract就可以实现对当前Working Memory中的Fact对象进行新增、删除或者是修改。
(1)insert/insertLogical函数
函数insert的作用与我们在java类当中调用StatefulKnowIedgeSession对象的insert方法的作用相同,都是将一个Fact对象插入到当前的Working Memory当中。
需注意:一旦调用 insert 宏函数,那么 Drools 会重新与所有的规则再重新匹配⼀次, 对于没有设置no-loop 属性为 true 的规则,如果条件满足,不管其之前是否执行过都会在执行,这个特性不仅存在于 insert 宏函数上,后⾯介绍的 update、retract 宏函数同样具有该特性,所以在某些情况下因考虑不周调用 insert、update 或 retract 容易发生死循环。
//Drools提供的内置⽅法insert
rule "rule7"
when
eval(true); //默认成⽴
then
Order order=new Order();
order.setAmount(1000);
insert(order);
System.out.println("测试Drools提供的内置⽅法insert 触发...,order:"+order);
end
@Test
public void test6()
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("rule7"));
//关闭会话
kieSession.dispose();
insertLogical:insertLogical 作⽤与 insert 类似,它的作用也是将⼀个 Fact 对象插入到当前的 Working Memroy 当中
(2)update函数
update函数意义与其名称⼀样, ⽤来实现对当前Working Memory当中的 Fact进⾏更新,⽤来告诉当前的 Working Memory 该 Fact 对象已经发生了变化。
//Drools提供的内置⽅法update
rule "rule8"
when
$order:Order(amount == 100);
then
$order.setAmount(1000);
update($order);
System.out.println("测试Drools提供的内置⽅法update 触发...,order:"+$order);
end
@Test
public void test8()
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
Order order = new Order();
order.setAmount(100);
kieSession.insert(order);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("rule8"));
//关闭会话
kieSession.dispose();
(3)retract
retract用来将Wroking Memory当中某个Fact对象从Working Memory当中删除
rule "rule9"
when
$order:Order(amount == 100);
then
//retract($order); //先不执行删除
System.out.println("测试Drools提供的内置⽅法retract 触发...,order:"+$order);
end
rule "rule10"
when
$order:Order();
then
System.out.println("order:"+$order);
end
@Test
public void test9()
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
Order order = new Order();
order.setAmount(100);
kieSession.insert(order);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
rule "rule9"
when
$order:Order(amount == 100);
then
retract($order); //执行删除
System.out.println("测试Drools提供的内置⽅法retract 触发...,order:"+$order);
end
rule "rule10"
when
$order:Order();
then
System.out.println("order:"+$order);
end
测试方法还是上面那个
7.Drools内置属性部分
Drools中提供的属性
属性名 | 说明 |
salience | 指定规则执行优先级 |
dialect | 指定规则使用的语言类型,取值为java或者mvel |
enabled | 指定规则是否启用 |
date-effective | 指定规则生效时间 |
date-expires | 指定规则失效时间 |
activation-group | 激活分组,具有相同分组名称的规则只能有一个规则触发 |
agenda-group | 议程分组,只有获取焦点的组中的规则才有可能触发 |
timer | 定时器,指定规则触发的时间 |
auto-focus | 自动获取焦点,一般饥饿和agenda-group一起使用 |
no-loop | 防止死循环 |
(1)salience
salience用来设置规则执行的优先级,salience属性的值是一个数字,数字越大执行优先级越高。默认情况下,规则的salience默认值为0。如果不设置salience属性,规则体的执行顺序为由上到下。
rule "rule1"
salience 1
when
eval(true)
then
System.out.println("执行规则1");
end
rule "rule2"
salience 2
when
eval(true)
then
System.out.println("执行规则2");
end
@Test
public void test10()
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
(2)no-loop
no-loop是用来控制已经执行过的规则在条件再次满足的时候是否再次执行。no-loop属性是一个布尔型默认情况下规则的no-loop属性的值为false,如果no-loop属性值为true,那么就表示该规则只会被引擎检查一次。
//这是一个死循环修改,永远都会被匹配到修改
rule "rule3"
when
$order:Order(amount == 100);
then
$order.setAmount(100);
update($order);
System.out.println("测试Drools提供的内置⽅法update 触发...,order:"+$order);
end
@Test
public void test10()
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
Order order = new Order();
order.setAmount(100);
kieSession.insert(order);
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
//这是一个死循环修改,永远都会被匹配到修改
rule "rule3"
no-loop true //配置no-loop属性
when
$order:Order(amount == 100);
then
$order.setAmount(100);
update($order);
System.out.println("测试Drools提供的内置⽅法update 触发...,order:"+$order);
end
再次测试
(3)date-effective
date-effective的作用是来控制规则只有达到指定的时候后才会触发,只有当系统时间大于等于date-effective设置的时间值时,规则才会被执行。
date-effective 的值为⼀个日期型的字符串,默认情况下,date-effective 可接受的日期格式为 “dd-MM-yyyy”。
在实际使用中,如果不想使用这种格式,也可以通过java代码去设置System.setProperty(String key,String value)方法来修饰默认的时间格式。
System.setProperty("drools.dateformat","yyyy-MM-dd");
rule "rule4"
date-effective "2022-11-30"
when
eval(true);
then
System.out.println("测试Drools date-effective ");
end
@Test
public void test10()
//设置时间格式
System.setProperty("drools.dateformat","yyyy-MM-dd");
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("rule4"));
//关闭会话
kieSession.dispose();
(4)date-expires
date-expires的作用正好与date-effective属性恰恰相反,date-expires的作用时用来设置规则的有效期,引擎在执行规则的时候,会检查规则有没有date-expires属性,如果有的话,那么将这个属性与当前系统时间进行比较,如果大于系统时间就执行。
rule "rule5"
date-expires "2022-11-30"
when
eval(true);
then
System.out.println("测试Drools date-effective ");
end
@Test
public void test10()
//设置时间格式
System.setProperty("drools.dateformat","yyyy-MM-dd");
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("rule4"));
//关闭会话
kieSession.dispose();
(5)enabled
enabled的作用就是定义一个规则是否可用。该属性的值是一个布尔值默认该属性的值为true,表示规则是可用的。设置enabled属性为false时,该规则引擎不会执行。
rule "rule1"
enabled true
when
eval(true)
then
System.out.println("执行规则1");
end
rule "rule2"
enabled false
when
eval(true)
then
System.out.println("执行规则2");
end
@Test
public void test11()
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
(6)dialect
dialect作用是用来定义规则当中要使用的语言类型,目前支持两种类型的语言,mvel和java,默认情况下,如果没有手工设置的话,默认使用java语言。
(7)activation-group
activation-group的作用是将若干个规则划分成一个组,用一个字符串来给这个组命名,在执行规则时,具有相同activation-group属性的规则中只要有一个会被执行,其他规则将不再执行。当然具有相同activation-group属性的规则中哪一个会先执行,可以设置salience属性来实现。
rule "rule1"
activation-group "test"
when
eval(true)
then
System.out.println("执行规则1");
end
rule "rule2"
activation-group "test"
when
eval(true)
then
System.out.println("执行规则2");
end
@Test
public void test11()
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
(8)agenda-group
agenda-group属性是一个字符串,不过通过这个字符串可以分为若干个AgendaGroup,默认情况下,引擎在调用这些设置了agenda-group属性的规则的时候需要显示的指定某个Agenda Group得到Focus,这样位于该Agenda Group当中的规则才会触发执行,否则将不执行。
rule "rule1"
agenda-group "001"
when
eval(true)
then
System.out.println("执行规则1");
end
rule "rule2"
agenda-group "002"
when
eval(true)
then
System.out.println("执行规则2");
end
@Test
public void test11()
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
//获取执行焦点
kieSession.getAgenda().getAgendaGroup("002").setFocus();
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
(9)auto-focus
auto-focus的作用是在已经设置了agenda-group的规则上设置该规则是否可以自动独取Focus,如果该属性设置为true,那么在执行引擎时,就不需要设置Focus。
rule "rule1"
agenda-group "001"
auto-focus true
when
eval(true)
then
System.out.println("执行规则1");
end
rule "rule2"
agenda-group "002"
when
eval(true)
then
System.out.println("执行规则2");
end
@Test
public void test11()
//创建会话对象,用于和规则交互的引擎
KieSession kieSession = kieBase.newKieSession();
//讲数据交给规则引擎,规则迎请会根据提供的数据进行规则匹配
//激活规则引擎,如果匹配成功则执行
kieSession.fireAllRules();
//关闭会话
kieSession.dispose();
以上是关于Java规则引擎Drools急速入门的主要内容,如果未能解决你的问题,请参考以下文章