文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

转转图书对基于Drools引擎的DMN实践

2024-12-01 13:12

关注

DMN logo

DMN是由OMG(Object Management Group,对象管理组织)管理的一种规范,该组织下比较知名的还有UML等。

DMN示例

如图所示,DMN的表现形式近似于流程图,通过可视化来更直观地体现出流转和处理的过程,而各个节点使用附带逻辑的表格来表现该节点处理数据的方式。

由于DMN是一个规范,所以在应用上,主要依靠各个DMN工具供应商提供具体实现,近似于SQL语句和MySQL、Oracle的关系。

1.2 为什么要用DMN

应用DMN主要目的是为了解决转转图书项目定价逻辑过于复杂的问题。

在引入DMN之前,图书项目使用java代码实现产品人员提供的定价逻辑。但是随着逻辑越来越复杂,定价逻辑的代码也越来越难以阅读和维护。同时,将产品人员的逻辑翻译成代码是一个单向过程,只有程序员能理解实现过程,产品人员只能通过结果反推是否正确合理,在逻辑变得复杂之后,很难快速发现问题。

复杂规则的一部分,区间和系数

而通过DMN,可以可视化的表示出逻辑过程,产品人员也可以直观的看到是否符合预期,还能够进行编辑,从而解决了只有程序员掌握实现而过于依赖程序员的问题,也能减少表述交流的过程产生理解偏差进而导致的错误。

使用DMN实现的规则表现

1.3 什么是Drools

Drools是用java语言编写的开源规则引擎,是DMN规范的一种实现。举例来说DMN规范就是接口,Drools就是实现了接口的其中一个工具类。

Drools logo

Drools属于Kie开源社区,而kie社区由Red Hat赞助,有比较高的社区活跃度。

Kie旗下的产品

1.4 为什么选择Drools

Drools引擎是基于java实现的,这使得不需要为Drools单独部署运行环境,运维成本是0,十分友好。

其次,DMN规范规定实现其规范的软件必须满足三级递增的符合性级别,三级最高,一级最低,满足三级级别时必须同时满足一级和二级级别。而Drools引擎对DMN规范的支持属于三级级别,功能完善。

Drools引擎对DMN各个版本提供支持

同时,Drools引擎社区活跃度高,同时提供了完整的工作组件,可靠性高。

2 Drools引擎应用

以下内容基于7.61.0版本,与8.x及以上的版本存在差异

2.1 官方推荐的最直接的应用方式

首先需要部署运行一个Kie Server用来执行DMN规则,然后部署Drools官方提供的基于Web的工作站软件用来编辑、测试、发布DMN规则。

Drools提供的工作站软件

当部署完成DMN规则之后,可以通过Kie Server REST API来运行规则获取结果,即通过Http的方式请求Kie Server提供的接口。

2.2 转转图书的限制

首先说图书项目并没有直接按照官方推荐的做法部署应用,原因有几个方面:

第一点,转转内部项目部署运行有自有的框架体系,而Kie Server是基于JBoss运行的服务器软件,在现有体系中部署一个外部项目需要额外的运维成本。

其次,Kie Server作为一个第三方工具,当出现问题时仅靠图书项目的人员难以解决,而等待社区反馈对于转转图书这种线上的商业项目难以接收。所以为了尽可能的减少出现问题的概率,节约人力,图书项目倾向于尽可能少的引入外部依赖。

基于以上原因,图书项目在应用Drools的时候选择了另外一种方式。

3 脱离Kie Server的Drools引擎实践

脱离开Kie Server,自然就没有了REST API的http接口,同时也失去了官方工作站的支持,但是相对的,Drools提供了一些对这种场景下的支持。

3.1 在线编辑DMN规则

在Kie旗下有另一款名为Kogito的产品,是一个提供在线编辑BPMN和DMN的服务器软件,同时其中有一个all-in-one的js文件,实现了在线编辑DMN的全部功能。

js提供的接口

图书项目基于这个js文件进行了包装,增加易用性,使得DMN编辑功能融入到现有的工作后台之中。

包装页面,下方是js提供的功能区

同时增加编辑记录列表用来便于管理和回滚。

编辑列表

js工具编辑后的DMN规则内容是xml格式的字符串,可以使用js提供的getContent()接口导出。

3.2 使用Drools引擎执行DMN规则

没有了Kie Server的支持之后,需要通过代码的方式运行Drools引擎。

首先在项目中引入Drools引擎的组件

引入Drools引擎组件

然后在项目中创建Drools引擎的引用并执行。

// 初始化KieServices
KieServices kieServices = KieServices.Factory.get();
// 通过指定的maven依赖创建Kie容器
ReleaseId releaseId = kieServices.newReleaseId( "com", "my-kjar", "1.0.0" );
KieContainer kieContainer = kieServices.newKieContainer( releaseId );
// 通过容器获取DMN运行时
DMNRuntime dmnRuntime = KieRuntimeFactory.of(kieContainer.getKieBase()).get(DMNRuntime.class);
// 通过DMN运行时获取需要执行的DMNModel,其中包含了DMN规则
String namespace = "my-namespace";
String modelName = "dmn-model-name";
DMNModel dmnModel = dmnRuntime.getModel(namespace, modelName);
// 获取上下文,并传入DMN规则需要用到的数据
DMNContext dmnContext = dmnRuntime.newContext();
dmnContext.set("inputData", "123");
// 执行规则获取结果
DMNResult dmnResult = dmnRuntime.evaluateAll(dmnModel, dmnContext);
for (DMNDecisionResult dr : dmnResult.getDecisionResults()) {
log.info("Decision: '" + dr.getDecisionName() + "', " + "Result: " + dr.getResult());
}

