CompileFlow简介
compileflow
是一个非常轻量、高性能、可集成、可扩展的流程引擎。
compileflow Process
引擎是淘宝工作流TBBPM
引擎之一,是专注于纯内存执行,无状态的流程引擎,通过将流程文件转换生成java
代码编译执行,简洁高效。
compileflow很多地方用到了QlExpress,建议先学习下QlExpress,我有篇介绍qlexpress使用的文档,https://www.jianshu.com/p/a3ff29cf579d
快速上手
有一个demo项目,地址如下https://github.com/compileflow/compileflow-demo, 然后用idea打开,如果idea没有把这个当作maven项目的话,找到pom.xml右键,"Add as Maven Project"。
这个demo项目中有一个ktv唱歌的例子,如果价格大于等于300的话打九折,否则不打折。
然后启动DemoApplication,端口是7001。
然后可以分别请求localhost:7001/run,localhost:7001/run2观察结果。然后可以自己在RunCase中写个run3,因为run是4个人唱ktv,每个人30,总价是120,在ktvExample.bpm中定义了一个decision节点,大于300的话打九折。
- RunCase中增加方法run3
public void run3() {
//code在bpm文件中定义
String code = "bpm.ktvExample";
//执行流程的入参
Map<String, Object> context = new HashMap<>();
List<String> pList = new ArrayList<>();
pList.add("a1");
pList.add("a2");
pList.add("a3");
pList.add("a4");
pList.add("a5");
pList.add("a6");
pList.add("a7");
pList.add("a8");
pList.add("a9");
pList.add("a10");
pList.add("a11");
context.put("pList", pList);
try {
ProcessEngine processEngine = ProcessEngineFactory.getProcessEngine();
Map<String, Object> result = processEngine.start(code, context);
System.out.println(result.get("price"));
} catch (Exception e) {
e.printStackTrace();
}
}
- DemoController增加一个请求
@RequestMapping("/run3")
public String run3() {
runCase.run3();
return "Run ok.";
}
请求localhost:7001/run3,可以发现已经打了9折了。
安装compile-flow idea插件
插件最新安装包下载,下载地址:compileflow-idea-designer.zip 如果你是idea的2020版本及以上的,请下载这个:compileflow-idea-designer.for.2020.up.zip
然后idea -> Preferences -> Plugins,选择install from disk, 重启就行了
compile-flow idea插件使用
然后打开bpm文件,比如我打开了ktvExample.bpm
可以看到有三个tab栏,分别是Text,java code,process-flow
可以在process-flow中进行编辑流程图
更详细的使用见 https://github.com/alibaba/compileflow-idea-designer/blob/master/README_CN.md
bpm规范
这个github上项目的文档已经写的很好了,直接点击链接查看吧。
协议详解
看过这个后,对于Text中的xml描述流程会有更好的了解。更详细的可以参见complieflow的TBBPM.xsd文档
进阶使用
预先加载bpm流程到内存
通过processEngine.load方法预先将bpm流程加载到内存
@Component
@Configuration
public class BpmInitializer implements InitializingBean {
@Override
public void afterPropertiesSet() throws Exception {
ProcessEngine processEngine = ProcessEngineFactory.getProcessEngine();
processEngine.load("bpm.ktvExample");
processEngine.load("bpm.sqrt");
}
@Bean
public SpringApplicationContextProvider getSpringApplicationContextProvider() {
return new SpringApplicationContextProvider();
}
}
获取bpm对应的code
获取java code
System.out.println(processEngine.getJavaCode(code));
获取test code
System.out.println(processEngine.getTestCode(code));
使用BPMN
默认使用的是TBBPM,如果需要使用BPMN的话,compileflow的源码的test有示例
final ProcessEngine processEngine = ProcessEngineFactory.getStatelessProcessEngine(FlowModelType.BPMN);