电商大促活动时，营销规则复杂多变，今天满300减50，明天买2送1，后天又变成阶梯式折扣？每次改规则都得改代码、重新发布，简直是开发人员的噩梦！今天就来聊聊如何用SpringBoot + Aviator表达式引擎，搭建一个灵活的营销规则中心，让运营同学也能轻松配置营销规则，再也不用求着开发改代码了！

一、营销规则的痛点

1.1 传统if-else的困境

在没有规则引擎之前，营销优惠计算通常是这样写的：

// 伪代码：传统的营销优惠计算publicBigDecimalcalculateDiscount(Orderorder){if(order.getUserLevel().equals("VIP")){if(order.getAmount().compareTo(newBigDecimal("1000"))>0){returnorder.getAmount().multiply(newBigDecimal("0.8"));// VIP用户满1000打8折}else{returnorder.getAmount().multiply(newBigDecimal("0.9"));// VIP用户其他情况打9折}}elseif(order.getUserLevel().equals("GOLD")){if(order.getAmount().compareTo(newBigDecimal("500"))>0){returnorder.getAmount().multiply(newBigDecimal("0.85"));// 金牌用户满500打8.5折}else{returnorder.getAmount().multiply(newBigDecimal("0.95"));// 金牌用户其他情况打9.5折}}else{if(order.getAmount().compareTo(newBigDecimal("1000"))>0){returnorder.getAmount().multiply(newBigDecimal("0.9"));// 普通用户满1000打9折}else{returnorder.getAmount();// 普通用户其他情况无折扣}}}

这种写法的问题显而易见：

• 代码复杂：复杂的if-else嵌套，难以维护
• 修改困难：每次改规则都要改代码、重新发布
• 扩展性差：新增规则类型需要修改核心代码
• 测试困难：各种规则组合需要大量测试用例

1.2 业务规则变化频繁

电商行业的营销活动变化极快：

• 节日促销：双11、双12、618等
• 会员权益：不同等级用户享受不同优惠
• 限时活动：秒杀、拼团、砍价等
• 渠道差异：APP、小程序、H5不同渠道的差异化策略

面对这些变化，传统的硬编码方式显然跟不上节奏。

二、Aviator表达式引擎的优势

2.1 什么是Aviator

Aviator是一个高性能、轻量级的Java表达式引擎，专门用于动态求值表达式。它的特点：

• 高性能：通过编译成Java字节码执行，性能优异
• 轻量级：依赖包仅450K，核心部分仅70K
• 功能丰富：支持算术运算、逻辑运算、正则表达式等
• 安全可靠：不支持赋值语句和外部函数调用，防止安全问题

2.2 Aviator vs 其他规则引擎

推荐场景：

• Aviator：简单到中等复杂度的计算场景
• Drools：复杂业务规则，有图形化编辑器需求
• QLExpress：需要中文语法的业务场景

三、SpringBoot + Aviator 实战

3.1 项目依赖配置

首先在pom.xml中添加Aviator依赖：

<dependency><groupId>com.googlecode.aviator</groupId><artifactId>aviator</artifactId><version>5.3.3</version></dependency>

3.2 核心代码实现

创建Aviator规则引擎服务：

