JBPM 流程定义管理与操作实践 | 极客日志

Javajava

JBPM 流程定义管理与操作实践

JBPM 流程定义管理涉及部署、查询、删除及资源获取。通过 RepositoryService 可实现 jpdl.xml 文件的部署与版本控制。支持类路径单文件添加或 ZIP 包批量部署。查询时可按版本排序筛选最新定义，删除需注意级联策略。此外可获取流程图资源及活动坐标信息，便于流程可视化与管理。

MongoKing发布于 2025/1/18更新于 2026/4/251 浏览

JBPM 流程定义管理与操作实践

JBPM 流程定义管理

在 JBPM 中，流程定义（ProcessDefinition）是核心概念，它描述了业务流程的步骤和规则。通常我们将其解析为 .jpdl.xml 文件得到流程步骤的信息。没有更新操作时，启动流程实例会使用指定 key 的最新版本。

1. 部署流程定义

部署是将流程资源注册到引擎的过程。支持从类路径添加单个资源，或者批量添加 ZIP 包。

单文件部署

如果资源分散在 Classpath 中，可以多次调用 addResourceFromClasspath。即使重复添加也不会报错，但建议保持资源整洁。

@Test
public void deploy_1() {
    String deploymentId = processEngine.getRepositoryService()
        .createDeployment()
        .addResourceFromClasspath("helloworld/test.jpdl.xml")
        .addResourceFromClasspath("helloworld/test.png")
        .deploy();
    System.out.println("deploymentId = " + deploymentId);
}

批量部署

对于多个资源，可以先打成 ZIP 包，然后使用 ZipInputStream 进行部署。这种方式适合包含子目录结构的复杂项目。

@Test
public void deploy_2() throws IOException {
    InputStream in = this.getClass().getClassLoader().getResourceAsStream("helloworld/helloworld.zip");
    ZipInputStream zipInputStream = new ZipInputStream(in);
    
    String deploymentId = processEngine.getRepositoryService()
        .createDeployment()
        .addResourcesFromZipInputStream(zipInputStream)
        .deploy();
    System.out.println("deploymentId = " + deploymentId);
}

注意： 除了上述方法，还可以使用添加单个流式文件。以上方法可以组合调用，灵活性很高。

addResourceFromInputStream

@Test
public void findAll() {
    List<ProcessDefinition> list = processEngine.getRepositoryService()
        .createProcessDefinitionQuery()
        .orderAsc(ProcessDefinitionQuery.PROPERTY_KEY)
        .list();

    for (ProcessDefinition pd : list) {
        System.out.println("id=" + pd.getId() + 
                           ", name=" + pd.getName() + 
                           ", key=" + pd.getKey() + 
                           ", version=" + pd.getVersion() + 
                           ", deploymentId=" + pd.getDeploymentId());
    }
}

@Test
public void findAllLatestVersions() {
    // 先按版本号升序排列，这样相同 key 的最后一条就是最新版
    List<ProcessDefinition> allList = processEngine.getRepositoryService()
        .createProcessDefinitionQuery()
        .orderAsc(ProcessDefinitionQuery.PROPERTY_VERSION)
        .list();

    Map<String, ProcessDefinition> map = new HashMap<>();
    for (ProcessDefinition pd : allList) {
        map.put(pd.getKey(), pd); // 后出现的会覆盖前面的，保留最新
    }

    for (ProcessDefinition pd : map.values()) {
        System.out.println("latest: id=" + pd.getId() + 
                           ", version=" + pd.getVersion());
    }
}

@Test
public void deleteById() {
    String deploymentId = "1";
    // 如果有关联的执行信息，普通 delete 会抛异常
    // processEngine.getRepositoryService().deleteDeployment(deploymentId);
    
    // 级联删除，强制清理关联数据
    processEngine.getRepositoryService().deleteDeploymentCascade(deploymentId);
}

@Test
public void deleteByKey() {
    List<ProcessDefinition> list = processEngine.getRepositoryService()
        .createProcessDefinitionQuery()
        .processDefinitionKey("helloworld")
        .list();

    for (ProcessDefinition pd : list) {
        processEngine.getRepositoryService().deleteDeploymentCascade(pd.getDeploymentId());
    }
}

@Test
public void getResourceFromDeployment() throws Exception {
    String deploymentId = "50001";
    String resourceName = "helloworld/test.png";

    // 获取该部署下所有文件名
    Set<String> names = processEngine.getRepositoryService().getResourceNames(deploymentId);
    for (String name : names) {
        System.out.println(name);
    }

    // 获取指定资源流并保存
    InputStream in = processEngine.getRepositoryService().getResourceAsStream(deploymentId, resourceName);
    OutputStream out = new FileOutputStream("c:/process.png");
    int b;
    while ((b = in.read()) != -1) {
        out.write(b);
    }
    in.close();
    out.close();
}

String processDefinitionId = "test-1";
String activityName = "start1";
ActivityCoordinates c = processEngine.getRepositoryService().getActivityCoordinates(processDefinitionId, activityName);
System.out.println("x=" + c.getX() + ",y=" + c.getY() + ",width=" + c.getWidth() + ",height=" + c.getHeight());