为了账号安全,请及时绑定邮箱和手机立即绑定

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

2018.06.12 22:54 1857浏览
字号
大字 中字 小字

概述

了解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内存鸿运国际hv128,方便我们快速启动程序演示,而不用费心在创建鸿运国际hv128相关工作,当程序启动Spring boot会基于自动配置原理给我们隐式的创建一个工作流引擎对象ProcessEngine,并把RuntimeService(控制流程运行时数据流转)等核心服务注册到 Spring 容器中,我们只需要 依赖注入使用即可。
  • 绘制流程图
  • 绘制流程图建议大家通过Eclipse + Activiti插件来绘制,如果大家对流程图元素还不了解,可以直接拷贝流程定义文件运行,这样方便快速的运行我们的快速程序
  • 部署流程图
  • 我们代码里面并没有体现流程部署的过程,也得益于Spring Boot提供的自动部署功能,也是在Spring 容器启动的过程通过 activiti-spring组件,把Class path对应的/processes目录的流程文件自动加载部署,约定大于配置,快速演示代码推荐大家把流程图放到/processes 资源包下面,线上系统则不建议这样做
  • 启动流程
  • 启动流程是通过流程定义文件Key创建一个流程实例的过程,类似于我们根据类名new出一个对象的原理,一个流程定义文件可以生成许许多多的流程实例
  • 多用户协助审批流程
  • 在命令行下体验流程审批的效果,对Java鸿运国际hv128来说,更多的倾向于了解底层的原理,而对UI效果兴趣不高,其实Activiti也跟我们提供了还不错的activiti-app来更好的体验流程的流转。我们这里在命令行下运行工作流程,可以满足一下极客青年小小的虚荣心。

    开发

    创建工程

    基于spring Initializr创建一个标准的maven工程,并添加相关依赖 spring boot 2.0.2最新稳定版,Activiti 6最新稳定版
    // pom.xml <?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" 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.imooc.activiti</groupId> <artifactId>activiti-demo</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>activiti-demo</name> <description>Demo project for Spring Boot</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.2.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency>         <dependency>             <groupId>com.google.guava</groupId>             <artifactId>guava</artifactId>             <version>24.0-jre</version>         </dependency> <dependency> <groupId>org.activiti</groupId> <artifactId>activiti-spring-boot-starter-basic</artifactId> <version>6.0.0</version> </dependency> <dependency> <groupId>com.h2database</groupId> <artifactId>h2</artifactId> <scope>runtime</scope> </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>
    Spring Initializr会自动创建程序启动入口类ActivitiDemoApplication
    /src/main/java/com.imooc.activiti.demo.ActivitiDemoApplicationpackage  com.imooc.activiti.demo; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplicationpublic class ActivitiDemoApplication {     public static void main(String[] args) {         SpringApplication.run(ActivitiDemoApplication.class, args);     } }

    设计流程定义文件

    https://img4.mukewang.com/5b1fde170001823818100620.jpg
    刚开始设计流程定义文件推荐大家使用 Eclipse+ Activiti插件的方式, Activiti也提供了基于浏览器的web 流程设计器,都可以分别体验一下,这个流程定义文件就是普通的xml,大家应该能很容易看明白这个xml文件
    // src/main/resources/processes/second_approve.bpmn <?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="">   <process id="second_approve" name="二级审批流程" isExecutable="true" isClosed="false" processType="None">     <startEvent id="startEvent" name="开始"></startEvent>     <userTask id="submitForm" name="填写审批信息">       <extensionElements>         <activiti:formProperty id="message" name="申请信息" type="string" required="true"></activiti:formProperty>         <activiti:formProperty id="name" name="申请人姓名" type="string" required="true"></activiti:formProperty>         <activiti:formProperty id="submitTime" name="提交时间" type="date" datePattern="yyyy-MM-dd" required="true"></activiti:formProperty>         <activiti:formProperty id="submitType" name="确认申请" type="string" required="true"></activiti:formProperty>       </extensionElements>     </userTask>     <sequenceFlow id="flow1" sourceRef="startEvent" targetRef="submitForm"></sequenceFlow>     <exclusiveGateway id="decideSubmit" name="提交OR取消"></exclusiveGateway>     <sequenceFlow id="flow2" sourceRef="submitForm" targetRef="decideSubmit"></sequenceFlow>     <userTask id="tl_approve" name="主管审批">       <extensionElements>         <activiti:formProperty id="tlApprove" name="主管审批结果" type="string"></activiti:formProperty>         <activiti:formProperty id="tlMessage" name="主管备注" type="string" required="true"></activiti:formProperty>       </extensionElements>     </userTask>     <sequenceFlow id="flow3" sourceRef="decideSubmit" targetRef="tl_approve">       <conditionExpression xsi:type="tFormalExpression"><![CDATA[${submitType == "y" || submitType == "Y"}]]></conditionExpression>     </sequenceFlow>     <exclusiveGateway id="decideTLApprove" name="主管审批校验"></exclusiveGateway>     <sequenceFlow id="flow4" sourceRef="tl_approve" targetRef="decideTLApprove"></sequenceFlow>     <endEvent id="endEvent" name="结束"></endEvent>     <endEvent id="endEventCancel" name="取消"></endEvent>     <sequenceFlow id="flow8" sourceRef="decideSubmit" targetRef="endEventCancel">       <conditionExpression xsi:type="tFormalExpression"><![CDATA[${submitType == "n" || submitType == "N"}]]></conditionExpression>     </sequenceFlow>     <sequenceFlow id="flow9" sourceRef="decideTLApprove" targetRef="submitForm">       <conditionExpression xsi:type="tFormalExpression"><![CDATA[${tlApprove == "n" || tlApprove == "N"}]]></conditionExpression>     </sequenceFlow>     <sequenceFlow id="_2" sourceRef="decideTLApprove" targetRef="endEvent">       <conditionExpression xsi:type="tFormalExpression"><![CDATA[${tlApprove == "y" || tlApprove == "Y"}]]></conditionExpression>     </sequenceFlow>   </process>  </definitions>

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

    流程执行我们使用了CommandLineRunner,这个类的事例会在Spring boot容器启动加载完成后直接运行
    //src/main/java/com.imooc.activiti.demo.AutoConfigurationProcessDemo @Configuration @Slf4jpublic class AutoConfigurationProcessDemo {     @Autowired    private RuntimeService runtimeService;     @Autowired    private TaskService taskService;     @Autowired    private FormService formService;         /**      * 命令行执行      *      * @return      */     @Bean       public CommandLineRunner commandLineRunner() {                 return new CommandLineRunner() {             @Override                         public void run(String... args) throws Exception {                                 log.info("启动我们的程序");                                 //启动运行流程                 ProcessInstance processInstance = startProcessInstance("second_approve");                                 //处理流程任务                 processTask(processInstance);                                 log.info("结束我们的程序");             }         };     }    /**      * 处理流程任务      *      * @param processInstance      * @throws ParseException      */     private void processTask(ProcessInstance processInstance) throws ParseException {         Scanner scanner = new Scanner(System.in);                 while (processInstance != null && !processInstance.isEnded()) {             List<Task> list = taskService.createTaskQuery().list();                         log.info("待处理任务数量 [{}]", list.size());                         for (Task task : list) {                             log.info("待处理任务 [{}]", task.getName());                 Map<String, Object> variables = buildVariablesByScanner(scanner, task);                 taskService.complete(task.getId(), variables);                 processInstance = runtimeService                         .createProcessInstanceQuery()                         .processInstanceId(processInstance.getId())                         .singleResult();             }         }         scanner.close();     }    /**      * 从控制台获取变量      *      * @param scanner      * @param task      * @return      * @throws ParseException      */     private Map<String, Object> buildVariablesByScanner(Scanner scanner, Task task) throws ParseException {         TaskFormData taskFormData = formService.getTaskFormData(task.getId());         List<FormProperty> formProperties = taskFormData.getFormProperties();                 return buildVariablesByScanner(scanner, formProperties);     }              public static Map<String, Object> buildVariablesByScanner(Scanner scanner, List<FormProperty> formProperties) throws ParseException {         Map<String, Object> variables = Maps.newHashMap();                 for (FormProperty property : formProperties) {                     String line = null;                     if (StringFormType.class.isInstance(property.getType())) {                         log.info("请输入 {} ?", property.getName());                         line = scanner.nextLine();                 variables.put(property.getId(), line);             } else if (DateFormType.class.isInstance(property.getType())) {                             log.info("请输入 {} ? 格式 (yyyy-MM-dd)", property.getName());                            line = scanner.nextLine();                 SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");                 Date date = dateFormat.parse(line);                 variables.put(property.getId(), date);             } else {                                 log.info("类型暂不支持 {}", property.getType());             }                         log.info("您输入的内容是 [{}]", line);         }                 return variables;     }    /**      * 获取流程实例      *      * @param processDefinitionId      * @return      */     private ProcessInstance startProcessInstance(String processDefinitionId) {         ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionId);        log.info("启动流程 [{}]", processInstance.getProcessDefinitionKey());        return processInstance;     } }

    命令行运行效果

    可以看到我简单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工作流是一个有技术门槛的事儿,掌握有门槛的技术,提升自己的竞争力,相信大家可以做到的。

    本文原创发布于慕课网 ,转载请注明出处,谢谢合作
    17人推荐
    若觉得本文不错,就分享一下吧!
    看过此文的用户,还看了以下文章
    正在加载中
    1. 评论
    2. 收藏
    3. 共同学习,写下你的评论
    意见反馈 常见问题 APP下载
    官方微信
    举报
    0/150
    提交
    取消
    hv128