spring boot activiti工作流的搭建與簡(jiǎn)單使用
前言
最近一直研究springboot,根據(jù)工作需求,工作流需要作為一個(gè)單獨(dú)的微服務(wù)工程來提供給其他服務(wù)調(diào)用,現(xiàn)在簡(jiǎn)單的寫下工作流(使用的activiti)微服務(wù)的搭建與簡(jiǎn)單使用
jdk:1.8
數(shù)據(jù)庫:mysql 5.7
IDE:eclipse
springboot:1.5.8
activiti:6.0.0
1.新建空白的maven微服務(wù)架構(gòu)
新建maven項(xiàng)目的流程不在闡述,這里添加上activiti、myslq連接的依賴,只貼主要代碼
pox.xml
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.xxx</groupId> <artifactId>xxx</artifactId> <version>0.0.1-SNAPSHOT</version> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <java.version>1.8</java.version> </properties> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.8.RELEASE</version> </parent> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.activiti</groupId> <artifactId>activiti-spring-boot-starter-basic</artifactId> <version>6.0.0</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-thymeleaf</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-tomcat</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
確認(rèn)服務(wù)是可用
2.連接服務(wù)名、服務(wù)端口、數(shù)據(jù)庫配置
在resources目錄下的application.properties(項(xiàng)目定位原因沒有使用yaml,可根據(jù)自己項(xiàng)目使用)
spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.url=jdbc:mysql://127.0.0.1:3306/activity?characterEncoding=utf8&useSSL=true spring.datasource.username=root spring.datasource.password=root spring.jpa.properties.hibernate.hbm2ddl.auto=update spring.jpa.show-sql=true server.port=8081 server.context-path=/activity server.session.timeout=10 server.tomcat.uri-encoding=UTF-8
確認(rèn)配置的數(shù)據(jù)庫可用
3.main
import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; /** * Created by Guo on 2017/11/15. */ @SpringBootApplication public class ActivityApp { public static void main(String[] args) { SpringApplication.run(ActivityApp.class, args); } }
4.service及實(shí)現(xiàn)
service:
import org.activiti.engine.task.TaskQuery; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; @RestController @RequestMapping("/activityService") public interface ActivityConsumerService { /** * 流程demo * @return */ @RequestMapping(value="/startActivityDemo",method=RequestMethod.GET) public boolean startActivityDemo(); }
impl
import java.util.HashMap; import java.util.Map; import org.activiti.engine.RuntimeService; import org.activiti.engine.TaskService; import org.activiti.engine.impl.persistence.entity.ExecutionEntity; import org.activiti.engine.task.Task; import org.activiti.engine.task.TaskQuery; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.hongguaninfo.activity.service.ActivityConsumerService; @Service("activityService") public class ActivityConsumerServiceImpl implements ActivityConsumerService { @Autowired private RuntimeService runtimeService; @Autowired private TaskService taskService; @Override public boolean startActivityDemo() { System.out.println("method startActivityDemo begin...."); Map<String,Object> map = new HashMap<String,Object>(); map.put("apply","zhangsan"); map.put("approve","lisi"); //流程啟動(dòng) ExecutionEntity pi1 = (ExecutionEntity) runtimeService.startProcessInstanceByKey("leave",map); String processId = pi1.getId(); String taskId = pi1.getTasks().get(0).getId(); taskService.complete(taskId, map);//完成第一步申請(qǐng) Task task = taskService.createTaskQuery().processInstanceId(processId).singleResult(); String taskId2 = task.getId(); map.put("pass", false); taskService.complete(taskId2, map);//駁回申請(qǐng) System.out.println("method startActivityDemo end...."); return false; } }
5.bpmn
在resources目錄下新建文件夾:processes,并在processes創(chuàng)建一個(gè)新的bpmn文件,如圖
文件內(nèi)容:
<?xml version="1.0" encoding="UTF-8"?> <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/testm1510735932336" id="m1510735932336" name=""> <process id="leave" isExecutable="true" isClosed="false" processType="None"> <startEvent id="_2" name="StartEvent"></startEvent> <endEvent id="_3" name="EndEvent"></endEvent> <userTask id="approve" name="經(jīng)理審批" activiti:assignee="${approve}"></userTask> <exclusiveGateway id="_5" name="ExclusiveGateway"></exclusiveGateway> <sequenceFlow id="_6" sourceRef="approve" targetRef="_5"></sequenceFlow> <sequenceFlow id="_7" name="通過" sourceRef="_5" targetRef="_3"> <conditionExpression xsi:type="tFormalExpression"><![CDATA[${pass}]]></conditionExpression> </sequenceFlow> <userTask id="application" name="提交申請(qǐng)" activiti:assignee="${apply}"></userTask> <sequenceFlow id="_9" sourceRef="_2" targetRef="application"></sequenceFlow> <sequenceFlow id="_10" sourceRef="application" targetRef="approve"></sequenceFlow> <userTask id="modify" name="修改申請(qǐng)" activiti:assignee="${apply}"></userTask> <sequenceFlow id="_12" name="不通過" sourceRef="_5" targetRef="modify"> <conditionExpression xsi:type="tFormalExpression"><![CDATA[${!pass}]]></conditionExpression> </sequenceFlow> <sequenceFlow id="_13" sourceRef="modify" targetRef="approve"></sequenceFlow> </process> <bpmndi:BPMNDiagram id="BPMNDiagram_leave"> <bpmndi:BPMNPlane bpmnElement="leave" id="BPMNPlane_leave"> <bpmndi:BPMNShape bpmnElement="_2" id="BPMNShape__2"> <omgdc:Bounds height="35.0" width="35.0" x="15.0" y="60.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNShape bpmnElement="_3" id="BPMNShape__3"> <omgdc:Bounds height="35.0" width="35.0" x="630.0" y="63.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNShape bpmnElement="approve" id="BPMNShape_approve"> <omgdc:Bounds height="55.0" width="85.0" x="315.0" y="50.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNShape bpmnElement="_5" id="BPMNShape__5"> <omgdc:Bounds height="40.0" width="40.0" x="505.0" y="60.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNShape bpmnElement="application" id="BPMNShape_application"> <omgdc:Bounds height="55.0" width="85.0" x="135.0" y="50.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNShape bpmnElement="modify" id="BPMNShape_modify"> <omgdc:Bounds height="55.0" width="85.0" x="315.0" y="150.0"></omgdc:Bounds> </bpmndi:BPMNShape> <bpmndi:BPMNEdge bpmnElement="_6" id="BPMNEdge__6"> <omgdi:waypoint x="400.0" y="77.0"></omgdi:waypoint> <omgdi:waypoint x="505.0" y="80.0"></omgdi:waypoint> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge bpmnElement="_7" id="BPMNEdge__7"> <omgdi:waypoint x="545.0" y="80.0"></omgdi:waypoint> <omgdi:waypoint x="630.0" y="80.0"></omgdi:waypoint> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge bpmnElement="_9" id="BPMNEdge__9"> <omgdi:waypoint x="50.0" y="77.0"></omgdi:waypoint> <omgdi:waypoint x="135.0" y="77.0"></omgdi:waypoint> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge bpmnElement="_10" id="BPMNEdge__10"> <omgdi:waypoint x="220.0" y="77.0"></omgdi:waypoint> <omgdi:waypoint x="315.0" y="77.0"></omgdi:waypoint> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge bpmnElement="_12" id="BPMNEdge__12"> <omgdi:waypoint x="525.0" y="100.0"></omgdi:waypoint> <omgdi:waypoint x="525.0" y="177.0"></omgdi:waypoint> <omgdi:waypoint x="400.0" y="177.0"></omgdi:waypoint> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge bpmnElement="_13" id="BPMNEdge__13"> <omgdi:waypoint x="357.0" y="150.0"></omgdi:waypoint> <omgdi:waypoint x="357.0" y="105.0"></omgdi:waypoint> </bpmndi:BPMNEdge> </bpmndi:BPMNPlane> </bpmndi:BPMNDiagram> </definitions>
需要認(rèn)知的問題:.項(xiàng)目啟動(dòng)的時(shí)候,activiti會(huì)自動(dòng)在mysql中創(chuàng)建activiti相關(guān)表,不用像oracle那樣需要手動(dòng)去創(chuàng)建
6.驗(yàn)證
啟動(dòng)項(xiàng)目前,連接數(shù)據(jù)庫,查看需要連接數(shù)據(jù)庫中沒有表,啟動(dòng)項(xiàng)目完成后,刷新數(shù)據(jù)庫,activiti已經(jīng)創(chuàng)建相關(guān)表,打開act_re_procdef表,流程數(shù)據(jù)已經(jīng)存在,即流程已經(jīng)部署成功。
用瀏覽器訪問地址:http://127.0.0.1:8081/activity/activityService/startActivityDemo
打印了預(yù)計(jì)的日志,沒有報(bào)錯(cuò)信息,查看數(shù)據(jù)庫中的act_ru_task表,發(fā)現(xiàn)剛才執(zhí)行形成的數(shù)據(jù),項(xiàng)目成功。
PS:只是簡(jiǎn)單的微服務(wù),沒有去寫注冊(cè)服務(wù)、網(wǎng)關(guān)配置、熔斷機(jī)制等等,僅用于activiti與springboot的結(jié)合
=========================后續(xù)==========================
1.在項(xiàng)目單獨(dú)作為一個(gè)引擎,本身不部署流程的時(shí)候,如果resources目錄沒有“processes”目錄,啟動(dòng)項(xiàng)目報(bào)錯(cuò)--找不到processes目錄。需要在配置文件中添加一下內(nèi)容:
spring: activiti: ####校驗(yàn)流程文件,默認(rèn)校驗(yàn)resources下的processes文件夾里的流程文件 check-process-definitions: false
即啟動(dòng)項(xiàng)目,不去校驗(yàn)processes。
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了,希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,如果有疑問大家可以留言交流,謝謝大家對(duì)腳本之家的支持。
相關(guān)文章
JavaFX桌面應(yīng)用未響應(yīng)問題解決方案
這篇文章主要介紹了JavaFX桌面應(yīng)用未響應(yīng)問題解決方案,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-07-07Java中java.lang.ClassCastException異常原因以及解決方法詳解
這篇文章主要給大家介紹了關(guān)于Java中java.lang.ClassCastException異常原因以及解決方法的相關(guān)資料,ClassCastException從字面上看是類型轉(zhuǎn)換錯(cuò)誤,通常是進(jìn)行強(qiáng)制類型轉(zhuǎn)換時(shí)候出的錯(cuò)誤,需要的朋友可以參考下2024-02-02springBoot前后端分離項(xiàng)目中shiro的302跳轉(zhuǎn)問題
這篇文章主要介紹了springBoot前后端分離項(xiàng)目中shiro的302跳轉(zhuǎn)問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-12-12搭建Spring MVC和Vue3的應(yīng)用程序的實(shí)現(xiàn)
本文主要介紹了搭建Spring MVC和Vue3的應(yīng)用程序的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-11-11Java設(shè)置JSON字符串參數(shù)編碼的示例詳解
在Java中創(chuàng)建JSON字符串,我們可以使用多個(gè)庫,其中最流行的是Jackson、Gson和org.json,,下面給大家分享Java設(shè)置JSON字符串參數(shù)編碼的示例,感興趣的朋友一起看看吧2024-06-06Java服務(wù)如何調(diào)用系統(tǒng)指令、Bat腳本記錄
這篇文章主要介紹了Java服務(wù)如何調(diào)用系統(tǒng)指令、Bat腳本記錄,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-06-06SpringBoot整合MongoDB完整實(shí)例代碼
本文主要介紹了SpringBoot整合MongoDB完整實(shí)例,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-02-02Java線程之鎖對(duì)象Lock-同步問題更完美的處理方式代碼實(shí)例
這篇文章主要介紹了Java線程之鎖對(duì)象Lock-同步問題更完美的處理方式代碼實(shí)例,還是挺不錯(cuò)的,這里分享給大家,需要的朋友可以參考。2017-11-11