Spring Boot中使用Activiti的方法教程（二）
前言
前面一節(jié)我們已經(jīng)了解了Activiti的基礎(chǔ)概念，包括流程定義的用語(yǔ)和它的API功能，已經(jīng)如何入手Activiti，在這一節(jié)我們將結(jié)合代碼具體學(xué)習(xí)使用。小圖是我們需要完成的請(qǐng)假流程圖：
正如我們?cè)趫D中看到的，這是一個(gè)非常簡(jiǎn)單的流程：?jiǎn)T工提出休假請(qǐng)求，提供休假天數(shù)和開(kāi)始日期。請(qǐng)求發(fā)送給經(jīng)理。他們可以批準(zhǔn)/拒絕該請(qǐng)求。
如果獲得批準(zhǔn)，則會(huì)定義一個(gè)服務(wù)任務(wù)serviceTask來(lái)發(fā)送確認(rèn)電子郵件。如果被拒絕，員工可以選擇修改并重新發(fā)送請(qǐng)求，也可以不執(zhí)行任何操作。
此流程的BPMN 2.0定義文件VacationRequest.bpmn20.xml將start事件定義為：
<startEvent id="startEvent" name="請(qǐng)假" activiti:initiator="employeeName">
<extensionElements>
<activiti:formProperty id="numberOfDays" name="Number of days" type="long"
required="true"/>
<activiti:formProperty id="startDate" name="Vacation start date (MM-dd-yyyy)"
type="date" datePattern="MM-dd-yyyy hh:mm" required="true"/>
<activiti:formProperty id="reason" name="Reason for leave" type="string"/>
<modeler:editor-resource-id><![CDATA[startEvent1]]></modeler:editor-resource-id>
</extensionElements>
</startEvent>
分配給用戶(hù)組“management”的第一個(gè)用戶(hù)任務(wù)userTask將如下所示：
<userTask id="handle_vacation_request" name="申請(qǐng)請(qǐng)假">
<documentation>${employeeName} 請(qǐng)假 ${numberOfDays} 天
(Motivation: ${reason}).
</documentation>
<extensionElements>
<activiti:formProperty id="vacationApproval"
name="你要批準(zhǔn)這個(gè)請(qǐng)假要求嗎？"
type="enum"
required="true"/>
<activiti:formProperty id="comments" name="經(jīng)理的批示" type="string"/>
<modeler:allow-send-email><![CDATA[true]]></modeler:allow-send-email>
<modeler:activiti-idm-initiator><![CDATA[true]]></modeler:activiti-idm-initiator>
<modeler:editor-resource-id>
<![CDATA[sid-B9AA8E66-2F11-45D0-A270-B052E1A9248E]]></modeler:editor-resource-id>
</extensionElements>
<potentialOwner>
<resourceAssignmentExpression>
<formalExpression>management</formalExpression>
</resourceAssignmentExpression>
</potentialOwner>
</userTask>
使用ServiceTask，我們需要定義要執(zhí)行的代碼段。我們將SendEmailServiceTask.java類(lèi)作為這段代碼執(zhí)行者。
<serviceTask id="send-email-confirmation" name="發(fā)送郵件確認(rèn)"
activiti:class="com.example.activitiwithspring.servicetasks.SendEmailServiceTask.java">
<extensionElements>
<modeler:editor-resource-id>
<![CDATA[sid-2C5E1831-9101-4F70-9AEF-4BA72B704205]]></modeler:editor-resource-id>
</extensionElements>
</serviceTask>
SendEmailServiceTask的代碼如下：實(shí)現(xiàn)JavaDelegate接口，實(shí)現(xiàn)其execute方法：
public class SendEmailServiceTask implements JavaDelegate {
public void execute(DelegateExecution execution) {
//logic to sent email confirmation
}
}
通過(guò)在“sequenceFlow”中添加“conditionExpression”標(biāo)記來(lái)決定發(fā)送郵件在什么條件下觸發(fā)，也就是定義一個(gè)條件流：
<sequenceFlow id="flow3" name="批準(zhǔn)"
sourceRef="sid-12A577AE-5227-4918-8DE1-DC077D70967C"
targetRef="send-email-confirmation">
<extensionElements>
<modeler:editor-resource-id>
<![CDATA[sid-609BEB69-E833-4D2F-BD14-FC8F7FD3E9C7]]></modeler:editor-resource-id>
</extensionElements>
<conditionExpression xsi:type="tFormalExpression">
<![CDATA[${vacationApproved == 'true'}]]></conditionExpression>
</sequenceFlow>
這里，vacationApproved是上面的UserTask的formProperty。
部署流程
為了使我們的流程被Activiti Engine所知，我們需要部署該流程。我們可以使用RepositoryService以編程方式執(zhí)行此操作。讓我們編寫(xiě)一個(gè)JUnit測(cè)試來(lái)看看：
@Test
public void givenBPMN_whenDeployProcess_thenDeployed() {
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
repositoryService.createDeployment()
.addClasspathResource("org/activiti/test/vacationRequest.bpmn20.xml")
.deploy();
Long count = repositoryService.createProcessDefinitionQuery().count();
assertTrue(count >= 1);
}
部署意味著引擎將解析BPMN流程定義文件并將其轉(zhuǎn)換為可執(zhí)行文件。此外，還會(huì)將記錄添加到每個(gè)部署的Repository表中。之后，我們可以查詢(xún)Repository服務(wù)從而獲取已部署的進(jìn)程：也就是ProcessDefinitions。
啟動(dòng)流程實(shí)例ProcessInstance
在將ProcessDefinition部署到Activiti Engine之后，我們可以通過(guò)創(chuàng)建ProcessInstances來(lái)執(zhí)行該流程定義。如果說(shuō)ProcessDefinition繪制的是一幅藍(lán)圖，那么processInstance就是它的執(zhí)行實(shí)現(xiàn)。
對(duì)于一個(gè)ProcessDefinition，可以有多個(gè)ProcessInstances。
可以通過(guò)RuntimeService訪問(wèn)與ProcessInstances相關(guān)的所有詳細(xì)信息。
在我們的示例中，在開(kāi)始事件中，我們需要傳遞休假天數(shù)、開(kāi)始日期和原因。我們將使用流程變量，并在創(chuàng)建ProcessInstance時(shí)傳遞它們。
編寫(xiě)一個(gè)JUnit測(cè)試用例實(shí)現(xiàn)上面想法：
@Test
public void givenDeployedProcess_whenStartProcessInstance_thenRunning() {
//deploy the process definition
Map<String, Object> variables = new HashMap >();
variables.put("employeeName", "John");
variables.put("numberOfDays", 4);
variables.put("vacationMotivation", "I need a break!");
RuntimeService runtimeService = processEngine.getRuntimeService();
ProcessInstance processInstance = runtimeService
.startProcessInstanceByKey("vacationRequest", variables);
Long count=runtimeService.createProcessInstanceQuery().count();
assertEquals("1", count.toString());
}
某個(gè)流程定義的多個(gè)實(shí)例將因流程變量而異，也就是說(shuō)，同一份流程定義，因?yàn)樽兞坎煌?，?dǎo)致流程實(shí)例也會(huì)不同。
有多種方法啟動(dòng)流程實(shí)例，在這里，我們正在使用該流程的key:vacationRequest啟動(dòng)流程，啟動(dòng)流程實(shí)例后，我們可以通過(guò)查詢(xún)RuntimeService來(lái)獲取有關(guān)它的信息。
完成任務(wù)
當(dāng)我們的流程實(shí)例開(kāi)始運(yùn)行時(shí)，第一步執(zhí)行的是用戶(hù)任務(wù)userTask，分配任務(wù)給用戶(hù)組“management”的用戶(hù)。該用戶(hù)可能有一個(gè)收件箱，其中包含要由他們完成的任務(wù)列表?，F(xiàn)在，如果我們想繼續(xù)執(zhí)行流程，則需要用戶(hù)完成此任務(wù)。對(duì)于Activiti Engine，它被稱(chēng)為“完成任務(wù)”。
我們可以查詢(xún)TaskService，獲取任務(wù)對(duì)象，然后完成它。
@Test
public void givenProcessInstance_whenCompleteTask_thenGotNextTask() {
// 部署流程并開(kāi)始一個(gè)流程實(shí)例
TaskService taskService = processEngine.getTaskService();
List<Task> tasks = taskService.createTaskQuery()
.taskCandidateGroup("management").list();
Task task = tasks.get(0);
Map<String, Object> taskVariables = new HashMap<>();
taskVariables.put("vacationApproved", "false");
taskVariables.put("comments", "We have a tight deadline!");
taskService.complete(task.getId(), taskVariables);
Task currentTask = taskService.createTaskQuery()
.taskName("修改休假請(qǐng)求").singleResult();
assertNotNull(currentTask);
}
請(qǐng)注意，TaskService的complete（）方法也接受所需的流程變量。我們傳遞了經(jīng)理的回復(fù)。
在此之后，流程引擎將繼續(xù)下一步。在這里，下一步詢(xún)問(wèn)員工是否要重新發(fā)送休假請(qǐng)求。
因此，我們的ProcessInstance正在等待此UserTask，其名稱(chēng)為“修改休假請(qǐng)求”。
暫停和激活流程
我們可以暫停ProcessDefinition和ProcessInstance。如果我們暫停一個(gè)流程定義ProcessDefinition，則在它暫停掛起時(shí)我們就無(wú)法創(chuàng)建它的實(shí)例。我們可以使用RepositoryService來(lái)做到這一點(diǎn)：
@Test(expected = ActivitiException.class)
public void givenDeployedProcess_whenSuspend_thenNoProcessInstance() {
// deploy the process definition
repositoryService.suspendProcessDefinitionByKey("vacationRequest");
runtimeService.startProcessInstanceByKey("vacationRequest");
}
要再次激活它，我們只需要調(diào)用其中一個(gè)repositoryService.activateProcessDefinitionXXX方法。
同樣，我們可以使用RuntimeService暫停ProcessInstance 。
結(jié)論
在本文中，我們了解了如何將Activiti與Spring Boot結(jié)合使用。我們創(chuàng)建了一個(gè)示例ProcessEngineCofiguration文件，它可以幫助我們創(chuàng)建ProcessEngine。ProcessEngine提供的服務(wù)幫助我們管理和跟蹤ProcessDefinitions，ProcessInstances，UserTasks等。
示例代碼位于GitHub上。
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)腳本之家的支持。
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了java刪除指定目錄下指定格式文件的方法，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2018-08-08
maven?解包依賴(lài)項(xiàng)中的文件的解決方法
Maven是java中的一種項(xiàng)目管理、項(xiàng)目構(gòu)建、依賴(lài)管理的工具，接下來(lái)通過(guò)本文給大家介紹maven?解包依賴(lài)項(xiàng)中的文件,需要的朋友可以參考下2022-07-07
Spring實(shí)現(xiàn)定時(shí)任務(wù)的幾種方式總結(jié)
Spring Task 是 Spring 框架提供的一種任務(wù)調(diào)度和異步處理的解決方案,可以按照約定的時(shí)間自動(dòng)執(zhí)行某個(gè)代碼邏輯它可以幫助開(kāi)發(fā)者在 Spring 應(yīng)用中輕松地實(shí)現(xiàn)定時(shí)任務(wù)、異步任務(wù)等功能,提高應(yīng)用的效率和可維護(hù)性,需要的朋友可以參考下本文2024-07-07
Java 日期格式加上指定月數(shù)(一個(gè)期限)得到一個(gè)新日期的實(shí)現(xiàn)代碼
這篇文章主要介紹了Java 日期格式加上指定月數(shù)(一個(gè)期限)得到一個(gè)新日期的實(shí)現(xiàn)代碼,需要的朋友可以參考下2018-05-05
SpringBoot+WebSocket搭建簡(jiǎn)單的多人聊天系統(tǒng)
WebSocket是一種在單個(gè)TCP連接上進(jìn)行全雙工通信的協(xié)議。這是一種比較官方的說(shuō)法，簡(jiǎn)單點(diǎn)來(lái)說(shuō)就是，在一次TCP連接中，通信的雙方可以相互通信。這篇文章主要介紹了SpringBoot+WebSocket搭建簡(jiǎn)單的多人聊天系統(tǒng),需要的朋友可以參考下2019-10-10
Java實(shí)現(xiàn)求數(shù)組最長(zhǎng)子序列算法示例
這篇文章主要介紹了Java實(shí)現(xiàn)求數(shù)組最長(zhǎng)子序列算法,涉及java針對(duì)數(shù)組的遞歸遍歷、判斷相關(guān)操作技巧,需要的朋友可以參考下2018-07-07
Java實(shí)現(xiàn)MD5加密的方式與實(shí)例代碼
MD5加密是一種常見(jiàn)的加密方式，我們經(jīng)常用在保存用戶(hù)密碼和關(guān)鍵信息上。那么它到底有什么，又什么好處呢，會(huì)被這么廣泛的運(yùn)用在應(yīng)用開(kāi)發(fā)中2021-10-10
本文主要介紹了SpringBoot整合Activiti工作流框架的使用，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-02-02
詳解用JWT對(duì)SpringCloud進(jìn)行認(rèn)證和鑒權(quán)
這篇文章主要介紹了詳解用JWT對(duì)SpringCloud進(jìn)行認(rèn)證和鑒權(quán)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-03-03
@RequestAttribute和@RequestParam注解的區(qū)別及說(shuō)明
這篇文章主要介紹了@RequestAttribute和@RequestParam注解的區(qū)別及說(shuō)明,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-05-05