easy-rules规则引擎最佳落地实践

简介: 写作目的这是一个头部互联网公司中的一个问题。因为有很多业务产品线,作为一个新人或者团队外的人员是很难区分不同的产品线之间的区别的,因此需要给某个产品线一个描述。但是随着业务的发展,产品线下可能又根据某个字段进一步划分,那么子产品线就是父产品线 + 字段 去区分。后面根据两个字段划分…。人都麻了。因为不同的组合有不同的链路。因此针对一个产品,我们要提供针对这个产品的具体规则描述,从而减少答疑。

接下来以 餐厅、套餐、菜品进行举例。


1.png


比如你想加盟XX火锅店,你需要像区域经理申请开店。

经理说 你开一个 牛肉火锅(prouductId = 1) 自营店(type =1)。

经理让李四 开一个 羊肉火锅(prouductId = 2) 自营店(type =1)。

经理让王五 开一个 羊肉火锅(prouductId = 2) 旗舰店(type =2)。

。。。。。


那么针对不同的场景(product && type),需要走的审批流程不一样。


●牛肉火锅(prouductId = 1) 自营店(type =1)

开店规则:需要审批菜品,审批通过后套餐自动审批通过,套餐都审批通过后 餐厅自动审批通过,审批通过后即可运营。


2.png


●羊肉火锅(prouductId = 2) 自营店(type =1)

开店规则:只审批餐厅,审批通过后即可运营。


3.png


●羊肉火锅(prouductId = 2) 旗舰店(type =2)

开店规则:

只审批餐厅,审批通过后即可运营。

但是菜品也可以申请,审批通过后套餐自动审批通过,审批通过的套餐可以每天赠送100份。


4.png


那么问题来了,如果你作为审批流程客服工作人员,当一个开店的审批工单来了以后,总有人问你为什么他的工单还在审批中,你怎么办呢?最好的方式就是你告诉他你的工单是菜品、套餐、餐厅没审批通过,请找相关同学咨询。


源码下载Gitee (亲测可用,真实有效)


启动方法和工程目录如下


5.png


java规则引擎easy-rules简单使用


以上面的牛肉火锅(prouductId = 1) 自营店(type =1) 为例


正常情况下可以写代码判断


      int productId = 1;
      int type = 1;
      if(productId == 1 && type ==1){
        System.out.println("牛肉火锅自营店。请从【餐品】开始进行向上申请");
      }


如果这样的规则能通过配置的方式进行实现,那简直无敌。


下面先写一个demo版本


    Canteen canteen = new Canteen().setProductId(1).setType(1);
    // define rules 定义规则
    Rule canteenRule =
        new RuleBuilder()
            .name("牛肉火锅自营店") // 规则名称
            .description("productId = 1 && type =1 。文案:牛肉火锅自营店。请从【餐品】开始进行向上申请") // 规则描述
            .when(facts -> facts.get("productId").equals(1) && facts.get("type").equals(1)) // 规则条件
            .then(facts -> System.out.println("牛肉火锅自营店。请从【餐品】开始进行向上申请")) // 命中规则后的操作
            .build();
    // 定义规则集合
    Rules rules = new Rules();
    rules.register(canteenRule);
    // fire rules on known facts  创建执行引擎
    RulesEngine rulesEngine = new DefaultRulesEngine();
    // define facts 定义需要验证的参数
    Facts facts = new Facts();
    facts.put("productId", canteen.getProductId());
    facts.put("type", canteen.getType());
    // 进行规则校验
    rulesEngine.fire(rules, facts);


看打印结果


6.png


上面还存在以下问题


  • ●规则还是手动通过代码定义的,如果通过配置文件定义那就最好了
  • ●命中的规则后结果只能打印,我想获取规则的一些信息比如规则描述description应该怎么办


最佳落地实践


注意:部分代码没有展示,可以去仓库查看全部源码


通过配置文件定义规则 canteenRule.yml


---
name: "牛肉火锅自营店"
description: "prouductId = 1 && type = 1 "
condition: "canteen.productId==1&&canteen.type==1"
priority: 1
actions:
  - "System.out.println(1);"
---
name: "牛肉火锅旗舰店"
description: "prouductId = 1 && type = 2"
condition: "canteen.productId == 2 && canteen.type == 1"
priority: 2
actions:
  - "System.out.println(2);"


创建规则引擎工厂类RulesEngineFactory


目的:上述例子中,规则引擎不可能只为 餐厅 服务,还需要为 套餐、菜品服务。因此肯定是有不同的规则和规则引擎的。因此这里需要一个工厂。


