Flowable简单Demo

跟随官方文档来开始一个简单的Flowable demo

什么是Flowable？

Flowable 是用 Java 编写的轻量级业务流程引擎。Flowable 流程引擎允许您部署 BPMN2.0 流程定义（用于定义流程的行业 XML 标准），创建这些流程定义的流程实例，运行查询，访问活动或历史流程实例以及相关数据，以及更多其他功能。

当将 Flowable 添加到您的应用程序/服务/体系结构中时，它非常灵活。 您可以通过包含 Flowable 库将引擎嵌入到应用程序或服务中，该库可以作为 JAR 使用。 由于它是一个 JAR ，因此您可以轻松地将其添加到任何 Java 环境中：Java SE； Servlet 容器，例如 Tomcat 或 Jetty，Spring； Java EE服务器，例如 JBoss 或 WebSphere，等等。 或者，您可以使用 Flowable REST API通过HTTP进行通信。 还有一些 Flowable 应用程序（Flowable Modeler，Flowable Admin，Flowable IDM和Flowable Task），它们提供了用于处理流程和任务的现成示例UI。

Flowable 与 Activiti

Flowable 是Activiti（Alfresco的注册商标）的一个分支。

Demo 示例

构建的示例是一个简单的假日请求流程：

  • 员工请求放假 n 天；
  • 管理员允许或者拒绝；
  • 模仿这个流程，若管理员允许，则发送批准文件给系统；若拒绝，则发送拒绝邮件给该名员工。

流程图

cenganhui/TOIMGf250f0611104207N.png

创建一个Spring Boot项目

项目命名为 FlowableDemo 。

  • Flowable 流程引擎，这将使我们能够建 ProcessEngine 对象并访问 Flowable API；
  • 内存数据，因为 Flowable 引擎在运行流程实例时需要一个数据库来存储执行和历史数据。

修改 pom.xml 文件，添加如下依赖：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
<dependency>
	<groupId>mysql</groupId>
	<artifactId>mysql-connector-java</artifactId>
	<version>8.0.20</version>
</dependency>
<dependency>
    <groupId>org.flowable</groupId>
    <artifactId>flowable-engine</artifactId>
    <version>6.5.0</version>
</dependency>
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-api</artifactId>
    <version>1.7.21</version>
</dependency>
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-log4j12</artifactId>
    <version>1.7.21</version>
</dependency>

resources下创建log4j.properties

1
2
3
4
5
log4j.rootLogger=DEBUG, CA

log4j.appender.CA=org.apache.log4j.ConsoleAppender
log4j.appender.CA.layout=org.apache.log4j.PatternLayout
log4j.appender.CA.layout.ConversionPattern= %d{hh:mm:ss,SSS} [%t] %-5p %c %x - %m%n

resources下创建holiday-request.bpmn20.xml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xmlns:xsd="http://www.w3.org/2001/XMLSchema"
             xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"
             xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC"
             xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI"
             xmlns:flowable="http://flowable.org/bpmn"
             typeLanguage="http://www.w3.org/2001/XMLSchema"
             expressionLanguage="http://www.w3.org/1999/XPath"
             targetNamespace="http://www.flowable.org/processdef">

    <process id="holidayRequest" name="Holiday Request" isExecutable="true">

        <startEvent id="startEvent"/>
        <sequenceFlow sourceRef="startEvent" targetRef="approveTask"/>

        <userTask id="approveTask" name="Approve or reject request" flowable:candidateGroups="managers"/>
        <sequenceFlow sourceRef="approveTask" targetRef="decision"/>

        <exclusiveGateway id="decision"/>
        <sequenceFlow sourceRef="decision" targetRef="externalSystemCall">
            <conditionExpression xsi:type="tFormalExpression">
                <![CDATA[
                    ${approved}
                ]]>
            </conditionExpression>
        </sequenceFlow>
        <sequenceFlow  sourceRef="decision" targetRef="sendRejectionMail">
            <conditionExpression xsi:type="tFormalExpression">
                <![CDATA[
                    ${!approved}
                ]]>
            </conditionExpression>
        </sequenceFlow>

        <serviceTask id="externalSystemCall" name="Enter holidays in external system"
                     flowable:class="com.example.demo.CallExternalSystemDelegate"/>
        <sequenceFlow sourceRef="externalSystemCall" targetRef="holidayApprovedTask"/>

        <userTask id="holidayApprovedTask" name="Holiday approved" flowable:assignee="${employee}"/>
        <sequenceFlow sourceRef="holidayApprovedTask" targetRef="approveEnd"/>

        <serviceTask id="sendRejectionMail" name="Send out rejection email"
                     flowable:class="com.example.demo.SendRejectionMail"/>
        <sequenceFlow sourceRef="sendRejectionMail" targetRef="rejectEnd"/>

        <endEvent id="approveEnd"/>

        <endEvent id="rejectEnd"/>

    </process>

</definitions>

创建HolidayRequst.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
public class HolidayRequest {

    public static void main(String[] args) {

        // 通过ProcessEngineConfiguration实例创建ProcessEngine，该实例可以配置和调整流程引擎的设置
        // 通常用XML来创建，但也可以用编程方式创建
        // 配置JDBC连接
        ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
                .setJdbcUrl("jdbc:mysql://127.0.0.1:3306/flowable_test?autoReconnect=true&useUnicode=true&characterEncoding=utf-8&nullCatalogMeansCurrent=true&serverTimezone=GMT%2B8")
                .setJdbcUsername("root")
                .setJdbcPassword("nishi213")
                .setJdbcDriver("com.mysql.cj.jdbc.Driver")
                .setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE); // 数据库架构不存在时创建数据库架构
        // 实例化ProcessEngine，这是一个线程安全的对象，通常在应用程序中只需实例化一次。
        ProcessEngine processEngine = cfg.buildProcessEngine();

