Flowable 工作流引擎实战：从 JBPM 起源到 70 张 BPMN 数据库表全解

1
2
3
4
5
6
7
8

-- 1. 读取 BPMN XML
INSERT INTO act_ge_bytearray(name, bytes, ...) VALUES (..., ?, ...);

-- 2. 部署记录
INSERT INTO act_re_deployment(name, deploy_time, ...) VALUES (..., ?, ...);

-- 3. 流程定义
INSERT INTO act_re_procdef(name, key, version, deployment_id, ...) VALUES (..., ?, ?, ?, ...);

1
2
3
4
5

-- 运行时实例
INSERT INTO act_ru_execution(proc_inst_id, proc_def_id, ...) VALUES (?, ?, ...);
INSERT INTO act_ru_actinst(proc_inst_id, act_id, ...) VALUES (?, ?, ...);
INSERT INTO act_ru_task(id, execution_id, assignee, ...) VALUES (?, ?, ?, ...);
INSERT INTO act_ru_variable(type, name, execution_id, ...) VALUES (?, ?, ?, ...);

1
2
3
4
5
6
7

-- 查询待办
SELECT * FROM act_ru_task WHERE assignee = ? AND proc_def_id = ?;

-- 完成任务
DELETE FROM act_ru_task WHERE id = ?;
DELETE FROM act_ru_variable WHERE execution_id = ?;
UPDATE act_ru_execution SET act_id = ? WHERE id = ?;

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

-- 删除运行时数据
DELETE FROM act_ru_execution WHERE proc_inst_id = ?;
DELETE FROM act_ru_task WHERE execution_id IN (...);
DELETE FROM act_ru_variable WHERE execution_id IN (...);
DELETE FROM act_ru_identitylink WHERE proc_inst_id = ?;

-- 写入历史
INSERT INTO act_hi_procinst(...) VALUES (...);
INSERT INTO act_hi_taskinst(...) VALUES (...);
INSERT INTO act_hi_varinst(...) VALUES (...);

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

# 下载 Flowable 6.8
wget https://github.com/flowable/flowable-engine/releases/download/flowable-6.8.0/flowable-6.8.0.zip
unzip flowable-6.8.0.zip
cd flowable-6.8.0

# 启动（默认 H2 内存数据库）
java -jar flowable-ui.war

# 浏览器访问
# http://localhost:8080/flowable-ui/#/
# 默认账号: admin / test

1
2
3
4
5

<dependency>
    <groupId>org.flowable</groupId>
    <artifactId>flowable-spring-boot-starter</artifactId>
    <version>6.8.0</version>
</dependency>

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

# application.yml
spring:
  datasource:
    url: jdbc:mysql://{{MYSQL_HOST}}:3306/flowable?useUnicode=true&characterEncoding=UTF-8
    username: {{DB_USER}}
    password: {{DB_PASSWORD}}
flowable:
  database-schema-update: true   # 启动时自动建表
  async-executor-enabled: true   # 启用异步执行器
  cmmn-enabled: false            # 关闭 CMMN（按需）
  dmn-enabled: false             # 关闭 DMN
  history-level: audit           # 历史级别：none/activity/audit/full

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17

@Autowired
private RepositoryService repositoryService;

@Autowired
private RuntimeService runtimeService;

public void deployAndStart() {
    // 1. 部署 BPMN 流程
    Deployment deploy = repositoryService.createDeployment()
        .addClasspathResource("bpmn/leave.bpmn20.xml")
        .name("请假流程")
        .deploy();

    // 2. 启动流程实例
    ProcessInstance pi = runtimeService.startProcessInstanceByKey("leave");
    System.out.println("流程实例 ID: " + pi.getId());
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

@Autowired
private TaskService taskService;

public void completeTask(String assignee) {
    // 查询待办
    List<Task> tasks = taskService.createTaskQuery()
        .taskAssignee(assignee)
        .list();

    for (Task task : tasks) {
        System.out.println("任务: " + task.getName() + ", 流程实例: " + task.getProcessInstanceId());

        // 完成任务
        taskService.complete(task.getId());
    }
}

1
2
3
4
5

<dependency>
    <groupId>org.flowable</groupId>
    <artifactId>flowable-spring-boot-starter</artifactId>
    <version>7.0.0</version>
</dependency>

1
2
3
4
5
6
7

Spring Cloud 微服务
        ↓
   Zeebe Client (gRPC)
        ↓
   Zeebe Broker (分区)
        ↓
   Operate / Tasklist / Optimize (Web UI)

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

# application.yml
spring:
  datasource:
    url: jdbc:postgresql://pg:5432/flowable
    username: flowable
    password: ${DB_PASSWORD}
  jpa:
    database-platform: org.hibernate.dialect.PostgreSQLDialect

flowable:
  # V7 配置变更
  database-schema-update: true
  cmmn-enabled: true              # 7.0 起重新开启
  dmn-enabled: true
  history-level: full
  # 异步执行器
  async-executor:
    core-pool-size: 10
    max-pool-size: 50
    queue-capacity: 200
  # V7 新增：API 兼容性
  rest-api:
    enabled: true
    base-url: /flowable-api

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

工作流引擎怎么选（2024+）？
├── 中小 OA / 审批 / < 100 TPS
│   ├── 已有 Spring 团队 → Flowable 7
│   ├── 不想运维 → Camunda 8 SaaS
│   └── 简单 CRON 任务 → 直接用 @Scheduled
├── 中大型企业 / 规则密集 / DMN 多
│   └── Camunda 7（成熟稳定 + 商业支持）
├── 微服务编排 / 1000+ TPS / 云原生
│   └── Camunda 8（Zeebe 架构）
├── 大数据 ETL / 跨系统编排
│   └── Apache Airflow / DolphinScheduler
└── K8s 原生 DAG
    └── Argo Workflows / Temporal