Springboot 2.0.3.RELEASE 與 activiti 5.22.0 整合
阿新 • • 發佈：2018-12-20
activiti Spring boot 整合原始碼
專案採用Springboot 2.0.3.RELEASE版本以及activiti 5.22.0版本
在acitiviti官網下載完整包https://github.com/Activiti/Activiti/releases/tag/activiti-5.22.0
下載完成後
1、將Activiti-activiti-5.22.0\modules\activiti-webapp-explorer2\src\main\webapp下的diagram-viewer、editor-app以及modeler.html檔案放置在專案resources\static資料夾下。
2、將Activiti-activiti-5.22.0\modules\activiti-webapp-explorer2\src\resources下的stencilset.json放置在專案resources\static資料夾下。
3、將Activiti-activiti-5.22.0\modules\activiti-modeler\src\main\java\org\activiti\rest\editor下的main以及model中的java檔案放置到專案mian\java目錄下
複製完成後，首先將ModelEditoeJsonRestResource.java、ModelSaveRestResource.java、StencilsetRestResource.java上新增 @RequestMapping(value = “/service”)
然後修改resources\static\editor-app\app-cfg.js，如下圖
修改ModelSaveRestResource.java，如下（參考https://blog.csdn.net/qq_21770005/article/details/78713912）
@RestController @RequestMapping(value = "/service") public class ModelSaveRestResource implements ModelDataJsonConstants { private static final Logger LOGGER = LogManager.getLogger(ModelSaveRestResource.class); @Autowired private RepositoryService repositoryService; @Autowired private ObjectMapper objectMapper; @RequestMapping(value="/model/{modelId}/save", method = RequestMethod.PUT) @ResponseStatus(value = HttpStatus.OK) public void saveModel(@PathVariable String modelId, @RequestParam("name") String name, @RequestParam("json_xml") String json_xml, @RequestParam("svg_xml") String svg_xml, @RequestParam("description") String description) { try { Model model = repositoryService.getModel(modelId); ObjectNode modelJson = (ObjectNode) objectMapper.readTree(model.getMetaInfo()); modelJson.put(MODEL_NAME, name); modelJson.put(MODEL_DESCRIPTION, description); model.setMetaInfo(modelJson.toString()); model.setName(name); repositoryService.saveModel(model); repositoryService.addModelEditorSource(model.getId(), json_xml.getBytes("utf-8")); InputStream svgStream = new ByteArrayInputStream(svg_xml.getBytes("utf-8")); TranscoderInput input = new TranscoderInput(svgStream); PNGTranscoder transcoder = new PNGTranscoder(); // Setup output ByteArrayOutputStream outStream = new ByteArrayOutputStream(); TranscoderOutput output = new TranscoderOutput(outStream); // Do the transformation transcoder.transcode(input, output); final byte[] result = outStream.toByteArray(); repositoryService.addModelEditorSourceExtra(model.getId(), result); outStream.close(); } catch (Exception e) { LOGGER.error("Error saving model", e); throw new ActivitiException("Error saving model", e); } } }
在pom.xml新增activiti依賴
<!--activiti-->
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-spring-boot-starter-basic</artifactId>
<version>${activiti.version}</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-spring-boot-starter-actuator</artifactId>
<version>${activiti.version}</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-rest</artifactId>
<version>${activiti.version}</version>
</dependency>
<dependency>
<groupId>org.apache.xmlgraphics</groupId>
<artifactId>batik-codec</artifactId>
<version>1.7</version>
</dependency>
<dependency>
<groupId>org.apache.xmlgraphics</groupId>
<artifactId>batik-css</artifactId>
<version>1.7</version>
</dependency>
<dependency>
<groupId>org.apache.xmlgraphics</groupId>
<artifactId>batik-svg-dom</artifactId>
<version>1.7</version>
</dependency>
<dependency>
<groupId>org.apache.xmlgraphics</groupId>
<artifactId>batik-svggen</artifactId>
<version>1.7</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-explorer</artifactId>
<version>${activiti.version}</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-diagram-rest</artifactId>
<version>${activiti.version}</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-simple-workflow</artifactId>
<version>${activiti.version}</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-spring</artifactId>
<version>${activiti.version}</version>
</dependency>
<!-- END activiti -->
在application.yml中新增activiti的資料來源，如下
spring:
datasource:
activiti:
url: jdbc:mysql://localhost:3306/activity?useUnicode=true&characterEncoding=utf8&useSSL=false
username: root
password: 123
driverClassName: com.mysql.jdbc.Driver
type: com.alibaba.druid.pool.DruidDataSource
新增activiti資料來源配置類
@Configuration
public class ActitytiDataSourceConfig extends AbstractProcessEngineAutoConfiguration {
private static final Logger log = LogManager.getLogger(ActitytiDataSourceConfig.class);
@Bean(name = "activitiDataSource")
@ConfigurationProperties(prefix = "spring.datasource.activiti")
public DataSource activitiDataSource(){
log.info("activitiDataSource 初始化...");
return new DruidDataSource();
}
@Bean
public PlatformTransactionManager transactionManager() {
return new DataSourceTransactionManager(activitiDataSource());
}
@Bean
public SpringProcessEngineConfiguration springProcessEngineConfiguration() {
SpringProcessEngineConfiguration configuration = new SpringProcessEngineConfiguration();
configuration.setDataSource(activitiDataSource());
configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
configuration.setJobExecutorActivate(true);
configuration.setTransactionManager(transactionManager());
return configuration;
}
}
以上，基本配置已完成。在啟動專案後，將自動建立activiti所需要的25張表。
如報錯無法啟動，在application.yml中新增
spring:
activiti:
check-process-definitions: false
成功啟動專案後，發現訪問專案任何路徑都需要輸入使用者名稱和密碼。這是因為acitivi-rest中集成了spring-security，需要在啟動類上新增
@EnableAutoConfiguration(exclude={org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class, org.activiti.spring.boot.SecurityAutoConfiguration.class})
訪問http://localhost:8080/modeler.html，發現頁面未顯示內容，這是因為目前還未建立任何model
此時建立ActivitiModelController.java，如下
@Controller
public class ActivitiModelController {
private static final Logger log = LogManager.getLogger(ActivitiModelController.class);
@Autowired
ProcessEngine processEngine;
@Autowired
ObjectMapper objectMapper;
/**
* 新建一個空模型
*/
@RequestMapping("/create")
public void newModel(HttpServletResponse response) throws IOException {
RepositoryService repositoryService = processEngine.getRepositoryService();
//初始化一個空模型
Model model = repositoryService.newModel();
//設定一些預設資訊
String name = "new-process";
String description = "";
int revision = 1;
String key = "process";
ObjectNode modelNode = objectMapper.createObjectNode();
modelNode.put(ModelDataJsonConstants.MODEL_NAME, name);
modelNode.put(ModelDataJsonConstants.MODEL_DESCRIPTION, description);
modelNode.put(ModelDataJsonConstants.MODEL_REVISION, revision);
model.setName(name);
model.setKey(key);
model.setMetaInfo(modelNode.toString());
repositoryService.saveModel(model);
String id = model.getId();
//完善ModelEditorSource
ObjectNode editorNode = objectMapper.createObjectNode();
editorNode.put("id", "canvas");
editorNode.put("resourceId", "canvas");
ObjectNode stencilSetNode = objectMapper.createObjectNode();
stencilSetNode.put("namespace",
"http://b3mn.org/stencilset/bpmn2.0#");
editorNode.put("stencilset", stencilSetNode);
repositoryService.addModelEditorSource(id,editorNode.toString().getBytes("utf-8"));
response.sendRedirect("/modeler.html?modelId="+id);
}
/**
* 獲取所有模型
*/
@RequestMapping("/modelList")
@ResponseBody
public Object modelList(){
RepositoryService repositoryService = processEngine.getRepositoryService();
return repositoryService.createModelQuery().list();
}
/**
* 釋出模型為流程定義
*/
@RequestMapping("/deploy")
@ResponseBody
public Object deploy(String modelId) throws Exception {
//獲取模型
RepositoryService repositoryService = processEngine.getRepositoryService();
Model modelData = repositoryService.getModel(modelId);
byte[] bytes = repositoryService.getModelEditorSource(modelData.getId());
if (bytes == null) {
return "模型資料為空，請先設計流程併成功儲存，再進行釋出。";
}
JsonNode modelNode = new ObjectMapper().readTree(bytes);
BpmnModel model = new BpmnJsonConverter().convertToBpmnModel(modelNode);
if(model.getProcesses().size()==0){
return "資料模型不符要求，請至少設計一條主線流程。";
}
byte[] bpmnBytes = new BpmnXMLConverter().convertToXML(model);
//釋出流程
String processName = modelData.getName() + ".bpmn20.xml";
Deployment deployment = repositoryService.createDeployment()
.name(modelData.getName())
.addString(processName, new String(bpmnBytes, "UTF-8"))
.deploy();
modelData.setDeploymentId(deployment.getId());
repositoryService.saveModel(modelData);
return "SUCCESS";
}
/**
* 啟動流程
*/
@RequestMapping("/start")
@ResponseBody
public Object startProcess(String keyName) {
ProcessInstance process = processEngine.getRuntimeService().startProcessInstanceByKey(keyName);
return process.getId() + " : " + process.getProcessDefinitionId();
}
/**
* 提交任務
*/
@RequestMapping("/run")
@ResponseBody
public Object run(String processInstanceId) {
Task task = processEngine.getTaskService().createTaskQuery().processInstanceId(processInstanceId).singleResult();
log.info("task {} find ", task.getId());
processEngine.getTaskService().complete(task.getId());
return "SUCCESS";
}
}
通過訪問http://localhost:8080/create建立一個空白的model並跳轉到編輯頁面
在繪製流程完成後，訪問http://localhost:8080/deploy?modelId=1 對該流程進行部署
至此，springboot整合activiti modeler完成
需要原始碼，請及時聯絡我。Q:470801428