您现在的位置是：首页 > 文章详情

runflow —— 流程引擎框架

日期：2023-01-19点击：672收藏

runflow是一个基于逻辑流转的轻量级流程引擎。 runflow 支持 BPMN 规范，能够把复杂的业务逻辑可视化。开发人员可以通过流程编辑器设计自己的业务流程，为业务设计人员与开发工程师架起一座桥梁。

欢迎大家提 Issues，看到后我会回复的。

2. 特性

规则轻量：只要稍微了解bmpn规范的人员就快速上手。三分钟入门，一看既懂。
丰富业务场景：支持排他网关，并行网关。可以应用到各种业务场景。
多线程编排：通过并行网关与异步任务，可以对多线程进行编排。
流程设计：支持导入导出，可视化编辑流程图

更多文档

3. 界面

排他网关

并行网关

调用活动

4. 快速开始

Step1: 流程

S1.1: 流程设计

有一个五个任务串行执行的流程图demo1

下载文件：demo1.bpmn 放到resouces里面

目录结构如下

也可以用 http://123.249.93.130/runflow/ 在线设计自己的流程

S1.2: build

目前还没有上传到maven中央仓库，因此需要下载源码安装到本地仓库

git clone https://github.com/songhongtu/runflow.git mvn -Dmaven.test.failure.ignore=true clean install

S2.1: 调用流程(jar包方式)

2.1.1: 引入POM文件

<dependency>  <groupId>com.runflow</groupId>  <artifactId>runflow-core</artifactId>  <version>0.0.1-Beta</version> </dependency>

2.1.2: 调用流程

 ProcessEngineConfigurationImpl conf = new ProcessEngineConfigurationImpl(); RunTimeServiceImpl runTimeService;  {  //初始化  conf.init();  runTimeService = conf.getRunTimeService();  //bpmn位置  conf.addPath("/bpmn/demo1.bpmn");  }  @Test  public void demo1() {  //a.incrementAndGet()  AtomicInteger integer = new AtomicInteger(0);  Map map = new HashMap();  map.put("a", integer);  runTimeService.startWorkflow("Process_1671936597549", map);  System.out.println(integer);  }

直接运行即可

S3.1: 调用流程(springboot方式)

3.1.1: 引入POM文件

<dependency>  <groupId>com.runflow</groupId>  <artifactId>runflow-spring-boot-starters</artifactId>  <version>0.0.1-Beta</version> </dependency>

3.1.2: 调用流程

 @Autowired  RunTimeServiceImpl runTimeService;  @GetMapping("/demo1")  public Integer demo1(){  AtomicInteger integer = new AtomicInteger(0);  Map map = new HashMap();  map.put("a", integer);  runTimeService.startWorkflow("Process_1671936597549",map);  System.out.println(integer.get());  return integer.get();  }  /**  * 生成图片  * @param key  * @param response  * @throws IOException  */  @GetMapping("/images")  public void images(String key, HttpServletResponse response) throws IOException {  InputStream inputStream = runTimeService.generaImages(key);  IOUtils.copy(inputStream, response.getOutputStream());  }