        // 通过ProcessEngine对象获取到RepositoryService，将流程定义部署到Flowable引擎
        RepositoryService repositoryService = processEngine.getRepositoryService();
        // 通过传入XML文件并调用deploy()方法创建一个Deployment
        Deployment deployment = repositoryService.createDeployment()
                .addClasspathResource("holiday-request.bpmn20.xml")
                .deploy();

        // 通过AIP查询流程定义，以验证引擎是否知道流程定义（并了解有关API的知识）
        // 这是通过RepositoryService创建一个新的ProcessDefinitionQuery对象来完成的。
        ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
                .deploymentId(deployment.getId())
                .singleResult();
        System.out.println("Found process definition : " + processDefinition.getName());

        /*  启动流程实例  */
        // 录入一些简单的信息
        Scanner scanner = new Scanner(System.in);
        System.out.println("请问你是？");
        String employee = scanner.nextLine();
        System.out.println("那你想请几天假啊？");
        Integer nrOfHolidays = Integer.valueOf(scanner.nextLine());
        System.out.println("你为啥要请假啊？");
        String description = scanner.nextLine();

        // 通过RuntimeService启动流程实例
        RuntimeService runtimeService = processEngine.getRuntimeService();
        // 将数据以Map形式传递
        Map<String, Object> variables = new HashMap<>();
        variables.put("employee", employee);
        variables.put("nrOfHolidays", nrOfHolidays);
        variables.put("description", description);
        // key与holiday-request.bpmn20.xml中process的id匹配
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("holidayRequest", variables);

        /*  查询与完成任务 */
        // 通过ProcessEngine来获取TaskService
        TaskService taskService = processEngine.getTaskService();
        // 通过TaskService创建一个任务list
        List<Task> tasks = taskService.createTaskQuery().taskCandidateGroup("managers").list();
        System.out.println("你有 " + tasks.size() + " 任务：");
        for(int i = 0; i < tasks.size(); i++){
            System.out.println((i + 1) + ")" + tasks.get(i).getName());
        }

        // 选择一个要完成的任务
        System.out.println("***********管理人***********");
        System.out.println("你想要的完成哪一个任务？");
        int taskIndex = Integer.valueOf(scanner.nextLine());
        Task task = tasks.get(taskIndex - 1);
        Map<String, Object> processVariables = taskService.getVariables(task.getId());
        System.out.println(processVariables.get("employee") + " 想要请假 " + processVariables.get("nrOfHolidays") + " 天，你给不给嘛？(y or n)");

        // 通过输入y来判断允许或者拒绝请求
        // approved与holiday-request.bpmn20.xml中的网关匹配，决定路由到允许还是拒绝
        boolean approved = scanner.nextLine().toLowerCase().equals("y");
        variables = new HashMap<>();
        variables.put("approved", approved);
        // 完成任务
        taskService.complete(task.getId(), variables);

        // 历史数据处理，可以通过ProcessEngine来获取HistoryService，查询流程实例的持续时间等
        HistoryService historyService = processEngine.getHistoryService();
        List<HistoricActivityInstance> activities = historyService.createHistoricActivityInstanceQuery()
                .processInstanceId(processInstance.getId())
                .finished()
                .orderByHistoricActivityInstanceEndTime().asc() // 按结束时间排序，意味着按执行顺序进行排序
                .list();

        for (HistoricActivityInstance activity : activities){
            System.out.println(activity.getActivityId() + " took " + activity.getDurationInMillis() + " ms");
        }

    }

}

创建CallExternalSystemDelegate.java

路由到允许请求时执行的活动。

1
2
3
4
5
6
7
public class CallExternalSystemDelegate implements JavaDelegate {

    @Override
    public void execute(DelegateExecution delegateExecution) {
        System.out.println("发送批准文件给系统，同意 " + delegateExecution.getVariable("employee") + " 请假。");
    }
}

创建SendRejectionMail.java

路由到拒绝请求时执行的活动。

1
2
3
4
5
6
7
public class SendRejectionMail implements JavaDelegate {

    @Override
    public void execute(DelegateExecution delegateExecution) {
        System.out.println("发送拒绝邮件给 " + delegateExecution.getVariable("employee") + " ，不准请假。");
    }
}

项目地址： https://github.com/cenganhui/FlowableDemo
参考文档： https://flowable.com/open-source/docs/bpmn/ch02-GettingStarted/

扫一扫，分享到微信

微信分享二维码
本站总访问量次 | 本站访客数人次

tag:

    缺失模块。
    1、请确保node版本大于6.2
    2、在博客根目录（注意不是yilia根目录）执行以下命令：
    npm i hexo-generator-json-content --save

    3、在根目录_config.yml里添加配置： 

      jsonContent:
    meta: false
    pages: false
    posts:
      title: true
      date: true
      path: true
      text: false
      raw: false
      content: false
      slug: false
      updated: false
      comments: false
      link: false
      permalink: false
      excerpt: false
      categories: false
      tags: true

我是一个小码农