規則引擎:全稱為業務規則管理系統,英文名為BRMS。規則引擎的主要思想是將應用程序中的業務決策部分分離出來,并使用預定義的語義模塊編寫業務決策(業務規則),由用戶或 開發者在需要時進行配置、管理。需要注意的是規則引擎并不是一個具體的技術框架,而是指的一類系統,即業務規則管理系統。
java開源的規則引擎有:Drools、Easy Rules、Mandarax、IBM ILOG。使用最為廣泛并且開源的是Drools。
主要應用場景:對于一些存在比較復雜的業務規則并且業務規則會頻繁變換的系統比較適合使用規則引擎,如下:
風控決策系統-------風險貸款、風險評估
反欺詐項目-----銀行貸款、征信驗證、反洗錢
實時反欺詐平臺-----手機支付、信用卡消費
drools規則引擎由以下幾部分構成:
◆Pattern Match(匹配器)具體匹配那一個規則,由它來完成
◆Agenda(議程)
◆Execution Engine(執行引擎)
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:議程,用于存放通過匹配器進行模式匹配后被激活的規則。
規則文件構成
關鍵字 | 描述 |
package 包名 | 只限于邏輯上的管理,同一個包名下的查詢或者函數可以直接調用 |
import | 用于導入類或者靜態方法 |
global | 全局變量 |
function | 自定義函數 |
query | 查詢 |
rule end | 規則體 |
一個規則通常包含三個部分:屬性部分(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:關鍵字,表示一個規則結束。
符號 | 說明 |
> | 大于 |
< | 小于 |
>= | 大于等于 |
<= | 小于等于 |
== | 等于 |
!= | 不等于 |
contains | 檢查一個Fact對象的某個屬性值是否包含一個指定的對象值 |
not contains | 檢查一個Fact對象的某個屬性值是否不包含一個指定的對象值 |
memberOf | 判斷一個Fact對象的某個屬性是否在一個或多個集合中 |
not memberOf | 判斷一個Fact對象的某個屬性是否不在一個或多個集合中 |
matches | 判斷一個Fact對象的屬性是否與提供的標準的Java正則表達式進行匹配 |
not matches | 判斷一個Fact對象的屬性是否不與提供的標準的Java正則表達式進行匹配 |
Drools中提供的屬性如下表(部分屬性)
屬性名 | 說明 |
salience | 指定規則執行優先級 |
dialect | 指定規則使用的語言類型,取值為java和mvel |
enabled | 指定規則是否啟用 |
date-effective | 指定規則生效時間 |
date-expires | 指定規則失效時間 |
activation-group | 激活分組,具有相同分組名稱的規則只能有一個規則觸發 |
agenda-group | 議程分組,只有獲取焦點的組中的規則才有可能觸發 |
timer | 定時器,指定規則觸發的時間 |
auto-focus | 自動獲取焦點,一般結合agenda-group一起使用 |
no-loop | 防止死循環,防止自己更新規則再次觸發 |
lock-on-active | no-loop增強版本。可防止別人更新規則再次出發 |
省機頂盒軟探針平臺為實現機頂盒用戶視頻使用質量的實時監控,采用實時大數據進行準實時的指標統計,指標結果推送kafka,由平臺新增的告警引擎實時消費kafka數據并通過預定制的專家規則實現實時的告警判定,最終告警結果實時通知反饋到告警平臺,實現告警到告警恢復的生命周期。
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);
本文鏈接:http://www.tebozhan.com/showinfo-26-14022-0.htmlDrools規則引擎實戰
聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com
上一篇: 增強現實改變營銷的三種方式
下一篇: 徹底搞懂hashMap底層原理