package com.example.demo.rulesEngine.listener;
import com.example.demo.rulesEngine.common.RuleCommonInterface;
import lombok.Data;
import org.jeasy.rules.api.Facts;
import org.jeasy.rules.api.Rules;
import org.jeasy.rules.core.DefaultRulesEngine;
import org.jeasy.rules.mvel.MVELRuleFactory;
import org.jeasy.rules.support.YamlRuleDefinitionReader;
import java.io.FileReader;
/**
 * @author chaird
 * @create 2022-11-26 13:02
 */
public class RulesEngineFactory {
  /**
   * 构建食堂规则。特殊
   *
   * @return
   */
  public static BizRuleEngine buildRuleEngine4Canteen() {
    String entityType = "canteen";
    String reulePath =
        "D:\\work\\IntelliJ IDEA 2018.2.4Workspace\\Demooo\\springboot-easu-rules-demo\\src\\main\\resources\\canteenRule.yml";
    return buildRuleEngine(entityType, reulePath);
  }
  // 可以有N个
  public static BizRuleEngine buildRuleEngine4MealGroup() {
    String entityType = "mealGroup";
    String reulePath = "xxxxx";
    // return buildRuleEngine(entityType, reulePath);
    return null;
  }
  private static BizRuleEngine buildRuleEngine(String entityType, String rulePath) {
    BizRuleEngine bizRuleEngine = new BizRuleEngine(entityType, rulePath);
    return bizRuleEngine;
  }
  @Data
  public static class BizRuleEngine {
    private String entityType;
    private MVELRuleFactory ruleFactory;
    private DefaultRulesEngine rulesEngine;
    private Rules rules;
    public BizRuleEngine(String entityType, String rulePath) {
      try {
        this.entityType = entityType;
        ruleFactory = new MVELRuleFactory(new YamlRuleDefinitionReader());
        rules = ruleFactory.createRules(new FileReader(rulePath));
        rulesEngine = new DefaultRulesEngine();
        rulesEngine.registerRuleListener(new YmlRulesListener(entityType));
      } catch (Exception e) {
        e.printStackTrace();
      }
    }
    public void fire(RuleCommonInterface input) {
      Facts facts = new Facts();
      facts.put(entityType, input);
      rulesEngine.fire(rules, facts);
    }
  }
}


这样我就可以针对餐厅这样一个特殊的实例创建自己独有的规则引擎


RulesEngineFactory.BizRuleEngine canteenRuleEngine = RulesEngineFactory.buildRuleEngine4Canteen();
Canteen canteen = new Canteen().setName("西餐厅").setProductId(1).setType(1);
//todo


创建监听器YmlRulesListener


目的:其实有有的时候命中规则后我们要做一些事情,比如取到规则的一些描述等信息好组织文案


package com.example.demo.rulesEngine.listener;
import com.example.demo.rulesEngine.common.RuleCommonInterface;
import org.jeasy.rules.api.Facts;
import org.jeasy.rules.api.Rule;
import org.jeasy.rules.api.RuleListener;
/**
 * @author chaird
 * @create 2022-11-26 1:54
 */
public class YmlRulesListener implements RuleListener {
  private String entityType ;
  @Override
  public boolean beforeEvaluate(Rule rule, Facts facts) {
    return true;
  }
  @Override
  public void afterEvaluate(Rule rule, Facts facts, boolean evaluationResult) {
  }
  @Override
  public void beforeExecute(Rule rule, Facts facts) {
  }
  @Override
  public void onSuccess(Rule rule, Facts facts) {
    //获取需要验证的对象,比如 【餐厅、套餐、菜品 implement RuleCommonInterface】
    RuleCommonInterface ruleCommon = facts.get(entityType);
    //把规则信息进行一个赋值
    ruleCommon.setDescription(rule.getDescription());
  }
  @Override
  public void onFailure(Rule rule, Facts facts, Exception exception) {
  }
  public YmlRulesListener(){
  }
  public YmlRulesListener(String entityType) {
    this.entityType = entityType;
  }
}


可以直接通过规则action进行赋值


有的时候会有转换操作,针对本文提出的案例。我想让productId =2的时候和productId = 9527的后续流程一样,可以在actions中使用下面的命令


name: "牛肉火锅旗舰店"
description: "prouductId = 1 && type = 2"
condition: "canteen.productId == 2 && canteen.type == 1"
priority: 2
actions:
  - "canteen.productId = 9527;"


