Activiti7與Spring以及Spring Boot整合開(kāi)發(fā)
Activiti整合Spring
一、Activiti與Spring整合開(kāi)發(fā)
1.1 Activiti與Spring整合的配置
1)、在pom.xml文件引入坐標(biāo)
如下
<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來(lái)管理ProcessEngine
通過(guò)org.activiti.spring.SpringProcessEngineConfiguration 與Spring整合方式來(lái)創(chuàng)建ProcessEngine對(duì)象。
創(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ù)庫(kù)策略 --> <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"/> <!-- 流程運(yùn)行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ù)具體項(xiàng)目修改切點(diǎn)配置 <aop:config proxy-target-class="true"> <aop:advisor advice-ref="txAdvice" pointcut="execution(*com.itheima.service.impl..(..))"/> </aop:config>--> </beans>
databaseSchemaUpdate的取值內(nèi)容:
flase: 默認(rèn)值。activiti在啟動(dòng)時(shí),會(huì)對(duì)比數(shù)據(jù)庫(kù)表中保存的版本,如果沒(méi)有表或者版本不匹配,將拋出異常。(生產(chǎn)環(huán)境常用)
true: activiti會(huì)對(duì)數(shù)據(jù)庫(kù)中所有表進(jìn)行更新操作。如果表不存在,則自動(dòng)創(chuàng)建。(開(kāi)發(fā)時(shí)常用)
create_drop: 在activiti啟動(dòng)時(shí)創(chuàng)建表,在關(guān)閉時(shí)刪除表(必須手動(dòng)關(guān)閉引擎,才能刪除表)。(單元測(cè)試常用)
drop-create: 在activiti啟動(dòng)時(shí)刪除原來(lái)的舊表,然后在創(chuàng)建新表(不需要手動(dòng)關(guān)閉引擎)。
1.2 測(cè)試Activiti與Spring整合
1)、測(cè)試代碼
/** 測(cè)試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("部署對(duì)象:"+repositoryService); } }
2)、執(zhí)行流程分析
下面我們一起來(lái)分析Activiti與Spring整合加載的過(guò)程。
1、加載activiti-spring.xml配置文件
2、加載SpringProcessEngineConfiguration對(duì)象,這個(gè)對(duì)象它需要依賴注入dataSource對(duì)象和transactionManager對(duì)象。
3、加載ProcessEngineFactoryBean工廠來(lái)創(chuàng)建ProcessEngine對(duì)象,而ProcessEngineFactoryBean工廠又需要依賴注入processEngineConfiguration對(duì)象。
4、processEngine對(duì)象來(lái)負(fù)責(zé)創(chuàng)建我們的Service對(duì)象,從而簡(jiǎn)化Activiti的開(kāi)發(fā)過(guò)程。
二、Activiti7與SpringBoot整合開(kāi)發(fā)
Activiti7發(fā)布正式版之后,它與SpringBoot2.x已經(jīng)完全支持整合開(kāi)發(fā)。
2.1 SpringBoot整合Activiti7的配置
為了能夠?qū)崿F(xiàn)SpringBoot與Activiti7整合開(kāi)發(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>
通過(guò)該pom.xml文件所導(dǎo)入的坐標(biāo),我們就可以實(shí)現(xiàn)activiti7與Springboot整合。
2.2 SpringBoot的application.yml文件配置
為了能夠?qū)崿F(xiàn)Activiti7生成的表放到Mysql數(shù)據(jù)庫(kù)中,需要在配置文件application.yml中添加相關(guān)的配置
注意:activiti7默認(rèn)沒(méi)有開(kāi)啟數(shù)據(jù)庫(kù)歷史記錄,需要手動(dòng)配置開(kāi)啟
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:默認(rèn)值。activiti在啟動(dòng)時(shí),對(duì)比數(shù)據(jù)庫(kù)表中保存的版本,如果沒(méi)有表或者版本不匹配,將拋出異常 #2.true: activiti會(huì)對(duì)數(shù)據(jù)庫(kù)中所有表進(jìn)行更新操作。如果表不存在,則自動(dòng)創(chuàng)建 #3.create_drop: 在activiti啟動(dòng)時(shí)創(chuàng)建表,在關(guān)閉時(shí)刪除表(必須手動(dòng)關(guān)閉引擎,才能刪除表) #4.drop-create: 在activiti啟動(dòng)時(shí)刪除原來(lái)的舊表,然后在創(chuàng)建新表(不需要手動(dòng)關(guān)閉引擎) database-schema-update: true #檢測(cè)歷史表是否存在 activiti7默認(rèn)沒(méi)有開(kāi)啟數(shù)據(jù)庫(kù)歷史記錄 啟動(dòng)數(shù)據(jù)庫(kù)歷史記錄 db-history-used: true #記錄歷史等級(jí) 可配置的歷史級(jí)別有none, activity, audit, full #none:不保存任何的歷史數(shù)據(jù),因此,在流程執(zhí)行過(guò)程中,這是最高效的。 #activity:級(jí)別高于none,保存流程實(shí)例與流程行為,其他數(shù)據(jù)不保存。 #audit:除activity級(jí)別會(huì)保存的數(shù)據(jù)外,還會(huì)保存全部的流程任務(wù)及其屬性。audit為history的默認(rèn)值。 #full:保存歷史數(shù)據(jù)的最高級(jí)別,除了會(huì)保存audit級(jí)別的數(shù)據(jù)外,還會(huì)保存其他全部流程相關(guān)的細(xì)節(jié)數(shù)據(jù),包括一些流程參數(shù)等。 history-level: full #校驗(yàn)流程文件,默認(rèn)校驗(yàn)resources下的processes文件夾里的流程文件 check-process-definitions: false
2.3 編寫(xiě)啟動(dòng)類
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安全框架整合配置
因?yàn)锳ctiviti7與SpringBoot整合后,默認(rèn)情況下,集成了SpringSecurity安全框架,這樣我們就要去準(zhǔn)備SpringSecurity整合進(jìn)來(lái)的相關(guān)用戶權(quán)限配置信息。
SpringBoot的依賴包已經(jīng)將SpringSecurity的依賴包也添加進(jìn)項(xiàng)目中。
2.4.1 添加SecurityUtil類
為了能夠快速實(shí)現(xiàn)SpringSecurity安全框架的配置,所添加的一個(gè)組件。
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); } }
這個(gè)類可以從我們下載的Activiti7官方提供的Example中找到。
2.4.2 添加DemoApplicationConfig類
在Activiti7官方下載的Example中找到DemoApplicationConfig類,它的作用是為了實(shí)現(xiàn)SpringSecurity框架的用戶權(quán)限的配置,這樣我們就可以在系統(tǒng)中使用用戶權(quán)限信息。
本次項(xiàng)目中基本是在文件中定義出來(lái)的用戶信息,當(dāng)然也可以是數(shù)據(jù)庫(kù)中查詢的用戶權(quán)限信息。
后面處理流程時(shí)用到的任務(wù)負(fù)責(zé)人,需要添加在這里
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(); //這里添加用戶,后面處理流程時(shí)用到的任務(wù)負(fù)責(zé)人,需要添加在這里 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可以自動(dòng)部署流程,前提是在resources目錄下,創(chuàng)建一個(gè)新的目錄processes,用來(lái)放置bpmn文件。
創(chuàng)建一個(gè)簡(jiǎn)單的Bpmn流程文件,并設(shè)置任務(wù)的用戶組Candidate Groups。
Candidate Groups中的內(nèi)容與上面DemoApplicationConfiguration類中出現(xiàn)的用戶組名稱要保持一致,可以填寫(xiě):activitiTeam 或者 otherTeam。
這樣填寫(xiě)的好處:當(dāng)不確定到底由誰(shuí)來(lái)負(fù)責(zé)當(dāng)前任務(wù)的時(shí)候,只要是Groups內(nèi)的用戶都可以拾取這個(gè)任務(wù)
2.6 使用Junit方式測(cè)試
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); } } /** * 啟動(dòng)流程實(shí)例 */ @Test public void testStartProcess() { securityUtil.logInAs("system"); ProcessInstance pi = processRuntime.start(ProcessPayloadBuilder. start(). withProcessDefinitionKey("myProcess"). build()); System.out.println("流程實(shí)例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整合開(kāi)發(fā)的文章就介紹到這了,更多相關(guān)Activiti7整合開(kāi)發(fā)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
基于swagger參數(shù)與實(shí)體中參數(shù)不一致的原因分析
這篇文章主要介紹了基于swagger參數(shù)與實(shí)體中參數(shù)不一致的原因分析,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-11-11IDEA創(chuàng)建Java項(xiàng)目導(dǎo)出Jar包運(yùn)行
這篇文章主要介紹了IDEA創(chuàng)建Java項(xiàng)目導(dǎo)出Jar包運(yùn)行,需要的朋友可以參考下2021-01-01GC算法實(shí)現(xiàn)篇之并發(fā)標(biāo)記清除
這篇文章主要為大家介紹了GC算法實(shí)現(xiàn)篇之并發(fā)-標(biāo)記-清除,?CMS垃圾收集器在減少停頓時(shí)間上做了很多給力的工作,?大量的并發(fā)線程執(zhí)行的工作并不需要暫停應(yīng)用線程2022-01-01java objectUtils 使用可能會(huì)出現(xiàn)的問(wèn)題
這篇文章主要介紹了java objectUtils 使用可能會(huì)出現(xiàn)的問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-02-02Java SQL注入案例教程及html基礎(chǔ)入門(mén)
這篇文章主要介紹了前端開(kāi)發(fā)每天必學(xué)之SQL及HTML入門(mén)基礎(chǔ)知識(shí),介紹了學(xué)習(xí)web前端開(kāi)發(fā)需要掌握的基礎(chǔ)技術(shù),感興趣的小伙伴們可以參考一下2021-07-07