【Activiti系列学习】--6.IDEA创建第一个流程引擎Activiti6.0程序Helloworld

本文主要是介绍【Activiti系列学习】--6.IDEA创建第一个流程引擎Activiti6.0程序Helloworld,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

本文介绍以Eclipse和IDEA创建Activiti6.0第一个程序Helloworld,文章比较长,请耐心阅读。

为了方便读者练习,在本文中配有福利,请自行查取。

程序的运行效果如下所示:

一、工具

Eclipse辅助画流程图,创建流程定义文件

IDEA创建流程项目。

二、Eclipse中创建流程定义文件(简单点说就是画流程图)(***)

1.eclipse 中创建maven工程activiti-test,我们需要添加一个diagram的package,用于存放流程的流程定义文件。

2.在diagram中新建Activiti Diagram文件,并取名为second_approve.bpmn

在Eclipse中添加activiti插件:Help-->Install new SoftWare-->点击Add-->

Name:Activiti BPMN 2.0 designer

Locatioin: http://activiti.org/designer/update/

(安装之前可能需要挂VPN)

 

3.画流程图 ***(注:表单的每个元素都有基本信息Id和Name,三个方框要有对应的表单,第一个表单内容为申请人姓名,申请时间,申请信息和是否确认申请,后面两个表单为审批结果和备注,,三个网关后的两条线要有逻辑表达式)

画流程图如下所示:

 

 

4.设置流程图的信息(点击空白处设置即可)

5.给每个人工任务添加信息

填写审批信息元素:

 

主管与人事审批信息:

 

有两个取消事件,一个可以取为endEvent(结束),还有一个可以取为endEventCancel(取消)

6.填写表单信息

三个表单的信息:

 

 

7.填写每一个逻辑

填写审批信息-->确认提交的表达式:

填写审批信息-->取消提交的表达式:

 

另两个逻辑同理即可,只需要修改EL表达式的ID号即可

三、IDEA中创建Hello-world项目(*****)

8.IDEA中创建Maven工程

new project

GroupId可以理解为组织结构的编码,一般与包名类似;ArtifactId为项目名;Version默认即可;三者组成一个GAV三维的坐标系。

 创建好的项目的目录结构为:

9.在activiti6-helloworld中手动添加常用的依赖(添加依赖先检查IDEA是否安装maven,否则添加后会报错)

 完整的依赖如下:

<dependencies><!--activiti引擎--><dependency><groupId>org.activiti</groupId><artifactId>activiti-engine</artifactId><version>6.0.0</version></dependency><!--单元测试依赖--><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.11</version><scope>test</scope></dependency><!--日志组件依赖--><dependency><groupId>ch.qos.logback</groupId><artifactId>logback-classic</artifactId><version>1.1.11</version></dependency><!--添加常用的组件guava--><dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>23.0</version></dependency><!--使用内测数据库依赖h2--><dependency><groupId>com.h2database</groupId><artifactId>h2</artifactId><version>1.3.176</version></dependency></dependencies>

10.在java文件夹中创建包结构package 

创建main方法 

11.编写main方法中的流程逻辑的代码

public class DemoMain {private static final Logger LOGGER = LoggerFactory.getLogger(DemoMain.class);public static void main(String[] args) {LOGGER.info("启动我们的程序");//1.创建流程引擎ProcessEngineConfiguration cfg= ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration();ProcessEngine processEngine=cfg.buildProcessEngine();String name=processEngine.getName();String version=processEngine.VERSION;LOGGER.info("流程引擎名称{},版本{}",name,version);//2.部署流程定义文件//3.启动运行流程//4.处理流程任务LOGGER.info("结束我们的程序");}
}

12.修改日志显示级别

运行时,提示了很多信息,可以拷贝logback.xml到资源文件夹resources中,plain为只显示我们想要的信息,拷贝进去后重新运行即可。

<?xml version="1.0" encoding="utf-8" ?>
<configuration debug="false" scan="true" scanPeriod="30 seconds"><property name="log.dir" value="target/logs"/><property name="encoding" value="UTF-8"/><property name="plain" value="%msg%n"/><property name="std" value="%d{HH:mm:ss.SSS}[%thread][%-5level]%msg %X{user} %logger{10}.%M:%L%n "/><property name="normal" value="%d{yyyy-MM-dd:HH:mm:ss.SSS}[%thread][%-5level] %logger{10}.%M:%L %msg%n"/><!--控制台输出--><appender name="stdout" class="ch.qos.logback.core.ConsoleAppender"><encoder><pattern>${plain}</pattern><charset>${encoding}</charset></encoder></appender><!--时间滚动输出 Level为All 日志--><appender name="file"class="ch.qos.logback.core.rolling.RollingFileAppender"><File>${log.dir}/file.log</File><rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"><FileNamePattern>${log.dir}/file.%d{yyyy-MM-dd}.log</FileNamePattern><MaxHistory>30</MaxHistory></rollingPolicy><encoder><pattern>${std}</pattern><charset>${encoding}</charset></encoder></appender><logger name="root"><level value="ERROR"/></logger><logger name="com.syc"><level value="DEBUG"/></logger><root><appender-ref ref="stdout"/><appender-ref ref="file"/></root>
</configuration>

13.部署流程定义文件

eclipse中的second_approve.bpmn文件拷贝到resources中,--->另外重命名,生成一个second_approve.bpmn20.xml文件

编写代码:

//部署流程定义文件
//获取service
RepositoryService repositoryService = processEngine.getRepositoryService();
//通过repositoryService获取一个builder
DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();
deploymentBuilder.addClasspathResource("second_approve.bpmn20.xml");
Deployment deployment = deploymentBuilder.deploy();
String deploymentId=deployment.getId();
ProcessDefinition processDefinition=repositoryService.createProcessDefinitionQuery().deploymentId(deploymentId).singleResult();
LOGGER.info("流程定义文件{},流程ID{}",processDefinition.getName(),processDefinition.getId());

