微信号:imooc-com

介绍:慕课网是一个超酷的互联网、IT技术免费学习平台,创新的网络一站式学习、实践体验;服务及时贴心,内容专业、有趣易学。专注服务互联网工程师快速成为技术高手!

十分钟认识Activiti6.0工作流引擎

2018-06-21 20:50 JimmyNo1


越来越多的互联网公司开始采用工作流引擎的方式来适应业务的快速变化



了解Activiti


假如你还不知道Activiti是什么,那么工作流引擎对你来说一定也是新的,解决Activiti和工作流知识盲点,到这里就对了。还有Android同学会误以为是“Activity”,工作流引擎Activiti和Android开发的Activity这是两码事儿,Activiti是一个开源的自动化业务工作流引擎,具体概念就不碎碎念介绍了。


使用工作流引擎 

工作流引擎最常见用于审批流程中,现在一线互联网公司也开始使用,并有快速推广的趋势,复杂繁多的业务流程如果采用if else实现那将是崩溃的,代码不可维护,业务流程在代码中可读性很差,所以高人设计了业务流程模型图示BPMN2.0,我们要做到就是把业务场景抽象为标准流程图,把流程图丢到流程引擎中按流程定义约定逐步流转,很显然扩展性和业务可描述性会好很多,所以工作流引擎主要用于解决复杂的业务,目前经常被提起的中台系统抽象业务为服务,也涉及大量智能的业务流程引擎做支撑。


让工作流引擎运行 

我们快速体验一个流程的运行过程


搭建流程引擎

我们在IDEA环境中使用 Spring Initializr引导我们创建一个标准工程,采用最新稳定版spring boot 2.0.2,Activiti 6.0,通过引入H2内存数据库,方便我们快速启动程序演示,而不用费心在创建数据库相关工作,当程序启动Spring boot会基于自动配置原理给我们隐式的创建一个工作流引擎对象ProcessEngine,并把RuntimeService(控制流程运行时数据流转)等核心服务注册到 Spring 容器中,我们只需要 依赖注入使用即可。


绘制流程图

绘制流程图建议大家通过Eclipse + Activiti插件来绘制,如果大家对流程图元素还不了解,可以直接拷贝流程定义文件运行,这样方便快速的运行我们的快速程序


部署流程图

我们代码里面并没有体现流程部署的过程,也得益于Spring Boot提供的自动部署功能,也是在Spring 容器启动的过程通过 activiti-spring组件,把Class path对应的/processes目录的流程文件自动加载部署,约定大于配置,快速演示代码推荐大家把流程图放到/processes 资源包下面,线上系统则不建议这样做


启动流程

启动流程是通过流程定义文件Key创建一个流程实例的过程,类似于我们根据类名new出一个对象的原理,一个流程定义文件可以生成许许多多的流程实例


多用户协助审批流程

在命令行下体验流程审批的效果,对Java后端开发来说,更多的倾向于了解底层的原理,而对UI效果兴趣不高,其实Activiti也跟我们提供了还不错的activiti-app来更好的体验流程的流转。我们这里在命令行下运行工作流程,可以满足一下极客青年小小的虚荣心。


 开发


创建工程 

