1. 項(xiàng)目概述為什么我們需要一個(gè)輕量級(jí)規(guī)則引擎如果你是一名后端開(kāi)發(fā)者或者負(fù)責(zé)過(guò)任何需要處理復(fù)雜業(yè)務(wù)邏輯的系統(tǒng)你一定對(duì)“if-else地獄”深?lèi)和唇^。當(dāng)一個(gè)促銷(xiāo)活動(dòng)有十幾種優(yōu)惠券疊加規(guī)則或者一個(gè)風(fēng)控策略需要根據(jù)幾十個(gè)用戶屬性動(dòng)態(tài)判斷時(shí)硬編碼的業(yè)務(wù)邏輯會(huì)迅速膨脹成一團(tuán)難以維護(hù)的“意大利面條代碼”。每次業(yè)務(wù)調(diào)整都意味著一次心驚膽戰(zhàn)的代碼修改、測(cè)試和上線。這時(shí)候一個(gè)能將業(yè)務(wù)規(guī)則從代碼中剝離出來(lái)的“規(guī)則引擎”就成了救星。在眾多規(guī)則引擎中Drools以其功能強(qiáng)大而聞名但其學(xué)習(xí)曲線陡峭、依賴繁重對(duì)于許多中小型項(xiàng)目來(lái)說(shuō)有點(diǎn)“殺雞用牛刀”的感覺(jué)。而Aviator則像一把精巧的瑞士軍刀。它是一個(gè)高性能、輕量級(jí)的Java表達(dá)式求值引擎通過(guò)將規(guī)則表達(dá)為簡(jiǎn)單的字符串表達(dá)式實(shí)現(xiàn)了業(yè)務(wù)邏輯的動(dòng)態(tài)配置和熱更新。你可以把它理解為一個(gè)超級(jí)計(jì)算器不僅能算11更能根據(jù)你定義的規(guī)則計(jì)算出“用戶等級(jí)為VIP且訂單金額大于1000時(shí)打8.5折”這樣的復(fù)雜業(yè)務(wù)結(jié)果。我最初接觸Aviator是在一個(gè)快速迭代的電商營(yíng)銷(xiāo)項(xiàng)目中頻繁變動(dòng)的滿減、折扣、積分規(guī)則讓我們疲于奔命。引入Aviator后我們將上百條規(guī)則配置到了數(shù)據(jù)庫(kù)中產(chǎn)品經(jīng)理通過(guò)后臺(tái)界面就能調(diào)整規(guī)則參數(shù)開(kāi)發(fā)人員徹底從“規(guī)則發(fā)布流程”中解放出來(lái)。它的核心魅力在于“輕”和“快”——不依賴復(fù)雜的規(guī)則語(yǔ)言直接用類(lèi)Java語(yǔ)法和內(nèi)置函數(shù)就能表達(dá)絕大多數(shù)業(yè)務(wù)邏輯編譯執(zhí)行性能接近原生Java代碼。對(duì)于Java技術(shù)棧的團(tuán)隊(duì)來(lái)說(shuō)幾乎可以做到開(kāi)箱即用學(xué)習(xí)成本極低。這篇教程我將從一個(gè)多年實(shí)戰(zhàn)者的角度帶你從零開(kāi)始不僅學(xué)會(huì)Aviator的基本用法更會(huì)深入其設(shè)計(jì)思想、性能優(yōu)化技巧和實(shí)際落地中的各種“坑”目標(biāo)是讓你看完就能在項(xiàng)目中穩(wěn)健地用起來(lái)。2. Aviator規(guī)則引擎核心設(shè)計(jì)思想與快速上手2.1 核心設(shè)計(jì)思想表達(dá)式即規(guī)則與Drools等基于Rete算法、擁有自己一套完整規(guī)則語(yǔ)言DRL的“重型”引擎不同Aviator的設(shè)計(jì)哲學(xué)極其簡(jiǎn)潔一切規(guī)則都可以歸結(jié)為一個(gè)表達(dá)式對(duì)這個(gè)表達(dá)式求值得到的結(jié)果就是規(guī)則的執(zhí)行結(jié)論。這個(gè)表達(dá)式是一個(gè)字符串比如amount 100 userLevel “VIP”。Aviator的核心工作就是解析這個(gè)字符串將其編譯成Java字節(jié)碼或直接解釋執(zhí)行然后在給定的“環(huán)境”一個(gè)包含變量amount和userLevel的Map中執(zhí)行它并返回布爾值true或false。這種設(shè)計(jì)帶來(lái)了幾個(gè)巨大優(yōu)勢(shì)學(xué)習(xí)成本低表達(dá)式語(yǔ)法高度類(lèi)似Java任何有編程基礎(chǔ)的開(kāi)發(fā)者都能在5分鐘內(nèi)看懂并編寫(xiě)。集成簡(jiǎn)單只需引入一個(gè)輕量的jar包無(wú)需啟動(dòng)額外的規(guī)則服務(wù)。性能優(yōu)異編譯后的表達(dá)式以Java字節(jié)碼運(yùn)行速度極快。靈活度高規(guī)則可以作為字符串存儲(chǔ)在數(shù)據(jù)庫(kù)、配置中心甚至前端實(shí)現(xiàn)真正的動(dòng)態(tài)配置。它的核心對(duì)象只有兩個(gè)表達(dá)式Expression和執(zhí)行環(huán)境MapString, Object。你定義表達(dá)式準(zhǔn)備環(huán)境數(shù)據(jù)然后執(zhí)行獲取結(jié)果。大道至簡(jiǎn)。2.2 五分鐘快速上手你的第一個(gè)Aviator程序理論說(shuō)再多不如動(dòng)手一試。我們從一個(gè)最簡(jiǎn)單的例子開(kāi)始假設(shè)我們要判斷一個(gè)訂單是否滿足包郵條件訂單金額大于等于88元。首先在你的Maven項(xiàng)目中引入依賴以最新穩(wěn)定版為例請(qǐng)查閱官方倉(cāng)庫(kù)獲取最新版本dependency groupIdcom.googlecode.aviator/groupId artifactIdaviator/artifactId version5.4.1/version /dependency接下來(lái)我們寫(xiě)一段Java代碼import com.googlecode.aviator.AviatorEvaluator; import com.googlecode.aviator.Expression; import java.util.HashMap; import java.util.Map; public class AviatorQuickStart { public static void main(String[] args) { // 1. 定義規(guī)則表達(dá)式一個(gè)簡(jiǎn)單的布爾表達(dá)式 String rule “amount 88”; // 2. 編譯表達(dá)式。這一步會(huì)進(jìn)行語(yǔ)法解析和編譯是開(kāi)銷(xiāo)相對(duì)較大的操作。 // 通常建議對(duì)不變的規(guī)則進(jìn)行緩存。 Expression compiledExp AviatorEvaluator.compile(rule); // 3. 準(zhǔn)備執(zhí)行環(huán)境數(shù)據(jù)上下文 MapString, Object env new HashMap(); env.put(“amount”, 99.5); // 訂單金額99.5元 // 4. 執(zhí)行表達(dá)式傳入環(huán)境數(shù)據(jù) Boolean result (Boolean) compiledExp.execute(env); // 5. 輸出結(jié)果 System.out.println(“訂單是否包郵” result); // 輸出訂單是否包郵true } }就是這么簡(jiǎn)單你已經(jīng)完成了一個(gè)規(guī)則的執(zhí)行。你可以嘗試修改env.put(“amount”, 50)結(jié)果會(huì)變成false。注意AviatorEvaluator.compile()方法在首次編譯某個(gè)表達(dá)式時(shí)有一定開(kāi)銷(xiāo)。在生產(chǎn)環(huán)境中一定要對(duì)編譯后的Expression對(duì)象進(jìn)行緩存避免每次執(zhí)行都重新編譯。Aviator內(nèi)部自帶了一個(gè)全局的LRU緩存但為了更精細(xì)的控制我通常使用Guava Cache或Caffeine自己維護(hù)一個(gè)業(yè)務(wù)級(jí)的緩存池。2.3 表達(dá)式語(yǔ)法初探不僅僅是比較Aviator的表達(dá)式語(yǔ)法非常豐富支持絕大多數(shù)你需要的操作算術(shù)運(yùn)算,-,*,/,%(取模)。例如(price * quantity) * (1 - discount)。邏輯運(yùn)算,,,,,!,,||,!。例如age 18 age 60。三元運(yùn)算符a ? b : c。這是實(shí)現(xiàn)簡(jiǎn)單條件分支的利器。例如score 60 ? “及格” : “不及格”。正則匹配通過(guò)內(nèi)置函數(shù)regex實(shí)現(xiàn)。例如regex(pattern, str)更常用的是str ~ pattern這個(gè)操作符它返回一個(gè)Boolean。例如判斷手機(jī)號(hào)phoneNumber ~ ‘^1[3-9]\\d{9}$’。字符串操作連接內(nèi)置函數(shù)如string.contains(s1, s2),string.startsWith(s),string.length(s)等。集合操作支持?jǐn)?shù)組、List、Map的訪問(wèn)。例如list[0],map[‘key’]。一個(gè)更復(fù)雜的例子組合風(fēng)控規(guī)則String riskRule “(userAge 18 || userAge 70) “ “(transactionAmount 5000 || “ “(deviceCity ! registeredCity hourOfDay 22))”; // 解讀用戶年齡小于18或大于70并且交易金額大于5000 或 設(shè)備所在城市與注冊(cè)城市不同且交易時(shí)間在晚上10點(diǎn)后掌握了這些語(yǔ)法你已經(jīng)能覆蓋80%的日常規(guī)則場(chǎng)景了。但Aviator的強(qiáng)大遠(yuǎn)不止于此接下來(lái)我們深入其高級(jí)特性和性能核心。3. 核心細(xì)節(jié)解析函數(shù)、數(shù)據(jù)類(lèi)型與性能調(diào)優(yōu)3.1 自定義函數(shù)擴(kuò)展規(guī)則能力的邊界雖然內(nèi)置函數(shù)和語(yǔ)法已經(jīng)很強(qiáng)但業(yè)務(wù)邏輯千變?nèi)f化。比如你需要判斷一個(gè)用戶是否在某個(gè)“黑名單ID列表”中或者需要調(diào)用一個(gè)遠(yuǎn)程服務(wù)獲取用戶的信用分。這時(shí)你就需要自定義函數(shù)。Aviator允許你將任何Java方法注冊(cè)為表達(dá)式中的函數(shù)。這是它將規(guī)則邏輯與系統(tǒng)能力連接起來(lái)的關(guān)鍵橋梁。方式一實(shí)現(xiàn)AviatorFunction接口推薦這種方式更規(guī)范支持可變參數(shù)能獲得參數(shù)類(lèi)型信息。import com.googlecode.aviator.runtime.function.AbstractFunction; import com.googlecode.aviator.runtime.function.FunctionUtils; import com.googlecode.aviator.runtime.type.AviatorBoolean; import com.googlecode.aviator.runtime.type.AviatorObject; import java.util.Map; import java.util.HashSet; import java.util.Set; /** * 自定義函數(shù)判斷用戶ID是否在黑名單中 * 函數(shù)名isInBlacklist * 用法isInBlacklist(userId) */ public class IsInBlacklistFunction extends AbstractFunction { // 模擬一個(gè)黑名單集合 private static final SetString BLACKLIST new HashSet(); static { BLACKLIST.add(“U10001”); BLACKLIST.add(“U10002”); } Override public String getName() { return “isInBlacklist”; // 在表達(dá)式中使用的函數(shù)名 } Override public AviatorObject call(MapString, Object env, AviatorObject arg1) { // 1. 從AviatorObject中獲取實(shí)際參數(shù)值 String userId FunctionUtils.getStringValue(arg1, env); // 2. 執(zhí)行業(yè)務(wù)邏輯 boolean isInList BLACKLIST.contains(userId); // 3. 返回Aviator支持的類(lèi)型 return AviatorBoolean.valueOf(isInList); } } // 注冊(cè)并使用 public class CustomFunctionDemo { public static void main(String[] args) { // 注冊(cè)自定義函數(shù) AviatorEvaluator.addFunction(new IsInBlacklistFunction()); String rule “isInBlacklist(userId)”; // 使用自定義函數(shù) Expression exp AviatorEvaluator.compile(rule); MapString, Object env new HashMap(); env.put(“userId”, “U10001”); Boolean result (Boolean) exp.execute(env); System.out.println(“用戶是否在黑名單” result); // 輸出true } }方式二直接注冊(cè)Java靜態(tài)方法對(duì)于簡(jiǎn)單的工具方法這種方式更快捷。public class BizUtils { // 假設(shè)這是一個(gè)計(jì)算用戶等級(jí)的函數(shù) public static String calculateLevel(int purchaseCount) { if (purchaseCount 100) return “鉆石”; else if (purchaseCount 50) return “黃金”; else if (purchaseCount 10) return “白銀”; else return “普通”; } } // 注冊(cè) AviatorEvaluator.addFunction(new FunctionLoader() { Override public AviatorFunction onFunctionNotFound(String name) { if (“calculateLevel”.equals(name)) { // 將Java靜態(tài)方法包裝成Aviator函數(shù) return new AbstractFunction() { Override public String getName() { return name; } Override public AviatorObject call(MapString, Object env, AviatorObject arg1) { Integer count FunctionUtils.getNumberValue(arg1, env).intValue(); String level BizUtils.calculateLevel(count); return new AviatorString(level); } }; } return null; } });實(shí)操心得自定義函數(shù)是Aviator接入企業(yè)級(jí)應(yīng)用的靈魂。但務(wù)必注意兩點(diǎn)第一函數(shù)內(nèi)部不要做耗時(shí)的IO操作如數(shù)據(jù)庫(kù)查詢、遠(yuǎn)程調(diào)用這會(huì)讓規(guī)則引擎的性能優(yōu)勢(shì)蕩然無(wú)存。正確的做法是在執(zhí)行規(guī)則前將所需數(shù)據(jù)預(yù)先查詢好并放入環(huán)境變量中。第二自定義函數(shù)應(yīng)保持無(wú)狀態(tài)和線程安全因?yàn)樗鼈兛赡鼙欢鄠€(gè)線程并發(fā)調(diào)用。3.2 數(shù)據(jù)類(lèi)型與空值安全避免運(yùn)行時(shí)“驚喜”Aviator有自己的類(lèi)型系統(tǒng)在執(zhí)行時(shí)會(huì)與Java類(lèi)型自動(dòng)轉(zhuǎn)換。理解這一點(diǎn)對(duì)避免ClassCastException至關(guān)重要。數(shù)字類(lèi)型Aviator內(nèi)部統(tǒng)一使用Number可能是Long,Double,BigInteger,BigDecimal。使用FunctionUtils.getNumberValue()獲取最安全。字符串對(duì)應(yīng)Java的String。布爾值對(duì)應(yīng)Java的Boolean。集合與數(shù)組支持Java的List,Map,Array在表達(dá)式中可以用[ ]訪問(wèn)?？罩祅ilAviator用nil表示空。在表達(dá)式中判斷空值要用 nil或! nil。例如userInfo nil ? “default” : userInfo.name。一個(gè)常見(jiàn)的坑是空指針異常。雖然Aviator在訪問(wèn)不存在的變量時(shí)會(huì)返回nil但如果你在自定義函數(shù)或某些操作中直接使用了可能為null的Java對(duì)象就會(huì)出錯(cuò)。最佳實(shí)踐在準(zhǔn)備環(huán)境數(shù)據(jù)時(shí)對(duì)于可能為null的變量主動(dòng)進(jìn)行處理。MapString, Object env new HashMap(); User user userService.getUser(id); // 不好的做法直接放入可能為null的對(duì)象 // env.put(“user”, user); // 好的做法放入一個(gè)安全的包裝對(duì)象或提前處理 env.put(“user”, Optional.ofNullable(user).orElse(NullObject.getInstance())); // 或者在表達(dá)式中處理空值user ! nil ? user.level : ‘普通’3.3 性能調(diào)優(yōu)核心編譯緩存與表達(dá)式優(yōu)化Aviator的性能之所以出色關(guān)鍵在于“編譯”。但編譯本身有成本。以下是幾個(gè)關(guān)鍵的性能優(yōu)化點(diǎn)1. 表達(dá)式編譯緩存這是最重要的優(yōu)化。Aviator的頂層入口AviatorEvaluator默認(rèn)使用一個(gè)全局的LRU緩存默認(rèn)最大緩存100個(gè)表達(dá)式。對(duì)于生產(chǎn)環(huán)境這通常不夠。// 1. 使用自定義的緩存如Guava Cache import com.google.common.cache.CacheBuilder; import com.google.common.cache.CacheLoader; import com.google.common.cache.LoadingCache; import java.util.concurrent.TimeUnit; import java.util.concurrent.ExecutionException; public class ExpressionCache { private static final LoadingCacheString, Expression CACHE CacheBuilder.newBuilder() .maximumSize(1000) // 根據(jù)規(guī)則數(shù)量調(diào)整 .expireAfterWrite(10, TimeUnit.MINUTES) // 規(guī)則可能更新設(shè)置過(guò)期時(shí)間 .build(new CacheLoaderString, Expression() { Override public Expression load(String expression) { // 緩存未命中時(shí)編譯并加載 return AviatorEvaluator.compile(expression, true); // true表示啟用緩存 } }); public static Expression getCompiledExpression(String rule) { try { return CACHE.get(rule); } catch (ExecutionException e) { throw new RuntimeException(“Failed to compile expression: ” rule, e); } } } // 使用時(shí)Expression exp ExpressionCache.getCompiledExpression(ruleString);2. 啟用編譯常量折疊Constant Folding在編譯時(shí)AviatorEvaluator.compile(expression, true)的第二個(gè)參數(shù)設(shè)為true可以啟用常量折疊優(yōu)化。例如表達(dá)式3 5 * 2會(huì)在編譯時(shí)直接計(jì)算為13而不會(huì)在每次執(zhí)行時(shí)都計(jì)算。3. 避免在表達(dá)式中進(jìn)行復(fù)雜字符串拼接像“Hello, ” name “!”這樣的拼接在表達(dá)式內(nèi)部會(huì)產(chǎn)生臨時(shí)對(duì)象。如果name是變量這無(wú)法避免。但如果都是常量不如直接在Java層拼接好再傳入。更復(fù)雜的字符串處理考慮使用自定義函數(shù)。4. 基準(zhǔn)測(cè)試與監(jiān)控對(duì)于核心規(guī)則務(wù)必進(jìn)行基準(zhǔn)測(cè)試。使用JMHJava Microbenchmark Harness來(lái)測(cè)試規(guī)則執(zhí)行的平均時(shí)間、吞吐量。監(jiān)控緩存命中率、編譯頻率等指標(biāo)它們能直觀反映你的使用方式是否高效。4. 實(shí)戰(zhàn)構(gòu)建一個(gè)可配置的電商促銷(xiāo)規(guī)則引擎讓我們通過(guò)一個(gè)完整的實(shí)戰(zhàn)案例將前面所有知識(shí)串聯(lián)起來(lái)。假設(shè)我們要為一個(gè)電商平臺(tái)設(shè)計(jì)一個(gè)促銷(xiāo)規(guī)則引擎支持多種規(guī)則類(lèi)型滿減、折扣、贈(zèng)品的靈活配置和組合執(zhí)行。4.1 系統(tǒng)設(shè)計(jì)與數(shù)據(jù)模型我們的設(shè)計(jì)目標(biāo)是規(guī)則配置在數(shù)據(jù)庫(kù)里引擎讀取配置動(dòng)態(tài)生成Aviator表達(dá)式并執(zhí)行。數(shù)據(jù)庫(kù)表設(shè)計(jì)簡(jiǎn)化CREATE TABLE promotion_rule ( id BIGINT PRIMARY KEY, rule_name VARCHAR(100), rule_type VARCHAR(20), — ‘DISCOUNT’折扣, ‘FULL_REDUCTION’滿減, ‘GIFT’贈(zèng)品 condition_expression TEXT, — Aviator條件表達(dá)式 action_expression TEXT, — 執(zhí)行動(dòng)作的表達(dá)式或參數(shù) priority INT, — 優(yōu)先級(jí)數(shù)字越大越優(yōu)先 enabled BOOLEAN );Java領(lǐng)域模型Data public class PromotionRule { private Long id; private String ruleName; private RuleType ruleType; // 枚舉 private String conditionExpression; // 如”totalAmount 100 memberLevel ‘GOLD’” private String actionExpression; // 如對(duì)于折扣”{‘type’:’DISCOUNT’, ‘value’:0.9}” 對(duì)于滿減”{‘type’:’FULL_REDUCTION’, ‘threshold’:200, ‘reduce’:50}” private Integer priority; private Boolean enabled; } Data public class OrderContext { private String userId; private String memberLevel; // 會(huì)員等級(jí) private BigDecimal totalAmount; // 訂單總金額 private ListString skuList; // 商品SKU列表 private MapString, Object extraInfo; // 其他擴(kuò)展信息 // 執(zhí)行結(jié)果 private ListPromotionResult appliedResults new ArrayList(); } Data public class PromotionResult { private String ruleName; private RuleType ruleType; private BigDecimal discountAmount; // 優(yōu)惠金額 private String giftSku; // 贈(zèng)品SKU // … 其他結(jié)果信息 }4.2 規(guī)則引擎核心執(zhí)行器實(shí)現(xiàn)這是最核心的部分負(fù)責(zé)加載規(guī)則、編譯表達(dá)式、執(zhí)行匹配并應(yīng)用動(dòng)作。import com.googlecode.aviator.Expression; import org.springframework.stereotype.Component; import javax.annotation.PostConstruct; import java.math.BigDecimal; import java.util.*; import java.util.stream.Collectors; Component public class PromotionEngine { // 規(guī)則緩存 規(guī)則ID, 編譯后的條件表達(dá)式 private MapLong, Expression conditionCache new ConcurrentHashMap(); // 規(guī)則列表緩存 private ListPromotionRule ruleCache new ArrayList(); Autowired private PromotionRuleMapper ruleMapper; // 假設(shè)的數(shù)據(jù)庫(kù)訪問(wèn)層 /** * 初始化加載所有啟用規(guī)則并編譯 */ PostConstruct public void init() { refreshRuleCache(); } /** * 刷新規(guī)則緩存可被定時(shí)任務(wù)或管理后臺(tái)調(diào)用 */ public void refreshRuleCache() { ListPromotionRule enabledRules ruleMapper.selectEnabledRules(); this.ruleCache enabledRules; this.conditionCache.clear(); for (PromotionRule rule : enabledRules) { try { // 編譯條件表達(dá)式并緩存 Expression exp AviatorEvaluator.compile(rule.getConditionExpression(), true); conditionCache.put(rule.getId(), exp); } catch (Exception e) { // 記錄編譯錯(cuò)誤日志此規(guī)則失效 log.error(“編譯促銷(xiāo)規(guī)則失敗 ruleId{}, expression{}”, rule.getId(), rule.getConditionExpression(), e); } } // 按優(yōu)先級(jí)排序 ruleCache.sort(Comparator.comparing(PromotionRule::getPriority).reversed()); } /** * 對(duì)訂單執(zhí)行所有促銷(xiāo)規(guī)則 */ public OrderContext execute(OrderContext orderContext) { // 準(zhǔn)備Aviator執(zhí)行環(huán)境 MapString, Object env prepareExecutionEnv(orderContext); for (PromotionRule rule : ruleCache) { Expression conditionExp conditionCache.get(rule.getId()); if (conditionExp null) { continue; // 編譯失敗的規(guī)則跳過(guò) } try { // 1. 執(zhí)行條件判斷 Boolean isMatch (Boolean) conditionExp.execute(env); if (Boolean.TRUE.equals(isMatch)) { // 2. 規(guī)則匹配執(zhí)行動(dòng)作 PromotionResult result applyAction(rule, orderContext, env); orderContext.getAppliedResults().add(result); // 3. 更新環(huán)境例如應(yīng)用折扣后訂單金額變化可能影響后續(xù)規(guī)則 updateEnvAfterAction(env, result); } } catch (Exception e) { log.error(“執(zhí)行促銷(xiāo)規(guī)則異常 ruleId{}”, rule.getId(), e); // 根據(jù)業(yè)務(wù)需求決定是跳過(guò)此規(guī)則還是終止執(zhí)行 } } return orderContext; } /** * 準(zhǔn)備執(zhí)行環(huán)境將OrderContext中的屬性轉(zhuǎn)換為Aviator可用的變量 */ private MapString, Object prepareExecutionEnv(OrderContext ctx) { MapString, Object env new HashMap(); env.put(“userId”, ctx.getUserId()); env.put(“memberLevel”, ctx.getMemberLevel()); env.put(“totalAmount”, ctx.getTotalAmount()); // Aviator支持BigDecimal env.put(“skuList”, ctx.getSkuList()); // 可以放入一些工具函數(shù)或常用數(shù)據(jù) env.put(“Math”, Math.class); // 允許在表達(dá)式中使用Math.max等 // 例如判斷商品是否在列表中string.contains(skuList, ‘SKU123’) return env; } /** * 應(yīng)用規(guī)則動(dòng)作 */ private PromotionResult applyAction(PromotionRule rule, OrderContext ctx, MapString, Object env) { PromotionResult result new PromotionResult(); result.setRuleName(rule.getRuleName()); result.setRuleType(rule.getRuleType()); // 這里根據(jù)actionExpression進(jìn)行解析和執(zhí)行 // 實(shí)際項(xiàng)目中actionExpression可能是一段JSON配置或另一個(gè)Aviator表達(dá)式 switch (rule.getRuleType()) { case DISCOUNT: // 假設(shè)actionExpression是JSON: {“discountRate”: 0.9} MapString, Object actionConfig parseActionConfig(rule.getActionExpression()); BigDecimal discountRate new BigDecimal(actionConfig.get(“discountRate”).toString()); BigDecimal discountAmount ctx.getTotalAmount().multiply(BigDecimal.ONE.subtract(discountRate)); result.setDiscountAmount(discountAmount.setScale(2, BigDecimal.ROUND_HALF_UP)); break; case FULL_REDUCTION: MapString, Object actionConfig parseActionConfig(rule.getActionExpression()); BigDecimal threshold new BigDecimal(actionConfig.get(“threshold”).toString()); BigDecimal reduce new BigDecimal(actionConfig.get(“reduce”).toString()); if (ctx.getTotalAmount().compareTo(threshold) 0) { result.setDiscountAmount(reduce); } break; case GIFT: // 添加贈(zèng)品邏輯 result.setGiftSku(parseGiftSku(rule.getActionExpression())); break; } return result; } private void updateEnvAfterAction(MapString, Object env, PromotionResult result) { // 例如應(yīng)用了折扣后需要更新環(huán)境中的訂單金額以便后續(xù)規(guī)則基于新金額判斷 if (result.getDiscountAmount() ! null) { BigDecimal currentAmount (BigDecimal) env.get(“totalAmount”); env.put(“totalAmount”, currentAmount.subtract(result.getDiscountAmount())); } } }4.3 規(guī)則配置與管理界面思路有了引擎還需要一個(gè)讓運(yùn)營(yíng)人員能方便配置規(guī)則的管理后臺(tái)。這里提供一些前端配置的思路條件配置可視化可以設(shè)計(jì)一個(gè)拖拽或表單生成器將“用戶等級(jí)”、“訂單金額”、“商品類(lèi)目”等條件因子變成下拉框、輸入框后端將其拼接成Aviator表達(dá)式。例如條件1memberLevel等于 [黃金]條件2totalAmount大于 [100]邏輯關(guān)系 [且]生成的表達(dá)式memberLevel ‘黃金’ totalAmount 100動(dòng)作配置模板化針對(duì)不同的ruleType提供不同的動(dòng)作表單。折扣輸入“折扣率”0.9代表9折。滿減輸入“滿X元”和“減Y元”。贈(zèng)品選擇贈(zèng)品SKU。表達(dá)式預(yù)覽與測(cè)試在保存規(guī)則前提供一個(gè)測(cè)試區(qū)域讓運(yùn)營(yíng)人員輸入模擬的訂單數(shù)據(jù)JSON格式實(shí)時(shí)查看規(guī)則是否匹配、計(jì)算結(jié)果如何。這能極大減少配置錯(cuò)誤。版本與灰度重要的規(guī)則可以引入版本管理和灰度發(fā)布。例如新規(guī)則先對(duì)10%的用戶生效觀察效果后再全量。5. 高級(jí)特性與深度優(yōu)化5.1 腳本與多行表達(dá)式處理復(fù)雜邏輯對(duì)于非常復(fù)雜的規(guī)則單行表達(dá)式可能難以維護(hù)。Aviator支持多行表達(dá)式和順序執(zhí)行類(lèi)似于一個(gè)簡(jiǎn)單的腳本。String complexRule “ — 計(jì)算基礎(chǔ)折扣 baseDiscount userLevel ‘VIP’ ? 0.15 : 0.05; — 計(jì)算活動(dòng)額外折扣 extraDiscount 0; if (contains(skuList, ‘FLASH_SALE_SKU’)) { extraDiscount 0.1; } else if (hourOfDay 20 hourOfDay 22) { extraDiscount 0.05; } — 計(jì)算總折扣率最高不超過(guò)0.3 totalDiscount baseDiscount extraDiscount; totalDiscount 0.3 ? 0.3 : totalDiscount; ”; Expression exp AviatorEvaluator.compile(complexRule); MapString, Object env new HashMap(); env.put(“userLevel”, “VIP”); env.put(“skuList”, Arrays.asList(“NORMAL_SKU”, “FLASH_SALE_SKU”)); env.put(“hourOfDay”, 21); // 注意執(zhí)行多行表達(dá)式時(shí)默認(rèn)返回最后一條語(yǔ)句的值 BigDecimal finalDiscount (BigDecimal) exp.execute(env); System.out.println(“最終折扣率” finalDiscount); // 輸出0.25注意事項(xiàng)多行表達(dá)式功能強(qiáng)大但過(guò)度使用會(huì)讓規(guī)則變得像代碼一樣難以管理違背了規(guī)則引擎“聲明式”配置的初衷。它更適合用來(lái)封裝一些復(fù)雜的計(jì)算過(guò)程而核心的業(yè)務(wù)條件判斷仍應(yīng)盡量保持簡(jiǎn)潔清晰。5.2 自定義語(yǔ)法與運(yùn)算符重載Aviator允許你自定義運(yùn)算符通過(guò)AviatorEvaluator.addOpFunction和修改語(yǔ)法特性通過(guò)AviatorEvaluator.setOption但這屬于高級(jí)用法除非有非常特殊的需求否則不建議修改。保持與標(biāo)準(zhǔn)語(yǔ)法的兼容性更利于團(tuán)隊(duì)協(xié)作和后期維護(hù)。一個(gè)相對(duì)安全的自定義是添加常量// 定義一些業(yè)務(wù)常量 AviatorEvaluator.defineConstant(“MAX_ORDER_AMOUNT”, 10000); AviatorEvaluator.defineConstant(“VIP_LEVEL_LIST”, Arrays.asList(“GOLD”, “DIAMOND”)); // 在表達(dá)式中直接使用 String rule “totalAmount MAX_ORDER_AMOUNT contains(VIP_LEVEL_LIST, userLevel)”;5.3 與Spring生態(tài)的深度集成在Spring Boot項(xiàng)目中我們可以將PromotionEngine包裝得更加優(yōu)雅。配置化將Aviator的緩存大小、啟用特性等放在application.yml中。監(jiān)聽(tīng)規(guī)則變更利用Spring的ApplicationEvent或集成配置中心如Nacos、Apollo在規(guī)則更新時(shí)觸發(fā)refreshRuleCache。健康檢查通過(guò)Spring Boot Actuator的HealthIndicator暴露規(guī)則引擎的健康狀態(tài)如緩存加載是否成功、最近一次規(guī)則執(zhí)行的平均耗時(shí)等。AOP切面可以為規(guī)則執(zhí)行方法添加切面統(tǒng)一進(jìn)行日志記錄、性能監(jiān)控和異常處理。Aspect Component Slf4j public class RuleExecutionAspect { Around(“execution(* com.yourcompany.engine..*.execute(..))”) public Object monitorRuleExecution(ProceedingJoinPoint pjp) throws Throwable { String ruleEngineName pjp.getTarget().getClass().getSimpleName(); long startTime System.currentTimeMillis(); try { Object result pjp.proceed(); long duration System.currentTimeMillis() - startTime; log.debug(“規(guī)則引擎 {} 執(zhí)行耗時(shí): {} ms”, ruleEngineName, duration); // 可以推送到監(jiān)控系統(tǒng)如Micrometer Metrics.timer(“rule.engine.execution.time”, “engine”, ruleEngineName).record(duration, TimeUnit.MILLISECONDS); return result; } catch (Exception e) { log.error(“規(guī)則引擎 {} 執(zhí)行失敗”, ruleEngineName, e); Metrics.counter(“rule.engine.execution.error”, “engine”, ruleEngineName).increment(); throw e; } } }6. 常見(jiàn)問(wèn)題、排查技巧與選型思考6.1 常見(jiàn)問(wèn)題速查表問(wèn)題現(xiàn)象可能原因排查步驟與解決方案執(zhí)行時(shí)報(bào)ClassCastException1. 環(huán)境變量中的Java類(lèi)型與表達(dá)式預(yù)期不符。2. 自定義函數(shù)返回值類(lèi)型錯(cuò)誤。1. 檢查env.put的值類(lèi)型確保與表達(dá)式中使用方式匹配。例如表達(dá)式是age 18則env中的age應(yīng)為Integer或Long而不是String。2. 在自定義函數(shù)中使用FunctionUtils系列方法安全轉(zhuǎn)換類(lèi)型。表達(dá)式編譯失敗報(bào)語(yǔ)法錯(cuò)誤1. 表達(dá)式字符串有語(yǔ)法錯(cuò)誤拼寫(xiě)、括號(hào)不匹配等。2. 使用了未注冊(cè)的自定義函數(shù)或變量。1. 將表達(dá)式字符串復(fù)制到簡(jiǎn)單的測(cè)試程序中單獨(dú)編譯定位錯(cuò)誤行。2. 使用AviatorEvaluator.validate方法預(yù)先驗(yàn)證表達(dá)式但此方法檢查有限。3.最佳實(shí)踐在規(guī)則管理后臺(tái)提供表達(dá)式“校驗(yàn)”按鈕調(diào)用編譯接口并返回詳細(xì)錯(cuò)誤信息。規(guī)則執(zhí)行結(jié)果始終為false或不符合預(yù)期1. 環(huán)境變量數(shù)據(jù)未正確傳入或值為null/nil。2. 邏輯運(yùn)算符優(yōu)先級(jí)理解錯(cuò)誤。3. 字符串比較未考慮大小寫(xiě)。1. 在執(zhí)行前打印env內(nèi)容確認(rèn)數(shù)據(jù)無(wú)誤。br2. 在復(fù)雜邏輯表達(dá)式中多用括號(hào)()明確優(yōu)先級(jí)例如(a b) || c。br3. 字符串比較使用string.equals_ignore_case(str1, str2) 函數(shù)或提前統(tǒng)一轉(zhuǎn)大小寫(xiě)。性能突然下降1. 未命中緩存每次都在編譯表達(dá)式。2. 表達(dá)式過(guò)于復(fù)雜或自定義函數(shù)中有耗時(shí)操作。3. 環(huán)境變量Map過(guò)大。1. 檢查緩存實(shí)現(xiàn)確認(rèn)緩存大小和淘汰策略是否合理監(jiān)控緩存命中率。2. 對(duì)復(fù)雜表達(dá)式進(jìn)行拆分、簡(jiǎn)化。確保自定義函數(shù)是純內(nèi)存計(jì)算。3. 只將規(guī)則計(jì)算必需的數(shù)據(jù)放入env避免傳入整個(gè)大對(duì)象?？罩羔槷惓PE在表達(dá)式中直接調(diào)用了可能返回null的Java對(duì)象的方法或?qū)傩浴?. 使用安全導(dǎo)航操作如果版本支持或三元運(yùn)算符處理空值user ! nil ? user.name : ‘default’。2. 在準(zhǔn)備環(huán)境數(shù)據(jù)時(shí)用Optional或空對(duì)象模式替換null。6.2 Aviator vs Drools如何選擇這是最常被問(wèn)到的問(wèn)題。簡(jiǎn)單對(duì)比如下特性AviatorDrools定位輕量級(jí)表達(dá)式求值引擎企業(yè)級(jí)規(guī)則管理系統(tǒng)BRMS核心模型表達(dá)式求值基于Rete算法的產(chǎn)生式規(guī)則系統(tǒng)學(xué)習(xí)曲線極低Java開(kāi)發(fā)者半小時(shí)上手陡峭需要學(xué)習(xí)DRL語(yǔ)言、Rete算法概念部署與集成一個(gè)Jar包無(wú)外部依賴嵌入應(yīng)用相對(duì)較重可獨(dú)立部署為規(guī)則服務(wù)性能極高編譯后接近原生Java高但推理引擎有一定開(kāi)銷(xiāo)規(guī)則復(fù)雜度適合條件判斷和計(jì)算邏輯復(fù)雜度中等適合復(fù)雜推理、多規(guī)則關(guān)聯(lián)、有狀態(tài)會(huì)話動(dòng)態(tài)更新非常方便更新表達(dá)式字符串即可支持但通常需要整套BRMS管理界面社區(qū)與生態(tài)活躍但功能聚焦非常龐大和成熟屬于JBoss生態(tài)典型場(chǎng)景促銷(xiāo)計(jì)算、風(fēng)控簡(jiǎn)單規(guī)則、動(dòng)態(tài)配置過(guò)濾、字段映射金融風(fēng)控復(fù)雜反欺詐、保險(xiǎn)核保、智能診斷選型建議選擇Aviator如果你的規(guī)則主要是“如果…那么…”的條件判斷和數(shù)值計(jì)算規(guī)則之間相對(duì)獨(dú)立變更頻繁且你希望以最小的成本和最快的速度集成到現(xiàn)有Java應(yīng)用中。它像是你代碼庫(kù)里的一個(gè)“超級(jí)工具類(lèi)”。選擇Drools如果你的業(yè)務(wù)規(guī)則極其復(fù)雜規(guī)則之間存在大量的交叉和關(guān)聯(lián)需要實(shí)現(xiàn)類(lèi)似“專家系統(tǒng)”的推理并且你有專門(mén)的團(tuán)隊(duì)來(lái)維護(hù)這套規(guī)則體系。它更像是一個(gè)獨(dú)立的“規(guī)則大腦”。對(duì)于絕大多數(shù)互聯(lián)網(wǎng)公司的業(yè)務(wù)場(chǎng)景營(yíng)銷(xiāo)、簡(jiǎn)單風(fēng)控、配置化流程Aviator的輕量和高效是巨大的優(yōu)勢(shì)。我個(gè)人的經(jīng)驗(yàn)是先用Aviator只有當(dāng)它的表達(dá)式模型無(wú)法清晰、優(yōu)雅地描述你的業(yè)務(wù)規(guī)則時(shí)才需要考慮Drools。6.3 最后的經(jīng)驗(yàn)之談使用Aviator幾年踩過(guò)一些坑也積累了一些確保項(xiàng)目成功的心得規(guī)則版本化與回滾規(guī)則配置一定要有版本管理。每次修改保存時(shí)記錄舊版本。一旦新規(guī)則上線出現(xiàn)問(wèn)題能快速回滾到上一個(gè)穩(wěn)定版本。這在運(yùn)營(yíng)頻繁調(diào)整規(guī)則的場(chǎng)景下是救命稻草。嚴(yán)格的測(cè)試沙盒線上規(guī)則引擎必須配備一個(gè)與生產(chǎn)環(huán)境數(shù)據(jù)隔離的測(cè)試沙盒。任何新規(guī)則或修改必須在沙盒中用真實(shí)的歷史數(shù)據(jù)或模擬數(shù)據(jù)驗(yàn)證通過(guò)后才能發(fā)布到生產(chǎn)環(huán)境。性能基線監(jiān)控為核心規(guī)則集建立性能基線如平均執(zhí)行時(shí)間P99線。當(dāng)規(guī)則變更導(dǎo)致執(zhí)行時(shí)間顯著偏離基線時(shí)監(jiān)控系統(tǒng)要能告警。這能幫你提前發(fā)現(xiàn)那些不經(jīng)意寫(xiě)出的低效表達(dá)式。表達(dá)式“消毒”如果規(guī)則表達(dá)式來(lái)自不完全受信任的源比如來(lái)自部分開(kāi)放的管理后臺(tái)要警惕表達(dá)式注入風(fēng)險(xiǎn)。避免使用AviatorEvaluator.exec()直接執(zhí)行字符串堅(jiān)持使用compile()?？梢钥紤]對(duì)表達(dá)式進(jìn)行白名單過(guò)濾只允許出現(xiàn)特定的變量名和函數(shù)名。文檔與培訓(xùn)為運(yùn)營(yíng)和產(chǎn)品同學(xué)編寫(xiě)清晰的規(guī)則配置文檔用他們能懂的語(yǔ)言而不是代碼語(yǔ)法解釋每個(gè)條件因子的含義。定期進(jìn)行培訓(xùn)減少因誤解導(dǎo)致的配置錯(cuò)誤。Aviator不是一個(gè)龐大的系統(tǒng)而是一個(gè)精致強(qiáng)大的工具。把它用好的關(guān)鍵不在于掌握多少高深特性而在于能否圍繞它構(gòu)建起一套涵蓋配置、測(cè)試、發(fā)布、監(jiān)控的完整工程實(shí)踐。當(dāng)你把這套體系搭建起來(lái)后你會(huì)發(fā)現(xiàn)業(yè)務(wù)變化的壓力不再直接壓在研發(fā)的肩上而是轉(zhuǎn)化為一種可管理、可控制的配置能力。這種解放感正是規(guī)則引擎帶來(lái)的最大價(jià)值。