@Component@Slf4jpublicclassAviatorRuleEngine{/** * 缓存编译后的表达式，提高执行效率 */privatefinalMap<String,Expression>expressionCache=newConcurrentHashMap<>();/** * 执行规则表达式 */publicObjectexecuteRule(Stringexpression,Map<String,Object>env){try{// 检查缓存中是否存在编译后的表达式ExpressioncompiledExpression=expressionCache.get(expression);if(compiledExpression==null){// 编译表达式并缓存compiledExpression=AviatorEvaluator.compile(expression,true);expressionCache.put(expression,compiledExpression);log.debug("缓存表达式: {}",expression);}// 执行表达式Objectresult=compiledExpression.execute(env);log.debug("表达式执行结果: {} = {}",expression,result);returnresult;}catch(Exceptione){log.error("执行规则表达式失败: {}",expression,e);thrownewRuntimeException("规则执行失败: "+e.getMessage(),e);}}/** * 验证表达式语法 */publicbooleanvalidateExpression(Stringexpression){try{AviatorEvaluator.compile(expression,true);returntrue;}catch(Exceptione){log.error("表达式语法错误: {}",expression,e);returnfalse;}}}

3.3 营销规则服务实现

@Service@Slf4jpublicclassRuleService{@AutowiredprivateAviatorRuleEngineaviatorRuleEngine;/** * 根据订单金额和用户等级计算折扣 */publicDoublecalculateDiscount(DoubleorderAmount,StringuserLevel,StringproductCategory){Map<String,Object>context=newHashMap<>();context.put("orderAmount",orderAmount);context.put("userLevel",userLevel);context.put("productCategory",productCategory);// 根据不同用户等级和订单金额计算折扣StringruleExpression;if("VIP".equals(userLevel)){// VIP用户：订单金额>1000打8折，否则打9折ruleExpression="orderAmount > 1000 ? 0.8 : 0.9";}elseif("GOLD".equals(userLevel)){// 金牌用户：订单金额>500打8.5折，否则打9.5折ruleExpression="orderAmount > 500 ? 0.85 : 0.95";}else{// 普通用户：订单金额>1000打9折，否则无折扣ruleExpression="orderAmount > 1000 ? 0.9 : 1.0";}Objectresult=aviatorRuleEngine.executeRule(ruleExpression,context);returnDouble.valueOf(result.toString());}/** * 计算满减优惠 */publicDoublecalculateCouponDiscount(DoubleorderAmount,StringcouponType){Map<String,Object>context=newHashMap<>();context.put("orderAmount",orderAmount);context.put("couponType",couponType);StringruleExpression;if("MANYIJIAN".equals(couponType)){// 满减券：满200减20，满500减50ruleExpression="orderAmount >= 500 ? 50 : (orderAmount >= 200 ? 20 : 0)";}elseif("ZHEKOU".equals(couponType)){// 折扣券：满100打9折ruleExpression="orderAmount >= 100 ? orderAmount * 0.1 : 0";}else{ruleExpression="0";}Objectresult=aviatorRuleEngine.executeRule(ruleExpression,context);returnDouble.valueOf(result.toString());}}

3.4 API接口实现

@RestController@RequestMapping("/api/marketing")@Slf4jpublicclassMarketingRuleController{@AutowiredprivateRuleServiceruleService;/** * 计算订单折扣 */@PostMapping("/calculate-discount")publicResponseEntity<Map<String,Object>>calculateDiscount(@RequestBodyMap<String,Object>request){try{DoubleorderAmount=Double.valueOf(request.get("orderAmount").toString());StringuserLevel=request.get("userLevel").toString();StringproductCategory=request.get("productCategory").toString();DoublediscountRate=ruleService.calculateDiscount(orderAmount,userLevel,productCategory);Map<String,Object>result=newHashMap<>();result.put("originalAmount",orderAmount);result.put("discountRate",discountRate);result.put("discountedAmount",orderAmount*discountRate);result.put("savedAmount",orderAmount*(1-discountRate));result.put("userLevel",userLevel);log.info("订单折扣计算完成: {}",result);returnResponseEntity.ok(result);}catch(Exceptione){log.error("计算订单折扣失败",e);Map<String,Object>error=newHashMap<>();error.put("error",e.getMessage());returnResponseEntity.badRequest().body(error);}}}

3.5 常用的营销规则表达式

// 1. 满减规则：满200减20，满500减50StringmanjianRule="orderAmount >= 500 ? 50 : (orderAmount >= 200 ? 20 : 0)";// 2. 折扣规则：VIP用户打8折，金牌用户打8.5折StringzhekouRule="userLevel == 'VIP' ? 0.8 : (userLevel == 'GOLD' ? 0.85 : 1.0)";// 3. 阶梯规则：消费金额越高折扣越大StringjietiRule="orderAmount >= 1000 ? 0.7 : (orderAmount >= 500 ? 0.8 : (orderAmount >= 200 ? 0.9 : 1.0))";// 4. 组合规则：多条件判断StringcomplexRule="(userLevel == 'VIP' and orderAmount >= 1000) ? 0.7 : "+"(userLevel == 'GOLD' and orderAmount >= 500) ? 0.8 : 1.0";// 5. 时间规则：特定时间段内有效StringtimeRule="orderTime >= '2023-11-11 00:00:00' and orderTime <= '2023-11-11 23:59:59' ? 0.5 : 1.0";

四、规则中心架构设计

4.1 整体架构

前端运营系统 ←→ 规则配置API ←→ 规则引擎服务 ←→ 缓存 ←→ 数据库 ↓ 业务服务调用

4.2 规则存储设计

@Entity@Table(name="t_rule")@DatapublicclassRule{@Id@GeneratedValue(strategy=GenerationType.IDENTITY)privateLongid;/** * 规则编码 */@Column(unique=true,nullable=false)privateStringruleCode;/** * 规则名称 */privateStringruleName;/** * 规则表达式 */@LobprivateStringruleExpression;/** * 规则描述 */privateStringdescription;/** * 规则类型 */privateStringruleType;/** * 是否启用 */privateBooleanenabled=true;/** * 版本号 */privateIntegerversion=1;/** * 创建时间 */privateLocalDateTimecreateTime=LocalDateTime.now();/** * 更新时间 */privateLocalDateTimeupdateTime=LocalDateTime.now();}

4.3 规则缓存策略

@ServicepublicclassCachedRuleService{@AutowiredprivateRedisTemplate<String,Object>redisTemplate;@AutowiredprivateRuleRepositoryruleRepository;privatestaticfinalStringRULE_CACHE_PREFIX="rule:expression:";/** * 获取规则表达式（带缓存） */publicStringgetRuleExpression(StringruleCode){StringcacheKey=RULE_CACHE_PREFIX+ruleCode;// 先从缓存获取Stringexpression=(String)redisTemplate.opsForValue().get(cacheKey);if(expression!=null){returnexpression;}// 缓存未命中，从数据库获取Rulerule=ruleRepository.findByRuleCodeAndEnabledTrue(ruleCode);if(rule!=null){expression=rule.getRuleExpression();// 存入缓存，设置过期时间redisTemplate.opsForValue().set(cacheKey,expression,300,TimeUnit.SECONDS);returnexpression;}returnnull;}/** * 更新规则时清除缓存 */publicvoidupdateRule(Rulerule){ruleRepository.save(rule);// 清除缓存StringcacheKey=RULE_CACHE_PREFIX+rule.getRuleCode();redisTemplate.delete(cacheKey);}}

五、最佳实践建议

5.1 规则设计原则

1. 单一职责：每个规则只负责一个业务逻辑
2. 可测试性：规则表达式应该易于单元测试
3. 可读性：复杂的规则应该拆分成多个简单规则
4. 性能考虑：避免过于复杂的嵌套表达式

5.2 安全性考虑

// 1. 表达式验证publicbooleanvalidateRuleExpression(Stringexpression){try{// 编译表达式验证语法Expressioncompiled=AviatorEvaluator.compile(expression,true);returntrue;}catch(Exceptione){log.error("表达式验证失败: {}",expression,e);returnfalse;}}// 2. 沙箱执行（可选）publicObjectexecuteRuleSafely(Stringexpression,Map<String,Object>env){// 设置执行超时时间，防止死循环Map<String,Object>envWithTimeout=newHashMap<>(env);envWithTimeout.put("max_execution_time",1000);// 1秒超时returnAviatorEvaluator.execute(expression,envWithTimeout);}

5.3 监控和日志

@Service@Slf4jpublicclassMonitoredRuleService{@AutowiredprivateMeterRegistrymeterRegistry;publicObjectexecuteRuleWithMonitor(StringruleCode,Stringexpression,Map<String,Object>env){Timer.Samplesample=Timer.start(meterRegistry);try{Objectresult=aviatorRuleEngine.executeRule(expression,env);// 记录成功指标sample.stop(Timer.builder("rule.execution.time").tag("rule_code",ruleCode).tag("result","success").register(meterRegistry));log.info("规则执行成功: ruleCode={}, result={}",ruleCode,result);returnresult;}catch(Exceptione){// 记录失败指标sample.stop(Timer.builder("rule.execution.time").tag("rule_code",ruleCode).tag("result","error").register(meterRegistry));log.error("规则执行失败: ruleCode={}, expression={}",ruleCode,expression,e);throwe;}}}

5.4 规则版本管理

// 规则版本管理@Entity@Table(name="t_rule_version")@DatapublicclassRuleVersion{@Id@GeneratedValue(strategy=GenerationType.IDENTITY)privateLongid;privateStringruleCode;privateStringruleExpression;privateIntegerversion;privateStringdescription;privateLocalDateTimecreateTime;privateStringcreatedBy;// 是否为当前版本privateBooleancurrent=false;}

六、总结

通过SpringBoot + Aviator的组合，我们可以轻松构建一个灵活的营销规则引擎：

1. 业务灵活性：运营人员可以动态配置营销规则，无需开发介入
2. 系统性能：Aviator高性能表达式引擎，满足高并发场景
3. 维护性：规则与代码分离，降低维护成本
4. 扩展性：支持复杂的业务规则表达式

这套方案特别适合电商、金融等营销活动频繁变化的业务场景。记住，技术的价值在于解决业务问题，选择合适的工具才能事半功倍！

掌握了这套规则引擎方案，相信你再面对复杂的营销规则时会更加从容不迫，让运营同学也能轻松玩转营销活动！

本文由服务端技术精选原创，转载请注明出处。关注我们，获取更多后端技术干货！

源码下载