Activiti7與Spring以及Spring Boot整合開發(fā)
更新時間：2023年03月28日 11:24:49 作者：干凈的壞蛋
這篇文章主要介紹了Activiti7與Spring以及Spring Boot整合開發(fā)，在Activiti中核心類的是ProcessEngine流程引擎，與Spring整合就是讓Spring來管理ProcessEngine，有感興趣的同學可以參考閱讀
Activiti整合Spring
一、Activiti與Spring整合開發(fā)
1.1 Activiti與Spring整合的配置
1)、在pom.xml文件引入坐標
如下
<properties>
<slf4j.version>1.6.6</slf4j.version>
<log4j.version>1.2.12</log4j.version>
</properties>
<dependencies>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-engine</artifactId>
<version>7.0.0.Beta1</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-spring</artifactId>
<version>7.0.0.Beta1</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-bpmn-model</artifactId>
<version>7.0.0.Beta1</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-bpmn-converter</artifactId>
<version>7.0.0.Beta1</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-json-converter</artifactId>
<version>7.0.0.Beta1</version>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-bpmn-layout</artifactId>
<version>7.0.0.Beta1</version>
</dependency>
<dependency>
<groupId>org.activiti.cloud</groupId>
<artifactId>activiti-cloud-services-api</artifactId>
<version>7.0.0.Beta1</version>
</dependency>
<dependency>
<groupId>aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.5.4</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.40</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.0.7.RELEASE</version>
</dependency>
<!-- log start -->
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>${log4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-nop</artifactId>
<version>${slf4j.version}</version>
</dependency>
<!-- log end -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.5</version>
</dependency>
<dependency>
<groupId>commons-dbcp</groupId>
<artifactId>commons-dbcp</artifactId>
<version>1.4</version>
</dependency>
</dependencies>
<repositories>
<repository>
<id>alfresco</id>
<name>Activiti Releases</name>
<url>https://artifacts.alfresco.com/nexus/content/repositories/activiti-releases/</url>
<releases>
<enabled>true</enabled>
</releases>
</repository>
</repositories>
在Activiti中核心類的是ProcessEngine流程引擎，與Spring整合就是讓Spring來管理ProcessEngine
通過org.activiti.spring.SpringProcessEngineConfiguration 與Spring整合方式來創(chuàng)建ProcessEngine對象。
創(chuàng)建spring與activiti的整合配置文件：activiti-spring.xml（名稱不固定）
2)、創(chuàng)建activiti-spring.xml
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd">
<!-- 數(shù)據(jù)源 -->
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/activiti"/>
<property name="username" value="root"/>
<property name="password" value="123456"/>
<property name="maxActive" value="3"/>
<property name="maxIdle" value="1"/>
</bean>
<!-- 工作流引擎配置bean -->
<bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration">
<!-- 數(shù)據(jù)源 -->
<property name="dataSource" ref="dataSource"/>
<!-- 使用spring事務(wù)管理器 -->
<property name="transactionManager" ref="transactionManager"/>
<!-- 數(shù)據(jù)庫策略 -->
<property name="databaseSchemaUpdate" value="drop-create"/>
</bean>
<!-- 流程引擎 -->
<bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
<property name="processEngineConfiguration" ref="processEngineConfiguration"/>
</bean>
<!-- 資源服務(wù)service -->
<bean id="repositoryService" factory-bean="processEngine" factory-method="getRepositoryService"/>
<!-- 流程運行service -->
<bean id="runtimeService" factory-bean="processEngine" factory-method="getRuntimeService"/>
<!-- 任務(wù)管理service -->
<bean id="taskService" factory-bean="processEngine" factory-method="getTaskService"/>
<!-- 歷史管理service -->
<bean id="historyService" factory-bean="processEngine" factory-method="getHistoryService"/>
<!-- 事務(wù)管理器 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
<!-- 通知 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<tx:attributes>
<!-- 傳播行為 -->
<tx:method name="save*" propagation="REQUIRED"/>
<tx:method name="insert*" propagation="REQUIRED"/>
<tx:method name="delete*" propagation="REQUIRED"/>
<tx:method name="update*" propagation="REQUIRED"/>
<tx:method name="find*" propagation="SUPPORTS" read-only="true"/>
<tx:method name="get*" propagation="SUPPORTS" read-only="true"/>
</tx:attributes>
</tx:advice>
<!-- 切面，根據(jù)具體項目修改切點配置
<aop:config proxy-target-class="true">
<aop:advisor advice-ref="txAdvice"
pointcut="execution(*com.itheima.service.impl..(..))"/>
</aop:config>-->
</beans>
databaseSchemaUpdate的取值內(nèi)容：
flase： 默認值。activiti在啟動時，會對比數(shù)據(jù)庫表中保存的版本，如果沒有表或者版本不匹配，將拋出異常。（生產(chǎn)環(huán)境常用）
true： activiti會對數(shù)據(jù)庫中所有表進行更新操作。如果表不存在，則自動創(chuàng)建。（開發(fā)時常用）
create_drop： 在activiti啟動時創(chuàng)建表，在關(guān)閉時刪除表（必須手動關(guān)閉引擎，才能刪除表）。（單元測試常用）
drop-create： 在activiti啟動時刪除原來的舊表，然后在創(chuàng)建新表（不需要手動關(guān)閉引擎）。
1.2 測試Activiti與Spring整合
1）、測試代碼
/**
測試activiti與spring整合是否成功
**/
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:activiti-spring.xml")
public class ActivitiTest {
@Autowired
private RepositoryService repositoryService;
@Test
public void test01(){
System.out.println("部署對象:"+repositoryService);
}
}
2）、執(zhí)行流程分析
下面我們一起來分析Activiti與Spring整合加載的過程。
1、加載activiti-spring.xml配置文件
2、加載SpringProcessEngineConfiguration對象，這個對象它需要依賴注入dataSource對象和transactionManager對象。
3、加載ProcessEngineFactoryBean工廠來創(chuàng)建ProcessEngine對象，而ProcessEngineFactoryBean工廠又需要依賴注入processEngineConfiguration對象。
4、processEngine對象來負責創(chuàng)建我們的Service對象，從而簡化Activiti的開發(fā)過程。
二、Activiti7與SpringBoot整合開發(fā)
Activiti7發(fā)布正式版之后，它與SpringBoot2.x已經(jīng)完全支持整合開發(fā)。
2.1 SpringBoot整合Activiti7的配置
為了能夠?qū)崿F(xiàn)SpringBoot與Activiti7整合開發(fā)，首先我們要引入相關(guān)的依賴支持。
在工程的pom.xml文件中引入相關(guān)的依賴，其中activiti的依賴是：activiti-spring-boot-starter。
具體依賴如下所示：
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.0.RELEASE</version>
</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-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-spring-boot-starter</artifactId>
<version>7.0.0.Beta2</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.29</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
通過該pom.xml文件所導入的坐標，我們就可以實現(xiàn)activiti7與Springboot整合。
2.2 SpringBoot的application.yml文件配置
為了能夠?qū)崿F(xiàn)Activiti7生成的表放到Mysql數(shù)據(jù)庫中，需要在配置文件application.yml中添加相關(guān)的配置
注意：activiti7默認沒有開啟數(shù)據(jù)庫歷史記錄，需要手動配置開啟
spring:
datasource:
url: jdbc:mysql:///activiti?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT
username: root
password: 123456
driver-class-name: com.mysql.jdbc.Driver
activiti:
#1.flase：默認值。activiti在啟動時，對比數(shù)據(jù)庫表中保存的版本，如果沒有表或者版本不匹配，將拋出異常
#2.true： activiti會對數(shù)據(jù)庫中所有表進行更新操作。如果表不存在，則自動創(chuàng)建
#3.create_drop： 在activiti啟動時創(chuàng)建表，在關(guān)閉時刪除表（必須手動關(guān)閉引擎，才能刪除表）
#4.drop-create： 在activiti啟動時刪除原來的舊表，然后在創(chuàng)建新表（不需要手動關(guān)閉引擎）
database-schema-update: true
#檢測歷史表是否存在 activiti7默認沒有開啟數(shù)據(jù)庫歷史記錄 啟動數(shù)據(jù)庫歷史記錄
db-history-used: true
#記錄歷史等級 可配置的歷史級別有none, activity, audit, full
#none：不保存任何的歷史數(shù)據(jù)，因此，在流程執(zhí)行過程中，這是最高效的。
#activity：級別高于none，保存流程實例與流程行為，其他數(shù)據(jù)不保存。
#audit：除activity級別會保存的數(shù)據(jù)外，還會保存全部的流程任務(wù)及其屬性。audit為history的默認值。
#full：保存歷史數(shù)據(jù)的最高級別，除了會保存audit級別的數(shù)據(jù)外，還會保存其他全部流程相關(guān)的細節(jié)數(shù)據(jù)，包括一些流程參數(shù)等。
history-level: full
#校驗流程文件，默認校驗resources下的processes文件夾里的流程文件
check-process-definitions: false
2.3 編寫啟動類
package com.itheima;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class ActApplication {
public static void main(String[] args) {
SpringApplication.run(ActApplication.class,args);
}
}
2.4 添加SpringSecurity安全框架整合配置
因為Activiti7與SpringBoot整合后，默認情況下，集成了SpringSecurity安全框架，這樣我們就要去準備SpringSecurity整合進來的相關(guān)用戶權(quán)限配置信息。
SpringBoot的依賴包已經(jīng)將SpringSecurity的依賴包也添加進項目中。
2.4.1 添加SecurityUtil類
為了能夠快速實現(xiàn)SpringSecurity安全框架的配置，所添加的一個組件。
package com.itheima.utils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.security.core.Authentication;
import org.springframework.security.core.GrantedAuthority;
import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.security.core.context.SecurityContextImpl;
import org.springframework.security.core.userdetails.UserDetails;
import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.stereotype.Component;
import java.util.Collection;
@Component
public class SecurityUtil {
private Logger logger = LoggerFactory.getLogger(SecurityUtil.class);
@Autowired
@Qualifier("myUserDetailsService")
private UserDetailsService userDetailsService;
public void logInAs(String username) {
UserDetails user = userDetailsService.loadUserByUsername(username);
if (user == null) {
throw new IllegalStateException("User " + username + " doesn't exist, please provide a valid user");
}
logger.info("> Logged in as: " + username);
SecurityContextHolder.setContext(
new SecurityContextImpl(
new Authentication() {
@Override
public Collection<? extends GrantedAuthority> getAuthorities() {
return user.getAuthorities();
}
@Override
public Object getCredentials() {
return user.getPassword();
}
@Override
public Object getDetails() {
return user;
}
@Override
public Object getPrincipal() {
return user;
}
@Override
public boolean isAuthenticated() {
return true;
}
@Override
public void setAuthenticated(boolean isAuthenticated) throws IllegalArgumentException { }
@Override
public String getName() {
return user.getUsername();
}
}));
org.activiti.engine.impl.identity.Authentication.setAuthenticatedUserId(username);
}
}
這個類可以從我們下載的Activiti7官方提供的Example中找到。
2.4.2 添加DemoApplicationConfig類
在Activiti7官方下載的Example中找到DemoApplicationConfig類，它的作用是為了實現(xiàn)SpringSecurity框架的用戶權(quán)限的配置，這樣我們就可以在系統(tǒng)中使用用戶權(quán)限信息。
本次項目中基本是在文件中定義出來的用戶信息，當然也可以是數(shù)據(jù)庫中查詢的用戶權(quán)限信息。
后面處理流程時用到的任務(wù)負責人，需要添加在這里
package com.itheima.config;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.core.authority.SimpleGrantedAuthority;
import org.springframework.security.core.userdetails.User;
import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.security.provisioning.InMemoryUserDetailsManager;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
@Configuration
public class DemoApplicationConfiguration {
private Logger logger = LoggerFactory.getLogger(DemoApplicationConfiguration.class);
@Bean
public UserDetailsService myUserDetailsService() {
InMemoryUserDetailsManager inMemoryUserDetailsManager = new InMemoryUserDetailsManager();
//這里添加用戶，后面處理流程時用到的任務(wù)負責人，需要添加在這里
String[][] usersGroupsAndRoles = {
{"jack", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"},
{"rose", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"},
{"tom", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"},
{"other", "password", "ROLE_ACTIVITI_USER", "GROUP_otherTeam"},
{"system", "password", "ROLE_ACTIVITI_USER"},
{"admin", "password", "ROLE_ACTIVITI_ADMIN"},
};
for (String[] user : usersGroupsAndRoles) {
List<String> authoritiesStrings = Arrays.asList(Arrays.copyOfRange(user, 2, user.length));
logger.info("> Registering new user: " + user[0] + " with the following Authorities[" + authoritiesStrings + "]");
inMemoryUserDetailsManager.createUser(new User(user[0], passwordEncoder().encode(user[1]),
authoritiesStrings.stream().map(s -> new SimpleGrantedAuthority(s)).collect(Collectors.toList())));
}
return inMemoryUserDetailsManager;
}
@Bean
public PasswordEncoder passwordEncoder() {
return new BCryptPasswordEncoder();
}
}
2.5 創(chuàng)建Bpmn文件
Activiti7可以自動部署流程，前提是在resources目錄下，創(chuàng)建一個新的目錄processes，用來放置bpmn文件。
創(chuàng)建一個簡單的Bpmn流程文件，并設(shè)置任務(wù)的用戶組Candidate Groups。
Candidate Groups中的內(nèi)容與上面DemoApplicationConfiguration類中出現(xiàn)的用戶組名稱要保持一致，可以填寫：activitiTeam 或者 otherTeam。
這樣填寫的好處：當不確定到底由誰來負責當前任務(wù)的時候，只要是Groups內(nèi)的用戶都可以拾取這個任務(wù)
2.6 使用Junit方式測試
package com.itheima.test;
import com.itheima.utils.SecurityUtil;
import org.activiti.api.process.model.ProcessInstance;
import org.activiti.api.process.model.builders.ProcessPayloadBuilder;
import org.activiti.api.process.runtime.ProcessRuntime;
import org.activiti.api.runtime.shared.query.Page;
import org.activiti.api.runtime.shared.query.Pageable;
import org.activiti.api.task.model.Task;
import org.activiti.api.task.model.builders.TaskPayloadBuilder;
import org.activiti.api.task.runtime.TaskRuntime;
import org.activiti.engine.repository.ProcessDefinition;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
@RunWith(SpringRunner.class)
@SpringBootTest
public class Actviti7DemoApplicationTests {
@Autowired
private ProcessRuntime processRuntime;
@Autowired
private TaskRuntime taskRuntime;
@Autowired
private SecurityUtil securityUtil;
@Test
public void testActBoot(){
System.out.println(taskRuntime);
}
/**
* 查看流程定義
*/
@Test
public void contextLoads() {
securityUtil.logInAs("system");
Page<org.activiti.api.process.model.ProcessDefinition> processDefinitionPage =
processRuntime.processDefinitions(Pageable.of(0, 10));
System.out.println("可用的流程定義數(shù)量：" + processDefinitionPage.getTotalItems());
for (org.activiti.api.process.model.ProcessDefinition pd : processDefinitionPage.getContent()) {
System.out.println("流程定義：" + pd);
}
}
/**
* 啟動流程實例
*/
@Test
public void testStartProcess() {
securityUtil.logInAs("system");
ProcessInstance pi = processRuntime.start(ProcessPayloadBuilder.
start().
withProcessDefinitionKey("myProcess").
build());
System.out.println("流程實例ID：" + pi.getId());
}
/**
**查詢?nèi)蝿?wù)，并完成自己的任務(wù)
**/
@Test
public void testTask() {
securityUtil.logInAs("jack");
Page<Task> taskPage=taskRuntime.tasks(Pageable.of(0,10));
if (taskPage.getTotalItems()>0){
for (Task task:taskPage.getContent()){
taskRuntime.claim(TaskPayloadBuilder.
claim().
withTaskId(task.getId()).build());
System.out.println("任務(wù)："+task);
taskRuntime.complete(TaskPayloadBuilder.
complete().
withTaskId(task.getId()).build());
}
}
Page<Task> taskPage2=taskRuntime.tasks(Pageable.of*(0,10));
if (taskPage2.getTotalItems()>0){
System.out.println("任務(wù)："+taskPage2.getContent());
}
}
}
到此這篇關(guān)于Activiti7與Spring以及Spring Boot整合開發(fā)的文章就介紹到這了,更多相關(guān)Activiti7整合開發(fā)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
基于swagger參數(shù)與實體中參數(shù)不一致的原因分析
這篇文章主要介紹了基于swagger參數(shù)與實體中參數(shù)不一致的原因分析,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-11-11
后端開發(fā)鎖成為一個不可避免的話題，今天我們討論的是與之對應(yīng)的無鎖 CAS。本文會從怎么來的、是什么、怎么用、原理分析、遇到的問題等不同的角度帶你真正搞懂 CAS。2021-09-09
這篇文章主要介紹了IDEA創(chuàng)建Java項目導出Jar包運行,需要的朋友可以參考下2021-01-01
本文小編給大家整理了在Java中關(guān)于靜態(tài)調(diào)用和動態(tài)調(diào)用的方法匯總，值得大家學習和參考。2017-11-11
這篇文章主要對Java太陽系小游戲進行深入分析以及對應(yīng)源碼解釋，進一步鞏固了面向?qū)ο蟮闹R,需要的朋友可以參考下2015-08-08
這篇文章主要為大家介紹了GC算法實現(xiàn)篇之并發(fā)-標記-清除,?CMS垃圾收集器在減少停頓時間上做了很多給力的工作,?大量的并發(fā)線程執(zhí)行的工作并不需要暫停應(yīng)用線程2022-01-01
java objectUtils 使用可能會出現(xiàn)的問題
這篇文章主要介紹了java objectUtils 使用可能會出現(xiàn)的問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-02-02
這篇文章主要介紹了前端開發(fā)每天必學之SQL及HTML入門基礎(chǔ)知識，介紹了學習web前端開發(fā)需要掌握的基礎(chǔ)技術(shù)，感興趣的小伙伴們可以參考一下2021-07-07
這篇文章主要介紹了java高質(zhì)量縮放圖片的示例代碼，幫助大家更好的使用Java處理圖片，感興趣的朋友可以了解下2020-09-09
這篇文章主要介紹了java爬取并下載酷狗TOP500歌曲的方法，非常具有實用價值，需要的朋友可以參考下2019-01-01