总结


●这样的一个工具案例其实写文章还挺难组织思路的,代码贴的多显示不出核心思路。代码贴的少大家又看不太懂。

●百度了一些文章,其实有些都没有跑通,所以自己写一篇文章。

●其实单场景下对一个实体类进行规则校验那很简单,本文通过工厂模式设计的是对多实体类进行规则校验。总体还是有难度的。

目录
相关文章
|
存储 Kubernetes Java
SpringBoot整合MinIO
MinIO是一款基于Go语言开发的高性能、分布式的对象存储系统,开源可商用。一开始就被设计为服务于私有云、公有云、混合云,因此在高可用、可扩展性、高性能方面有得天独厚的优势。 MinIO完全实现了AWS S3 标准,在日常使用、扩展升级、迁移方面更易于管理,对于上层应用程序来说,存储和访问对象是统一的,即使MinIO服务迁移了,应用程序侧是无感知的。 MinIO分三个版本,开源版、标准版、企业版,开源版本免费使用,后面两个为付费产品。MinIO支持多种部署环境:Kubernetes、Docker、Linux、MacOS、Windows
937 1
SpringBoot整合MinIO
|
缓存 安全 Java
|
Java API
QLExpress功能清单
QLExpress从一开始就是从复杂的阿里电商业务系统出发,并且不断完善的脚本语言解析引擎框架,在不追求java语法的完整性的前提下(比如异常处理,foreach循环,lambda表达式,这些都是groovy是强项),定制了很多普遍存在的业务需求解决方案(比如变量解析,spring打通,函数封装,操作符定制,宏替换),同时在高性能、高并发、线程安全等方面也下足了功夫,久经考验。
22578 1
|
存储 Java 应用服务中间件
Java规则引擎Drools急速入门
Java规则引擎Drools急速入门
11397 0
Java规则引擎Drools急速入门
|
算法 数据可视化 Java
JAVA规则引擎工具有哪些?
本文对比分析了六种Java规则引擎:Drools、IBM ODM (JRules)、Easy Rules、JBPM、OpenL Tablets以及Apache Camel结合规则组件的应用。Drools是一款功能全面的业务规则管理系统,支持DRL文件定义规则、高效的规则匹配算法、复杂的规则流及决策表,并易于与Java应用集成。IBM ODM (原JRules)提供了强大的规则管理功能,包括Web界面和Eclipse插件定义管理规则、直观的决策表和决策树、REST和Java API集成选项及优化的性能。
2852 3
|
存储 算法 数据库
带你学习DM数据库的基本操作
带你学习DM数据库的基本操作
2438 0
|
Kubernetes 监控 Linux
不借助 Docker Desktop 在Mac上开发容器应用
![](https://ata2-img.oss-cn-zhangjiakou.aliyuncs.com/neweditor/e2096947-f310-4ac5-a413-ec2b28b0e040.png) Docker Desktop是最为流行的开发者工具,Docker公司在 8/31 宣布对Docker Desktop的用户协议进行了变更,对个人开发者继续免费,但是对商业开发者采取了收费策
2184 114
不借助 Docker Desktop 在Mac上开发容器应用
|
数据采集 程序员 测试技术
程序员如何准备好一次高质量的汇报?
为什么掌握汇报能力很重要? 可能很多同学会说“我这种基层打工人不需要做年终述职了,跟周报一样写个书面总结就行了,至少现阶段跟我无关。” 当然,不少企业为了节省时间,对基层员工或基层管理者来说是不需要做述职汇报或者年终汇报的,仅提交书面形式的年终总结即可。 但实际情况是,无论是晋升述职、提案汇报,还是与客户售前交流、项目实施讲解,处处场景都要用到汇报技能,汇报是每一位职场人在成长的过程中都应该掌握的技能。 所以建议大家在日常工作中尽量珍惜每一次上台的机会,并从中积累汇报经验。
1459 1
程序员如何准备好一次高质量的汇报?
|
Java 数据安全/隐私保护 Spring
Springboot 中引入 SpEL,复杂权限控制轻松搞定,非常优雅!
Springboot 中引入 SpEL,复杂权限控制轻松搞定,非常优雅!
649 1
|
JSON API 数据中心
K/3 Cloud Web API接口说明文
K/3 Cloud Web API接口说明文 目的 三方集成,提供第三方系统与Cloud集成调用接口。   技术实现 HTTP + Json   提供标准接口   编号 名称 说明 1 Kingdee.
2922 0