由于Kie容器使用maven作为读取DMN配置的手段,所以要求DMN规则内容需要打包到Kie容器能够识别的jar包里,并且部署到项目可访问的maven环境中。

3.3 完善处理流程

按照上述流程就可以实现脱离Kie server运行Drools引擎。但是距离落地上线还有一小点距离。

官方的工作站可以提供DMN规则上线前的验证和测试功能,但是all-in-one的js文件没有,所以为了保证准确性和稳定性,需要额外实现DMN规则的验证动作。

这里可以使用KieContainer提供的verify接口来触发Drools引擎的验证动作并获取结果。

Results verify = kieContainer.verify();
for (Message message : verify.getMessages()) {
log.info(message.getLevel().name() + ": " + message.getText());
}

将验证流程放到保存DMN规则的时候,就可以快速发现是否存在编写错误。

3.4 DLC - 脱离maven环境运行Drools引擎

前面说了Drools引擎需要使用maven获取运行的DMNjar文件,但是在实际应用中,线上环境不一定会部署maven。例如图书项目需要在公司内部公用的spark集群上运行Drools,但是spark集群上没有部署maven环境,按照上述流程运行就会报错。

所以需要一个能够使Drools脱离maven环境的手段。

通过分析源码可以发现,在创建KieContainer的时候,会使用KieServices.getRepository()方法获取数据源,并通过maven坐标查找其中的KieModule。所以需要做的就是直接我们需要的jar写入KieServices的数据源中:

// 首先通过JarOutputStream生成包含DMN规则字符串,且符合Drools规范的jar二进制流
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
JarOutputStream jos = new JarOutputStream(outputStream);
// kmodule.xml
jos.putNextEntry(new JarEntry("/META-INF/kmodule.xml"));
jos.write("".getBytes(StandardCharsets.UTF_8));
// pom.properties
jos.putNextEntry(new JarEntry("/META-INF/maven/com.myspace/test/pom.properties"));
jos.write("groupId=com.myspace\nartifactId=test\nversinotallow=1.0.0".getBytes(StandardCharsets.UTF_8));
// pom.xml
jos.putNextEntry(new JarEntry("/META-INF/maven/com.myspace/test/pom.xml"));
jos.write(" 4.0.0 com.myspace test 1.0.0 kjar test ".getBytes(StandardCharsets.UTF_8));
// dmn
jos.putNextEntry(new JarEntry("/config/rules/test.dmn"));
jos.write(dmn.getBytes(StandardCharsets.UTF_8));
jos.finish();
ByteArrayInputStream inputStream = new ByteArrayInputStream(outputStream.toByteArray());
// 初始化KieServices
KieServices kieServices = KieServices.Factory.get();
// 获取KieServices的数据源
KieRepository repository = kieServices.getRepository();
// 向数据源中加入基于生成二进制流构造的KeiModule
KieModule kieModule = repository.addKieModule(kieServices.getResources().newInputStreamResource(inputStream));

如上就可以实现在没有maven环境的时候仍然能够让KieServices获取到我们需要DMN规则。

但是仅仅如此还不够,在创建KieContainer的时候,内部会生成一个KieProject实例,KieProject在实例化的过程中会默认生成一个基于maven的MavenClassLoaderResolver用于查找jar,而缺少maven环境的情况下在生成MavenClassLoaderResolver的时候也会报错。为此,我们需要一个取代MavenClassLoaderResolver的办法。

通过分析Drools源码可以发现,在源码中,某些时候会使用ProjectClassLoader.findParentClassLoader()来获取基于当前运行环境的ClassLoader。

所以,需要在创建KieContainer的时候使用ProjectClassLoader.findParentClassLoader()生成的ClassLoader来取代默认的MavenClassLoaderResolver:

// 使用另外一个接收ClassLoader的接口来生成KieContainer
KieContainer kieContainer = kieServices.newKieContainer(kieModule.getReleaseId(), ProjectClassLoader.findParentClassLoader());

如此一来,就可以完全脱离maven环境来使用Drools引擎了,而Drools引擎也可以融入到任意的java项目之中,部署到任意的java环境之下。

4 总结

DMN在实际应用中有比较明显的优点:

但是相对的也存在一些弊端或者表现不够好的地方:

复杂规则示例

总体而言,DMN主要应用在向程序员以外的人员提供决策管理的能力,以求更准确地反映目的,从程序员的角度讲可能和写ifelse没什么不一样,但是其他角色的参与人员可以通过较低的学习成本来上手实现规则,能够减少沟通成本和不同人的理解差异产生的不符合预期的结果。

5 参考资料

Drools官方网站:https://www.drools.org/

Drools官方的DMN教学:https://www.drools.org/learn/dmn.html

Drools官方的15分钟简易教学:https://learn-dmn-in-15-minutes.com/learn/introduction

Kogito在线编辑网页:https://sandbox.kie.org/#/

Kie官方网站:https://www.kie.org/

OMG官方网站的DMN页:https://www.omg.org/dmn/

作者简介

项赢,转转资深java工程师。长期服务于转转图书项目。

来源:转转技术内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