如何将Activiti存储在ACT_GE_BYTEARRAY表的BPMN文件转换为Camunda格式？

作为做过Activiti到Camunda迁移的开发者，我推荐用Camunda官方提供的BPMN Model API来实现这个需求，这是最稳妥、高效的方式——既能自动处理大部分兼容差异，也能灵活应对特殊场景。下面是详细的落地步骤：

1. 从Activiti数据库提取BPMN文件 #

首先得从ACT_GE_BYTEARRAY表中筛选并导出所有BPMN资源：

• 筛选规则：通过name_字段过滤，只提取以.bpmn或.bpmn20.xml结尾的记录（Activiti通常用这两种后缀存储BPMN文件）。
• 读取Blob数据：用JDBC或ORM框架（比如MyBatis）读取bytes_列的Blob，转换为InputStream或字符串格式供后续处理。

示例Java代码片段：

// 假设用JDBC连接Activiti数据库
String sql = "SELECT name_, bytes_ FROM ACT_GE_BYTEARRAY WHERE name_ LIKE '%.bpmn%' AND DEPLOYMENT_ID_ IS NOT NULL";
try (Connection conn = DriverManager.getConnection(url, user, pwd);
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery(sql)) {
    while (rs.next()) {
        String fileName = rs.getString("name_");
        Blob blob = rs.getBlob("bytes_");
        InputStream inputStream = blob.getBinaryStream();
        // 传递inputStream到后续转换逻辑
    }
}

2. 转换为Camunda兼容格式 #

Activiti和Camunda都遵循BPMN 2.0标准，但存在命名空间、扩展元素的细微差异，Camunda Model API能自动处理大部分基础兼容，剩下的特殊情况可以手动调整：

核心转换流程 #

• 加载Activiti BPMN模型：用Bpmn.readModelFromStream()读取原始BPMN文件，解析为BpmnModel对象。
• 自动兼容处理：Camunda的Model API会自动将Activiti的命名空间（http://activiti.org/bpmn）转换为Camunda的命名空间（http://camunda.org/schema/1.0/bpmn），并添加必要的扩展命名空间。
• 手动修复差异点：针对Activiti专属的扩展元素（比如activiti:taskListener、activiti:formProperty），替换为Camunda对应的元素（camunda:taskListener、camunda:formField）。

示例转换代码：

// 加载Activiti的BPMN模型
BpmnModel activitiModel = Bpmn.readModelFromStream(inputStream);

// 遍历所有用户任务，替换Activiti的taskListener为Camunda版本
for (UserTask userTask : activitiModel.getModelElementsByType(UserTask.class)) {
    List<ExtensionElement> activitiListeners = userTask.getExtensionElements().get("activiti:taskListener");
    if (activitiListeners != null) {
        for (ExtensionElement listener : activitiListeners) {
            listener.setNamespace("http://camunda.org/schema/1.0/bpmn");
            listener.setName("camunda:taskListener");
        }
        userTask.getExtensionElements().remove("activiti:taskListener");
        userTask.getExtensionElements().put("camunda:taskListener", activitiListeners);
    }
}

// 转换为Camunda兼容的XML字符串
String camundaBpmnXml = Bpmn.convertToString(activitiModel);

3. 批量验证转换结果 #

转换后必须验证BPMN文件是否能被Camunda正常解析和部署，避免后续运行报错：

• 用Camunda的RepositoryService尝试部署转换后的文件，部署成功说明格式合法；若失败则记录错误信息，手动修复问题文件。

示例验证代码：

ProcessEngine camundaEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = camundaEngine.getRepositoryService();

try {
    Deployment deployment = repositoryService.createDeployment()
            .addString(fileName, camundaBpmnXml)
            .deploy();
    // 验证完成后删除测试部署
    repositoryService.deleteDeployment(deployment.getId(), true);
} catch (Exception e) {
    System.err.println("转换失败的文件：" + fileName + "，错误信息：" + e.getMessage());
    // 将错误文件存入待处理目录，后续手动修复
}

4. 部署到Camunda环境 #

验证通过后，将转换后的BPMN文件正式部署到Camunda：

• 如果是全新部署，直接用RepositoryService.createDeployment()批量部署所有文件。
• 如果是从Activiti升级到Camunda（同数据库），不建议直接修改ACT_GE_BYTEARRAY表，最好重新部署转换后的BPMN，避免数据库关联数据不一致。

特殊场景处理 #

• 自定义扩展元素：如果Activiti中有自定义的BPMN扩展，需要手动映射到Camunda的自定义扩展或调整为Camunda支持的格式。
• 表达式差异：虽然两者都支持${}表达式，但部分内置函数（比如日期处理）可能有差异，需要逐一校验测试。

内容的提问来源于stack exchange，提问作者Vahid Alizadeh