Activiti指南（運行流程實例）
運行流程實例
部署的流程能夠使用Activiti API來啓動、運行、查看歷史記錄以及以其餘方式管理流程實例，本快速入門使用Java代碼運行流程實例。java
將Activiti的日誌記錄級別從DEBUG設置爲WARN，以下面的第1行所示。apache
文件：$mvnProject/src/main/resources/log4j.propertiessegmentfault
log4j.rootLogger=WARN, ACT
log4j.appender.ACT=org.apache.log4j.ConsoleAppender
log4j.appender.ACT.layout=org.apache.log4j.PatternLayout
log4j.appender.ACT.layout.ConversionPattern= %d{hh:mm:ss,SSS} [%t] %-5p %c %x - %m%n
添加到OnboardingRequest.java，以下圖所示：app
文件：$mvnProject/src/main/java/com/example/OnboardingRequest.javaui
package com.example;
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Scanner;
import org.activiti.engine.FormService;
import org.activiti.engine.HistoryService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.form.FormData;
import org.activiti.engine.form.FormProperty;
import org.activiti.engine.history.HistoricActivityInstance;
import org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration;
import org.activiti.engine.impl.form.DateFormType;
import org.activiti.engine.impl.form.LongFormType;
import org.activiti.engine.impl.form.StringFormType;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
public class OnboardingRequest {
public static void main(String[] args) throws ParseException {
ProcessEngineConfiguration cfg = new StandaloneProcessEngineConfiguration()
.setJdbcUrl("jdbc:h2:mem:activiti;DB_CLOSE_DELAY=1000")
.setJdbcUsername("sa")
.setJdbcPassword("")
.setJdbcDriver("org.h2.Driver")
.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);
ProcessEngine processEngine = cfg.buildProcessEngine();
String pName = processEngine.getName();
String ver = ProcessEngine.VERSION;
System.out.println("ProcessEngine [" + pName + "] Version: [" + ver + "]");
RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deployment = repositoryService.createDeployment()
.addClasspathResource("onboarding.bpmn20.xml").deploy();
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
.deploymentId(deployment.getId()).singleResult();
System.out.println(
"Found process definition ["
+ processDefinition.getName() + "] with id ["
+ processDefinition.getId() + "]");
RuntimeService runtimeService = processEngine.getRuntimeService();
ProcessInstance processInstance = runtimeService
.startProcessInstanceByKey("onboarding");
System.out.println("Onboarding process started with process instance id ["
+ processInstance.getProcessInstanceId()
+ "] key [" + processInstance.getProcessDefinitionKey() + "]");
TaskService taskService = processEngine.getTaskService();
FormService formService = processEngine.getFormService();
HistoryService historyService = processEngine.getHistoryService();
Scanner scanner = new Scanner(System.in);
while (processInstance != null && !processInstance.isEnded()) {
List<Task> tasks = taskService.createTaskQuery()
.taskCandidateGroup("managers").list();
System.out.println("Active outstanding tasks: [" + tasks.size() + "]");
for (int i = 0; i < tasks.size(); i++) {
Task task = tasks.get(i);
System.out.println("Processing Task [" + task.getName() + "]");
Map<String, Object> variables = new HashMap<String, Object>();
FormData formData = formService.getTaskFormData(task.getId());
for (FormProperty formProperty : formData.getFormProperties()) {
if (StringFormType.class.isInstance(formProperty.getType())) {
System.out.println(formProperty.getName() + "?");
String value = scanner.nextLine();
variables.put(formProperty.getId(), value);
} else if (LongFormType.class.isInstance(formProperty.getType())) {
System.out.println(formProperty.getName() + "? (Must be a whole number)");
Long value = Long.valueOf(scanner.nextLine());
variables.put(formProperty.getId(), value);
} else if (DateFormType.class.isInstance(formProperty.getType())) {
System.out.println(formProperty.getName() + "? (Must be a date m/d/yy)");
DateFormat dateFormat = new SimpleDateFormat("m/d/yy");
Date value = dateFormat.parse(scanner.nextLine());
variables.put(formProperty.getId(), value);
} else {
System.out.println("<form type not supported>");
}
}
taskService.complete(task.getId(), variables);
HistoricActivityInstance endActivity = null;
List<HistoricActivityInstance> activities =
historyService.createHistoricActivityInstanceQuery()
.processInstanceId(processInstance.getId()).finished()
.orderByHistoricActivityInstanceEndTime().asc()
.list();
for (HistoricActivityInstance activity : activities) {
if (activity.getActivityType() == "startEvent") {
System.out.println("BEGIN " + processDefinition.getName()
+ " [" + processInstance.getProcessDefinitionKey()
+ "] " + activity.getStartTime());
}
if (activity.getActivityType() == "endEvent") {
// Handle edge case where end step happens so fast that the end step
// and previous step(s) are sorted the same. So, cache the end step
//and display it last to represent the logical sequence.
endActivity = activity;
} else {
System.out.println("-- " + activity.getActivityName()
+ " [" + activity.getActivityId() + "] "
+ activity.getDurationInMillis() + " ms");
}
}
if (endActivity != null) {
System.out.println("-- " + endActivity.getActivityName()
+ " [" + endActivity.getActivityId() + "] "
+ endActivity.getDurationInMillis() + " ms");
System.out.println("COMPLETE " + processDefinition.getName() + " ["
+ processInstance.getProcessDefinitionKey() + "] "
+ endActivity.getEndTime());
}
}
// Re-query the process instance, making sure the latest state is available
processInstance = runtimeService.createProcessInstanceQuery()
.processInstanceId(processInstance.getId()).singleResult();
}
scanner.close();
}
}
文件：$mvnProject/src/main/java/com/example/OnboardingRequest.javaspa
| 行數 | 說明 |
|---|---|
| 12-13, 17-21, 28-39 | Activiti API中的主要服務導入用於流程管理。 |
| 54-59 | 啓動Onboarding流程的實例。 |
| 61-62, 67, 71-93 | 從符合「manager」角色的任務中收集命令行輸入並完成任務。 |
| 23-25, 76,80, 84 | 基於流程模型中定義的表單屬性類型，提示用戶輸入特定於類型的輸入。 |
| 63, 95-125 | 顯示流程歷史記錄。 |
| 23-25 | 檢索已部署的模型，證實它位於Activiti存儲庫中 |
經過運行「mvn package」打包代碼。命令行
像之前同樣運行Java程序，注意下面提到的示例輸出。日誌
命令：java -jar target/ActivitiDeveloperQuickStart-0.0.1-SNAPSHOT-jar-with-dependencies.jarcode
或 java -jar target/$quickStartJavaProjectName-0.0.1-SNAPSHOT-jar-with-dependencies.jarorm
基礎路徑：$mvnProject
ProcessEngine [default] Version: [5.22.0.0] Found process definition [Onboarding] with id [onboarding:1:4] Onboarding process started with process instance id [5] key [onboarding] Active outstanding tasks: [1] Processing Task [Enter Data] Full Name? John Doe Years of Experience? (Must be a whole number) 2 BEGIN Onboarding [onboarding] Sun Nov 27 21:36:21 EST 2016 -- Start [startOnboarding] 4 ms -- Enter Data [enterOnboardingData] 16855 ms -- Years of Experience [decision] 3 ms -- Generic and Automated Data Entry [automatedIntro] 322 ms -- End [endOnboarding] 0 ms COMPLETE Onboarding [onboarding] Sun Nov 27 21:36:38 EST 2016
觀察2年經驗在「Years of Experience」決定以後看到腳本任務「Generic and Automated Data Entry」以後的流程路徑，而後流程結束。
命令：java -jar target/ActivitiDeveloperQuickStart-0.0.1-SNAPSHOT-jar-with-dependencies.jar
或 java -jar target/$quickStartJavaProjectName-0.0.1-SNAPSHOT-jar-with-dependencies.jar
基礎路徑：$mvnProject
ProcessEngine [default] Version: [5.22.0.0] Found process definition [Onboarding] with id [onboarding:1:4] Onboarding process started with process instance id [5] key [onboarding] Active outstanding tasks: [1] Processing Task [Enter Data] Full Name? John Doe Years of Experience? (Must be a whole number) 5 BEGIN Onboarding [onboarding] Sun Nov 27 21:39:26 EST 2016 -- Start [startOnboarding] 5 ms -- Enter Data [enterOnboardingData] 7810 ms -- Years of Experience [decision] 2 ms Active outstanding tasks: [1] Processing Task [Personalized Introduction and Data Entry] Personal Welcome Time? (Must be a date m/d/yy) 12/9/16 BEGIN Onboarding [onboarding] Sun Nov 27 21:39:26 EST 2016 -- Start [startOnboarding] 5 ms -- Enter Data [enterOnboardingData] 7810 ms -- Years of Experience [decision] 2 ms -- Personalized Introduction and Data Entry [personalizedIntro] 20231 ms -- End [endOnboarding] 0 ms COMPLETE Onboarding [onboarding] Sun Nov 27 21:39:54 EST 2016
觀察5年經驗在「Years of Experience」Personalized Introduction and Data Entry「個性化介紹和數據輸入」以後的流程路徑，而後流程結束。
雖然簡單，但這個嵌入式示例顯示了你的應用程序如何將流程邏輯外部化爲基於標準的建模和代碼友好的開發模型。
上一篇：部署流程定義
相關文章
- 1. Activiti指南（部署流程定義）
- 2. Activiti指南（建立流程引擎）
- 3. Activiti(二)在官方實例上運行一個流程
- 4. Activiti的流程實例【ProcessInstance】與執行實例【Execution】
- 5. Activiti工做流之流程實例、任務的執行
- 6. 5.activiti工作流-流程實例、任務的執行
- 7. Activiti教程(七)activiti的流程執行
- 8. Activiti指南（介紹）
- 9. Activiti工做流實例
- 10. activiti 流程實例與業務關聯
- 更多相關文章...
- • Hibernate的運行流程 - Hibernate教程
- • Eclipse 運行程序 - Eclipse 教程
- • 算法總結-雙指針
- • Java 8 Stream 教程
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
