五分钟技术趣谈 | Drools规则引擎实战

作者：余贤雷 卢阳，单位：中国移动智慧家庭运营中心

在机顶盒软探针项目中，项目需要针对地域维度对机顶盒指标：播放成功率、收视用户数、EPG请求成功率，实现准实时的告警判定。针对告警规则的多变性，我们引入了规则引擎作为告警规则的实现方式。

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 基础语法

规则文件构成

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

语法结构体：

rule "ruleName"    attributes    when        LHS    then        RHSend

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

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

when：关键字，后面跟规则的条件部分。

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

then：关键字，后面跟规则的结果部分。

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

end：关键字，表示一个规则结束。

Part 2●规则比较操作符●

Part 3●Drools 规则属性 attributes●

Drools中提供的属性如下表(部分属性)

Part 4●项目应用●

省机顶盒软探针平台为实现机顶盒用户视频使用质量的实时监控，采用实时大数据进行准实时的指标统计，指标结果推送kafka，由平台新增的告警引擎实时消费kafka数据并通过预定制的专家规则实现实时的告警判定，最终告警结果实时通知反馈到告警平台，实现告警到告警恢复的生命周期。

Part 5●规则示例●

rule "播放成功率告警"no-loop truewhen    $fact:Fact()    eval($fact.getPlay() > 0.0)    eval($fact.getPlay() < MapUtils.getDoubleValue($fact, "playThreshold", 0.96))then    RuleResult fr = new RuleResult("播放成功率告警");    fr.setRuleCode(900001);    fr.setActualTime(MapUtils.getString($fact, "actualTime"));    fr.setAlarmTime(RuleUtil.getAlarmTime(MapUtils.getString($fact, "actualTime"), MapUtils.getString($fact, "900001")));    //说明当前是要告警的    fr.setAlarmStatus("1");    fr.setAlarmTitle("指标播放成功率异常");    fr.setLocateInfo("指标播放成功率异常");    fr.setAlarmText(RuleUtil.playAlarmText($fact, MapUtils.getDoubleValue($fact, "playThreshold", 0.96)));    insert(fr);endrule "播放成功率告警结束"no-loop truewhen    $fact:Fact()    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);