1

我在将 Camunda BPMN 与 springboot 集成时遇到问题，我创建了包含 Camunda 引擎配置的文件

@Bean
public SpringProcessEngineConfiguration processEngineConfiguration() {
   SpringProcessEngineConfiguration config = new SpringProcessEngineConfiguration();
   log.info("--------------------SpringProcessEngineConfiguration ");

  config.setDataSource(datasource);
  PlatformTransactionManager platformTransactionManager=new JpaTransactionManager(entityManagerFactory);
  config.setTransactionManager(platformTransactionManager);

  config.setDatabaseSchemaUpdate("true");
  config.setHistory("audit");
  config.setJobExecutorActivate(true);
  config.setApplicationContext(applicationContext);
  return config;
}

@Bean
public ProcessEngineFactoryBean processEngine() {
  log.info("--------------------processEngine ");
  ProcessEngineFactoryBean factoryBean = new ProcessEngineFactoryBean();
  factoryBean.setProcessEngineConfiguration(processEngineConfiguration());
  factoryBean.setApplicationContext(applicationContext);
  return factoryBean;
}

@Bean
public RepositoryService repositoryService(ProcessEngine processEngine) {
  log.info("--------------------repositoryService ");
  return processEngine.getRepositoryService();
}

@Bean
public RuntimeService runtimeService(ProcessEngine processEngine) {
   log.info("--------------------runtimeService ");
   return processEngine.getRuntimeService();
 }

@Bean
public TaskService taskService(ProcessEngine processEngine) {
   log.info("-------------------- taskService ");
   return processEngine.getTaskService();
}

我确实成功部署了这个过程，我猜：我发现 2 个表只有数据，ACT_RE_DEPLOYMENT并且ACT_GE_BYTEARRAY.

但是，在尝试从任何已部署的进程启动实例时，我总是遇到错误。


            ProcessEngine processEngine = restProcessEngineProvider.getDefaultProcessEngine();
            log.info("processEngine {} ",processEngine.getName());
            RuntimeService runtimeService = processEngine.getRuntimeService();
            log.info("runtimeService");
            RepositoryService repositoryService = processEngine.getRepositoryService();
            log.info("repositoryService");
            InputStream stream = new ByteArrayInputStream(process.getLastXmlDefinition().getBytes(Charset.defaultCharset()));
            DeploymentEntity deploymentResult;
            try {
                deploymentResult = (DeploymentEntity) repositoryService.createDeployment()
                        .name(name)
                        .addInputStream(name, stream).deploy();             
             List<ProcessDefinition> processes=   deploymentResult.getDeployedProcessDefinitions();          
             if (processes!=null)
             {
                 log.info("process not null {} ",processes.size());
             }
             else
             {
                 log.info("process null");
             }
            } finally {
                stream.close();
            }

            //read the result
            String deploymentId = deploymentResult.getId();
            log.info("deployement id {} ",deploymentId);
            ProcessDefinition processDef = repositoryService.createProcessDefinitionQuery()
                    .processDefinitionName(name)
                    .singleResult();
            log.info("process def ...");
            //return the process definition id for later query
            String processDefinitionId="";
            if (processDef!=null)
            {
                if (processDef.getId()!=null)
                 processDefinitionId = processDef.getId();
                else
                    log.info("process def id is null");
            }
            else

            {
                log.info("process def null ");
            }

            log.info("deployed success {} ",processDefinitionId);
            runtimeService.startProcessInstanceByKey(name);

总是得到空进程 def org.camunda.bpm.engine.exception.NullValueException: no processes deploy with key ...

4

1 回答 1

1

我找到了一种方法来回答我自己的问题，我想我应该把它贴在这里

String fileXML=""; // set here process  xml 
ProcessEngine processEngine = restProcessEngineProvider.getDefaultProcessEngine();

RuntimeService runtimeService = processEngine.getRuntimeService();

RepositoryService repositoryService = processEngine.getRepositoryService();
InputStream stream = new ByteArrayInputStream(fileXML);
DeploymentEntity deploymentResult;

String deploiementBuild = name + "deploiement";
DeploymentBuilder deploymentBuilder = repositoryService.createDeployment().name(deploiementBuild);
String definitionName = name + ".bpmn";

deploymentBuilder.addInputStream(definitionName, stream);
String deploymentId = deploymentBuilder.deploy().getId();
log.info("depoiement -------------> {}", deploymentId);

List definitions = repositoryService.createProcessDefinitionQuery().list();
log.info("depoiement size ------------> {} ",definitions.size());
于 2019-11-14T09:15:04.800 回答