 14.启动运行流程

//启动运行时对象
RuntimeService runtimeService = processEngine.getRuntimeService();
ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId());
LOGGER.info("启动流程[{}]",processInstance.getProcessDefinitionKey());
//处理流程任务
TaskService taskService = processEngine.getTaskService();
List<Task> list = taskService.createTaskQuery().list();
for(Task task:list){LOGGER.info("待处理任务[{}]",task.getName());
}
LOGGER.info("待处理任务数量[{}]",list.size());

 15.抽取方法

 将代码抽取为方法,选中代码,右键Refactor->Extract->Method,抽取后的效果:

//创建流程引擎
ProcessEngine processEngine=getProcessEngine();
//部署流程定义文件
ProcessDefinition processDefinition=getProcessDefinition(processEngine);
//启动运行流程//启动运行时对象
ProcessInstance processInstance=getProcessInstance(processEngine,processDefinition);

 16.最终代码

DemoMain.java(此处以未提取方法为例,便于查看业务过程,分享的文件中为提取方法后的代码)

public class Demo {private static final Logger LOGGER = LoggerFactory.getLogger(Demo.class);public static void main(String[] args) {//创建流程引擎ProcessEngineConfiguration cfg = ProcessEngineConfiguration.createStandaloneInMemProcessEngineConfiguration();ProcessEngine processEngine = cfg.buildProcessEngine();LOGGER.info("启动程序");LOGGER.info("流程引擎版本:[{}]", processEngine.VERSION);//部署流程定义文件RepositoryService repositoryService = processEngine.getRepositoryService();DeploymentBuilder deploymentBuilder = repositoryService.createDeployment();deploymentBuilder.addClasspathResource("second_approve.bpmn20.xml");Deployment deployment = deploymentBuilder.deploy();String deploymentId = deployment.getId();ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().deploymentId(deploymentId).singleResult();LOGGER.info("流程定义文件 [{}], 流程ID [{}]", processDefinition.getName(), processDefinition.getId());//启动运行流程RuntimeService runtimeService = processEngine.getRuntimeService();ProcessInstance processInstance = runtimeService.startProcessInstanceById(processDefinition.getId());LOGGER.info("启动流程 [{}]", processInstance.getProcessDefinitionKey());//处理流程任务Scanner scanner = new Scanner(System.in);while (processInstance != null && !processInstance.isEnded()) {TaskService taskService = processEngine.getTaskService();List<Task> list = taskService.createTaskQuery().list();LOGGER.info("待处理任务数量 [{}]", list.size());for (Task task : list) {LOGGER.info("待处理任务 [{}]", task.getName());Map<String, Object> variables = getMap(processEngine, scanner, task);taskService.complete(task.getId(), variables);processInstance = processEngine.getRuntimeService().createProcessInstanceQuery().processInstanceId(processInstance.getId()).singleResult();}}scanner.close();LOGGER.info("关闭程序");}//getMap()方法private static Map<String, Object> getMap(ProcessEngine processEngine, Scanner scanner, Task task){Map<String, Object> variables = new HashMap<>();FormService formService = processEngine.getFormService();TaskFormData taskFormData = formService.getTaskFormData(task.getId());List<FormProperty> formProperties = taskFormData.getFormProperties();for(FormProperty property : formProperties){String line = null;if(StringFormType.class.isInstance(property.getType())){LOGGER.info("请输入 [{}] ?", property.getName());line = scanner.nextLine();variables.put(property.getId(), line);}else if(DateFormType.class.isInstance(property.getType())){LOGGER.info("请输入 [{}] ? 格式(yyyy-MM-dd)", property.getName());line = scanner.nextLine();variables.put(property.getId(), line);}else{LOGGER.info("类型暂不支持{} ",property.getType());}LOGGER.info("您输入的内容是:{}", line);}return variables;}
}

DemoMain.java文件、pom.xml文件、second_approve.bpmn20.xml文件,以及需要整个程序者可自取:

链接:https://pan.baidu.com/s/1COuj1T4uvFumOTfn1wo53g 
提取码:93xp


以下为打包项目到linux环境中运行

17.打包过程添加依赖(以下代码已经添加到上述的pom.xml文件中)

1)添加parent内容

    <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.0.RELEASE</version><relativePath/></parent>

 2)添加plugin内容,基于plugin可以启动我们的程序。加在dependences后面

    <build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>

