阿里QLExpress教程：Java动态规则引擎解决业务规则硬编码问题实践

// 硬编码的促销规则判断
public boolean isEligibleForDiscount(User user, Order order) {
    if (user.isVip() && order.getAmount() > 300) {
        return true;
    }
    if (user.getLoginDays() > 100 && order.getItemCount() > 5) {
        return true;
    }
    // 更多规则...
    return false;
}

{
  "condition": {
    "type": "and",
    "rules": [
      {"field": "isVip", "operator": "eq", "value": true},
      {"field": "amount", "operator": "gt", "value": 300}
    ]
  }
}

// Groovy脚本实现规则
return user.isVip() && order.amount > 300 && 
       order.items.any { it.category == 'electronics' }

// 1. 创建带追踪配置的引擎
ExpressRunner runner = new ExpressRunner();
DefaultContext<String, Object> context = new DefaultContext<>();
// 开启追踪功能
runner.getEngineSetting().setTrace(true);

// 2. 定义规则和上下文变量
String rule = "isVip && (loginDays > 100 || orderAmount > 500)";
context.put("isVip", false);
context.put("loginDays", 150);
context.put("orderAmount", 600);

// 3. 执行并获取追踪结果
IExpressResult result = runner.execute(rule, context, null, true, false);
// 获取计算树
TraceNode traceTree = result.getTrace();

// 4. 解析追踪结果（实际应用中可转为JSON返回给前端）
printTrace(traceTree); 
// 输出：
// 整个表达式: false
// ├─ isVip: false
// └─ (loginDays > 100 || orderAmount > 500): true
//    ├─ loginDays > 100: true
//    └─ orderAmount > 500: true

// 直接在规则中定义JSON结构
String rule = "order.items.stream().filter(item -> " +
             "  item.category in ['electronics', 'books'] && " +
             "  item.price > 100" +
             ").count() >= 3";

// 上下文变量直接传入JSON格式数据
context.put("order", new JSONObject("{" +
             "\"items\": [" +
             "  {\"category\":\"electronics\",\"price\":150}," +
             "  {\"category\":\"clothes\",\"price\":80}," +
             "  {\"category\":\"books\",\"price\":120}" +
             "]}").toJavaObject(Order.class));

// 执行结果：true（符合2件指定品类且价格>100的条件）
Boolean result = (Boolean) runner.execute(rule, context, null, false, false);

// 创建安全管理器
SecurityManager securityManager = new SecurityManager();
// 配置白名单：只允许访问Order类的getAmount方法和User类的isVip方法
securityManager.addWhiteClassMethod(Order.class, "getAmount", new Class[]{});
securityManager.addWhiteClassMethod(User.class, "isVip", new Class[]{});
// 禁止System类的所有方法
securityManager.addBlackClass(System.class);

// 配置引擎使用安全管理器
runner.setSecurityManager(securityManager);

// 测试安全控制：尝试调用User.getPassword()会抛出异常
context.put("user", new User("test", "password123"));
try {
    runner.execute("user.getPassword()", context, null, false, false);
} catch (Exception e) {
    // 预期抛出：SecurityException: 禁止访问方法:User.getPassword
    System.out.println(e.getMessage());
}

// 开启缓存（默认关闭）
runner.getEngineSetting().setCache(true);
// 设置缓存最大条目（防止内存溢出）
runner.getEngineSetting().setCacheSize(1000);

// 首次执行：编译并缓存表达式
long start = System.nanoTime();
runner.execute("isVip && orderAmount > 300", context, null, false, false);
System.out.println("首次执行耗时：" + (System.nanoTime() - start) + "ns"); // ~50000ns

// 第二次执行：直接使用缓存
start = System.nanoTime();
runner.execute("isVip && orderAmount > 300", context, null, false, false);
System.out.println("缓存后执行耗时：" + (System.nanoTime() - start) + "ns"); // ~3000ns

// 生产级安全配置模板
SecurityManager securityManager = new SecurityManager();
// 1. 禁止所有系统类
securityManager.addBlackPackage("java.lang");
securityManager.addBlackPackage("java.util");
// 2. 只开放业务需要的自定义类
securityManager.addWhiteClass(Order.class);
securityManager.addWhiteClass(User.class);
// 3. 禁止反射相关方法
securityManager.addBlackMethod("java.lang.Class", "forName", new Class[]{String.class});
// 4. 使用自定义函数替代直接方法调用
runner.addFunction("calculateDiscount", new CalculateDiscountFunction());

// 打印执行耗时Top10的规则
runner.getStatistics().getTopNTimeConsumingExpressions(10).forEach(exp -> 
    System.out.println(exp.getExpression() + ": " + exp.getTotalTime() + "ms")
);