基于spring Initializr创建一个标准的maven工程,并添加相关依赖 spring boot 2.0.2最新稳定版,Activiti 6最新稳定版

 
           
  1. // pom.xml

  2. <?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  3.  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

  4.  <modelVersion>4.0.0</modelVersion>

  5.  <groupId>com.imooc.activiti</groupId>

  6.  <artifactId>activiti-demo</artifactId>

  7.  <version>0.0.1-SNAPSHOT</version>

  8.  <packaging>jar</packaging>

  9.  <name>activiti-demo</name>

  10.  <description>Demo project for Spring Boot</description>

  11.  <parent>

  12. <groupId>com.imooc.activiti</groupId>

  13. <artifactId>activiti-demo</artifactId>

  14. <version>0.0.1-SNAPSHOT</version>

  15. <packaging>jar</packaging>

  16. <name>activiti-demo</name>

  17. <description>Demo project for Spring Boot</description>

  18. <parent>

  19.  <groupId>org.springframework.boot</groupId>

  20.  <artifactId>spring-boot-starter-parent</artifactId>

  21.  <version>2.0.2.RELEASE</version>

  22.  <relativePath/> <!-- lookup parent from repository -->

  23. </parent>

  24. <properties>

  25.  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

  26.  <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

  27.  <java.version>1.8</java.version>

  28. </properties>

  29. <dependencies>

  30.  <dependency>

  31.  <groupId>org.springframework.boot</groupId>

  32.  <artifactId>spring-boot-starter</artifactId>

  33.  </dependency>

  34.  <dependency>

  35.  <groupId>org.projectlombok</groupId>

  36.  <artifactId>lombok</artifactId>

  37.  </dependency>

  38.  <dependency>

  39.  <groupId>com.google.guava</groupId>

  40.  <artifactId>guava</artifactId>

  41.  <version>24.0-jre</version>

  42.  </dependency>

  43.  <dependency>

  44.  <groupId>org.activiti</groupId>

  45.  <artifactId>activiti-spring-boot-starter-basic</artifactId>

  46.  <version>6.0.0</version>

  47.  </dependency>

  48.  <dependency>

  49.  <groupId>com.h2database</groupId>

  50.  <artifactId>h2</artifactId>

  51.  <scope>runtime</scope>

  52.  </dependency>

  53.  <dependency>

  54.  <groupId>org.springframework.boot</groupId>

  55.  <artifactId>spring-boot-starter-test</artifactId>

  56.  <scope>test</scope>

  57.  </dependency>

  58. </dependencies>

  59. <build>

  60.  <plugins>

  61.  <plugin>

  62.  <groupId>org.springframework.boot</groupId>

  63.  <artifactId>spring-boot-maven-plugin</artifactId>

  64.  </plugin>

  65.  </plugins>

  66. </build>


Spring Initializr会自动创建程序启动入口类ActivitiDemoApplication

 
           
  1. // src/main/resources/processes/second_approve.bpmn

  2. <?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:tns="http://www.activiti.org/test" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test" id="m1528728906382" name="">

  3.  <process id="second_approve" name="二级审批流程" isExecutable="true" isClosed="false" processType="None">

  4.  <startEvent id="startEvent" name="开始"></startEvent>

  5.  <userTask id="submitForm" name="填写审批信息">

  6.  <extensionElements>

  7.  <activiti:formProperty id="message" name="申请信息" type="string" required="true"></activiti:formProperty>

  8.  <activiti:formProperty id="name" name="申请人姓名" type="string" required="true"></activiti:formProperty>

  9.  <activiti:formProperty id="submitTime" name="提交时间" type="date" datePattern="yyyy-MM-dd" required="true"></activiti:formProperty>

  10.  <activiti:formProperty id="submitType" name="确认申请" type="string" required="true"></activiti:formProperty>

  11.  </extensionElements>

  12.  </userTask>

  13.  <sequenceFlow id="flow1" sourceRef="startEvent" targetRef="submitForm"></sequenceFlow>

  14.  <exclusiveGateway id="decideSubmit" name="提交OR取消"></exclusiveGateway>

  15.  <sequenceFlow id="flow2" sourceRef="submitForm" targetRef="decideSubmit"></sequenceFlow>

  16.  <userTask id="tl_approve" name="主管审批">

  17.  <extensionElements>

  18.  <activiti:formProperty id="tlApprove" name="主管审批结果" type="string"></activiti:formProperty>

  19.  <activiti:formProperty id="tlMessage" name="主管备注" type="string" required="true"></activiti:formProperty>

  20.  </extensionElements>

  21.  </userTask>

  22.  <sequenceFlow id="flow3" sourceRef="decideSubmit" targetRef="tl_approve">

  23.  <conditionExpression xsi:type="tFormalExpression"><![CDATA[${submitType == "y" || submitType == "Y"}]]></conditionExpression>

  24.  </sequenceFlow>

  25.  <exclusiveGateway id="decideTLApprove" name="主管审批校验"></exclusiveGateway>

  26.  <sequenceFlow id="flow4" sourceRef="tl_approve" targetRef="decideTLApprove"></sequenceFlow>

  27.  <endEvent id="endEvent" name="结束"></endEvent>

  28.  <endEvent id="endEventCancel" name="取消"></endEvent>

  29.  <sequenceFlow id="flow8" sourceRef="decideSubmit" targetRef="endEventCancel">

  30.  <conditionExpression xsi:type="tFormalExpression"><![CDATA[${submitType == "n" || submitType == "N"}]]></conditionExpression>

  31.  </sequenceFlow>

  32.  <sequenceFlow id="flow9" sourceRef="decideTLApprove" targetRef="submitForm">

  33.  <conditionExpression xsi:type="tFormalExpression"><![CDATA[${tlApprove == "n" || tlApprove == "N"}]]></conditionExpression>

  34.  </sequenceFlow>

  35.  <sequenceFlow id="_2" sourceRef="decideTLApprove" targetRef="endEvent">

  36.  <conditionExpression xsi:type="tFormalExpression"><![CDATA[${tlApprove == "y" || tlApprove == "Y"}]]></conditionExpression>

  37.  </sequenceFlow>

  38.  </process>

  39.  </definitions>