3)添加启动程序的依赖 

        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency>

18.将项目上传到虚拟机,编译运行,再打包

进入目录,以spring-boot方式启动程序

mvn spring-boot:run

 

 

打包目录mvn package

 进入到target目录查看到两个jar文件

注:第一个jar包含了所有的第三方依赖包括activiti和spring-boot依赖包

启动运行打包好的jar包:

java -jar activiti6-helloworld-1.0-SNAPSHOT.jar

该jar包可以放到任何有java环境上的机器上运行。

 完毕!

这篇关于【Activiti系列学习】--6.IDEA创建第一个流程引擎Activiti6.0程序Helloworld的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/414370

相关文章

Git打标签从本地创建到远端推送的详细流程

《Git打标签从本地创建到远端推送的详细流程》在软件开发中,Git标签(Tag)是为发布版本、标记里程碑量身定制的“快照锚点”,它能永久记录项目历史中的关键节点,然而,仅创建本地标签往往不够,如何将其... 目录一、标签的两种“形态”二、本地创建与查看1. 打附注标http://www.chinasem.cn

通过Docker容器部署Python环境的全流程

《通过Docker容器部署Python环境的全流程》在现代化开发流程中,Docker因其轻量化、环境隔离和跨平台一致性的特性,已成为部署Python应用的标准工具,本文将详细演示如何通过Docker容... 目录引言一、docker与python的协同优势二、核心步骤详解三、进阶配置技巧四、生产环境最佳实践

MyBatis分页查询实战案例完整流程

《MyBatis分页查询实战案例完整流程》MyBatis是一个强大的Java持久层框架,支持自定义SQL和高级映射,本案例以员工工资信息管理为例,详细讲解如何在IDEA中使用MyBatis结合Page... 目录1. MyBATis框架简介2. 分页查询原理与应用场景2.1 分页查询的基本原理2.1.1 分

python获取指定名字的程序的文件路径的两种方法

《python获取指定名字的程序的文件路径的两种方法》本文主要介绍了python获取指定名字的程序的文件路径的两种方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要... 最近在做项目,需要用到给定一个程序名字就可以自动获取到这个程序在Windows系统下的绝对路径,以下

Java使用Javassist动态生成HelloWorld类

《Java使用Javassist动态生成HelloWorld类》Javassist是一个非常强大的字节码操作和定义库,它允许开发者在运行时创建新的类或者修改现有的类,本文将简单介绍如何使用Javass... 目录1. Javassist简介2. 环境准备3. 动态生成HelloWorld类3.1 创建CtC

redis-sentinel基础概念及部署流程

《redis-sentinel基础概念及部署流程》RedisSentinel是Redis的高可用解决方案,通过监控主从节点、自动故障转移、通知机制及配置提供,实现集群故障恢复与服务持续可用,核心组件包... 目录一. 引言二. 核心功能三. 核心组件四. 故障转移流程五. 服务部署六. sentinel部署

SpringBoot集成XXL-JOB实现任务管理全流程

《SpringBoot集成XXL-JOB实现任务管理全流程》XXL-JOB是一款轻量级分布式任务调度平台,功能丰富、界面简洁、易于扩展,本文介绍如何通过SpringBoot项目,使用RestTempl... 目录一、前言二、项目结构简述三、Maven 依赖四、Controller 代码详解五、Service

Spring创建Bean的八种主要方式详解

《Spring创建Bean的八种主要方式详解》Spring(尤其是SpringBoot)提供了多种方式来让容器创建和管理Bean,@Component、@Configuration+@Bean、@En... 目录引言一、Spring 创建 Bean 的 8 种主要方式1. @Component 及其衍生注解

Mac电脑如何通过 IntelliJ IDEA 远程连接 MySQL

《Mac电脑如何通过IntelliJIDEA远程连接MySQL》本文详解Mac通过IntelliJIDEA远程连接MySQL的步骤,本文通过图文并茂的形式给大家介绍的非常详细,感兴趣的朋友跟... 目录MAC电脑通过 IntelliJ IDEA 远程连接 mysql 的详细教程一、前缀条件确认二、打开 ID

Python利用PySpark和Kafka实现流处理引擎构建指南

《Python利用PySpark和Kafka实现流处理引擎构建指南》本文将深入解剖基于Python的实时处理黄金组合:Kafka(分布式消息队列)与PySpark(分布式计算引擎)的化学反应,并构建一... 目录引言:数据洪流时代的生存法则第一章 Kafka:数据世界的中央神经系统消息引擎核心设计哲学高吞吐