Drools规则引擎实战

Part 1 规则引擎

规则引擎:全称为业务规则管理系统,英文名为BRMS。规则引擎的主要思想是将应用程序中的业务决策部分分离出来,并使用预定义的语义模块编写业务决策(业务规则),由用户或 开发者在需要时进行配置、管理。需要注意的是规则引擎并不是一个具体的技术框架,而是指的一类系统,即业务规则管理系统。

java开源的规则引擎有:Drools、Easy Rules、Mandarax、IBM ILOG。使用最为广泛并且开源的是Drools。

主要应用场景:对于一些存在比较复杂的业务规则并且业务规则会频繁变换的系统比较适合使用规则引擎,如下:

风控决策系统-------风险贷款、风险评估

反欺诈项目-----银行贷款、征信验证、反洗钱

实时反欺诈平台-----手机支付、信用卡消费

Drools规则引擎构成

drools规则引擎由以下几部分构成:

  • Working Memory(工作内存)
  • Rules(规则库)
  • Inference Engine(推理引擎)

◆Pattern Match(匹配器)具体匹配那一个规则,由它来完成

◆Agenda(议程)

◆Execution Engine(执行引擎)

Drools规则引擎概念

Working Memory:工作内存,drools规则引擎会从Working Memory中获取数据并和规则文件中定义的规则进行模式匹配,所以我们开发的应用程序只需要将我们的数据插入到Working Memory中即可,例如本案例中我们调用kieSession.insert(order)就是将order对象插入到了工作内存中。

Fact:事实,是指在drools 规则应用当中,将一个普通的JavaBean插入到Working Memory后的对象就是Fact对象,例如本案例中的Order对象就属于Fact对象。Fact对象是我们的应用和规则引擎进行数据交互的桥梁或通道。

Rules:规则库,我们在规则文件中定义的规则都会被加载到规则库中。

Pattern Matcher:匹配器,将Rule Base中的所有规则与Working Memory中的Fact对象进行模式匹配,匹配成功的规则将被激活并放入Agenda中。

Agenda:议程,用于存放通过匹配器进行模式匹配后被激活的规则。

Drools 基础语法

规则文件构成

关键字

描述

package 包名

只限于逻辑上的管理,同一个包名下的查询或者函数可以直接调用

import

用于导入类或者静态方法

global

全局变量

function

自定义函数

query

查询

rule end

规则体

一个规则通常包含三个部分:属性部分(attribute)、条件部分(LHS)和结果部分(RHS)

语法结构体:

rule "ruleName"
    attributes
    when
        LHS
    then
        RHS
end

rule:关键字,表示规则开始,参数为规则的唯一名称。

attributes:规则属性,是rule与when之间的参数,为可选项。

when:关键字,后面跟规则的条件部分。

LHS(Left Hand Side):是规则的条件部分的通用名称。它由零个或多个条件元素组成。如果LHS为空,则它将被视为始终为true的条件元素。

then:关键字,后面跟规则的结果部分。

RHS(Right Hand Side):是规则的后果或行动部分的通用名称。

end:关键字,表示一个规则结束。

Part 2 规则比较操作符

符号

说明

>

大于

=

大于等于

0.0) eval($fact.getPlay() = MapUtils.getDoubleValue($fact, "playThreshold", 0.96)) eval(MapUtils.getLongValue($fact, "900001") > 0) eval(RuleUtil.checkAlarmTime($fact.getActualTime(), MapUtils.getLongValue($fact, "900001_time"), MapUtils.getLongValue($fact, "reThreshold", 900000))) then RuleResult fr = new RuleResult("播放成功率告警恢复"); fr.setRuleCode(900001); fr.setActualTime(MapUtils.getString($fact, "actualTime")); fr.setAlarmTime(MapUtils.getString($fact, "900001")); fr.setAlarmStatus("0"); fr.setMsg("告警恢复"); fr.setAlarmTitle("指标播放成功率异常"); fr.setLocateInfo("指标播放成功率异常"); logger.info("播放告警恢复了{}", $fact); insert(fr);