设计流程定义文件



刚开始设计流程定义文件推荐大家使用 Eclipse+ Activiti插件的方式, Activiti也提供了基于浏览器的web 流程设计器,都可以分别体验一下,这个流程定义文件就是普通的xml,大家应该能很容易看明白这个xml文件

 
           
  1. //src/main/java/com.imooc.activiti.demo.ActivitiDemoApplicationpackage

  2. com.imooc.activiti.demo;

  3. import org.springframework.boot.SpringApplication;

  4. import org.springframework.boot.autoconfigure.SpringBootApplication;

  5. @SpringBootApplicationpublic class ActivitiDemoApplication {


  6. public static void main(String[] args) {

  7.  SpringApplication.run(ActivitiDemoApplication.class, args);

  8. }



开发可以根据spring boot自动装配的流程样例 

流程执行我们使用了

CommandLineRunner,这个类的事例会在Spring boot容器启动加载完成后直接运行


 
           
  1. //src/main/java/com.imooc.activiti.demo.AutoConfigurationProcessDemo

  2. @Configuration

  3. @Slf4jpublic class AutoConfigurationProcessDemo {

  4.  @Autowired private RuntimeService runtimeService;

  5.  @Autowired private TaskService taskService;

  6.  @Autowired private FormService formService;

  7.  /**

  8.  * 命令行执行

  9.  *

  10.  * @return

  11.  */

  12.  @Bean

  13.  public CommandLineRunner commandLineRunner() {

  14.  return new CommandLineRunner() {

  15.  @Override

  16.  public void run(String... args) throws Exception {

  17.  log.info("启动我们的程序");

  18.  //启动运行流程

  19.  ProcessInstance processInstance = startProcessInstance("second_approve");

  20.  //处理流程任务

  21.  processTask(processInstance);

  22.  log.info("结束我们的程序");

  23.  }

  24.  };

  25.  } /**

  26.  * 处理流程任务

  27.  *

  28.  * @param processInstance

  29.  * @throws ParseException

  30.  */

  31.  private void processTask(ProcessInstance processInstance) throws ParseException {

  32.  Scanner scanner = new Scanner(System.in);

  33.  while (processInstance != null && !processInstance.isEnded()) {

  34.  List<Task> list = taskService.createTaskQuery().list();

  35.  log.info("待处理任务数量 [{}]", list.size());

  36.  for (Task task : list) {

  37.  log.info("待处理任务 [{}]", task.getName());

  38.  Map<StringObject> variables = buildVariablesByScanner(scanner, task);

  39.  taskService.complete(task.getId(), variables);

  40.  processInstance = runtimeService

  41.  .createProcessInstanceQuery()

  42.  .processInstanceId(processInstance.getId())

  43.  .singleResult();

  44.  }

  45.  }

  46.  scanner.close();

  47.  } /**

  48.  * 从控制台获取变量

  49.  *

  50.  * @param scanner

  51.  * @param task

  52.  * @return

  53.  * @throws ParseException

  54.  */

  55.  private Map<StringObject> buildVariablesByScanner(Scanner scanner, Task task) throws ParseException {

  56.  TaskFormData taskFormData = formService.getTaskFormData(task.getId());

  57.  List<FormProperty> formProperties = taskFormData.getFormProperties();

  58.  return buildVariablesByScanner(scanner, formProperties);

  59.  }


  60. public static Map<StringObject> buildVariablesByScanner(Scanner scanner, List<FormProperty> formProperties) throws ParseException {

  61.  Map<StringObject> variables = Maps.newHashMap();

  62.  for (FormProperty property : formProperties) {

  63.  String line = null;

  64.  if (StringFormType.class.isInstance(property.getType())) {

  65.  log.info("请输入 {} ?"property.getName());

  66.  line = scanner.nextLine();

  67.  variables.put(property.getId(), line);

  68.  } else if (DateFormType.class.isInstance(property.getType())) {

  69.  log.info("请输入 {} ? 格式 (yyyy-MM-dd)"property.getName());

  70.  line = scanner.nextLine();

  71.  SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");

  72.  Date date = dateFormat.parse(line);

  73.  variables.put(property.getId(), date);

  74.  } else {

  75.  log.info("类型暂不支持 {}"property.getType());

  76.  }

  77.  log.info("您输入的内容是 [{}]", line);

  78.  }

  79.  return variables;

  80. /**

  81.  * 获取流程实例

  82.  *

  83.  * @param processDefinitionId

  84.  * @return

  85.  */

  86. private ProcessInstance startProcessInstance(String processDefinitionId) {

  87.  ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionId); log.info("启动流程 [{}]", processInstance.getProcessDefinitionKey()); return processInstance;

  88. }


命令行运行效果 

可以看到我简单3个文件就可以让工作流程序运行起来,为了让控制台输出更清晰直观,让控制台日志仅仅输出message日志信息,忽略默认格式中日志级别时间信息等等

//src/main/resources/application.yml logging: 
pattern: 
console: "%m%n" 


我们可以直接在控制台运行 mvn spring-boot:run,当然也可以mvn package打出一个Jar包后,运行独立jar包

mvn spring-boot:run
// 输入正常流程审批通过
启动我们的程序
启动流程 [second_approve]
待处理任务数量 [1]
待处理任务 [填写审批信息]
请输入 申请信息 ?
$辞职,世界那么大,我想去看看
您输入的内容是 [辞职,世界那么大,我想去看看]
请输入 申请人姓名 ?
$Jimmy
您输入的内容是 [Jimmy]
请输入 提交时间 ? 格式 (yyyy-MM-dd)
$2018-05-21
您输入的内容是 [2018-05-21]
请输入 确认申请 ?
$Y
您输入的内容是 [Y]
待处理任务数量 [1]
待处理任务 [主管审批]
请输入 主管审批结果 ?
$Y
您输入的内容是 [Y]
请输入 主管备注 ?
$钱包那么小,劝你别作妖
您输入的内容是 [钱包那么小,劝你别作妖]
结束我们的程序


总结


我们简单演示了一下Activiti6.0工作流的使用方式,希望能帮助到大家,Activiti是非常受欢迎的工作流引擎,很多公司的工作流平台技术选型都选了Activiti,工作流技术相对复杂一些,如果想深入了解工作流技术是需要下一番功夫的,正如说所Activiti工作流是一个有技术门槛的事儿,掌握有门槛的技术,提升自己的竞争力,相信大家可以做到的。



推荐一门Activiti6.0工作流引擎的教程,详情如下


想要学习,点击下图,即可订阅



     

程序员的梦工厂




 戳原文,带你系统掌握Activiti6.0

 
慕课网 更多文章 【慕课网实战课】从0开始双剑合璧Laravel,AngularJS全栈开发知乎 五功大成!慕课网安卓5.0客户端重磅发布! 节后第一天慕女神送你书籍给你助力!——评论区留言就送经典IT书籍! 【云栖专题——阿里百川技术分享】后APP时代的破局之路:阿里技术“三大容器五大方案”亮相,百川开放全面升级 做一次真实的开发,一次性拿下jQuery!转需~
猜您喜欢 iOS专项测试系列——iOS单元测试浅谈 ENode框架Conference案例分析系列之 - 事件溯源如何处理重构问题 reMarkable 电纸书使用体验续篇 腾讯携手华为举办Spark论坛,诚邀业内精英9月21日相聚腾讯大厦 VFP正则表达式应用:文本内容换行