爲了可以實現 SpringBoot 與 Activiti7 整合開發,首先咱們要引入相關的依賴支持。
因此,咱們在工程的 pom.xml 文件中引入相關的依賴,具體依賴以下所示:java
<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-jdbc</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <!-- https://mvnrepository.com/artifact/org.activiti/activiti-spring-boot-starter --> <dependency> <groupId>org.activiti</groupId> <artifactId>activiti-spring-boot-starter</artifactId> <version>7.0.0.Beta2</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>3.4.5</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.15</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build>
經過該 pom.xml 文件所導入的座標,咱們就能夠實現 activiti7 與 Springboot 整合。
mysql
爲了可以實現 Activiti7 生成的表放到 Mysql 數據庫中,須要在 springboot 的配置文件 application.yml
中添加相關的配置
git
spring: datasource: url: jdbc:mysql://localhost:3306/activiti?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT username : root password : 123456 driver-class-name: com.mysql.jdbc.Driver
由於 Activiti7 與 SpringBoot 整合後,默認狀況下,集成了 SpringSecurity 安全框架,這樣咱們就要去
準備 SpringSecurity 整合進來的相關用戶權限配置信息。
能夠查看一下整合 SpringBoot 的依賴包,發現同時也將 SpringSecurity 的依賴包也添加進項目中了,
以下:
github
添加 SecurityUtil 類。
爲了可以快速實現 SpringSecurity 安全框架的配置,所添加的一個組件。
web
package com.topcheer.activiti; import org.springframework.beans.factory.annotation.Autowired; 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 { @Autowired 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"); } 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 中找到。
spring
在 Activiti7 官方下載的 Example 中找到 DemoApplicationConfig 類,它的做用是爲了實現
SpringSecurity 框架的用戶權限的配置,這樣咱們就能夠在系統中使用用戶權限信息。本次項目中基
本是在文件中定義出來的用戶信息,固然也能夠是數據庫中查詢的用戶權限信息。 sql
/* * Copyright 2018 Alfresco, Inc. and/or its affiliates. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.topcheer.activiti; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.security.config.annotation.authentication.builders.AuthenticationManagerBuilder; import org.springframework.security.config.annotation.web.builders.HttpSecurity; import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity; import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter; 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 @EnableWebSecurity public class DemoApplicationConfiguration extends WebSecurityConfigurerAdapter { private Logger logger = LoggerFactory.getLogger(DemoApplicationConfiguration.class); @Override @Autowired public void configure(AuthenticationManagerBuilder auth) throws Exception { auth.userDetailsService(myUserDetailsService()); } @Bean public UserDetailsService myUserDetailsService() { InMemoryUserDetailsManager inMemoryUserDetailsManager = new InMemoryUserDetailsManager(); String[][] usersGroupsAndRoles = { {"salaboy", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"}, {"ryandawsonuk", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"}, {"erdemedeiros", "password", "ROLE_ACTIVITI_USER", "GROUP_activitiTeam"}, {"other", "password", "ROLE_ACTIVITI_USER", "GROUP_otherTeam"}, {"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; } @Override protected void configure(HttpSecurity http) throws Exception { http .csrf().disable() .authorizeRequests() .anyRequest() .authenticated() .and() .httpBasic(); } @Bean public PasswordEncoder passwordEncoder() { return new BCryptPasswordEncoder(); } }
@RunWith(SpringRunner.class) @SpringBootTest public class ActivitiApplicationTests { @Autowired private ProcessRuntime processRuntime; @Autowired private TaskRuntime taskRuntime; @Autowired private SecurityUtil securityUtil; // // /** // * 查看流程定義 // */ @Test public void contextLoads() { securityUtil.logInAs("salaboy"); Page<ProcessDefinition> processDefinitionPage = processRuntime.processDefinitions(Pageable.of(0, 10)); System.out.println("可用的流程定義數量:" + processDefinitionPage.getTotalItems()); for (ProcessDefinition pd : processDefinitionPage.getContent()) { System.out.println("流程定義:" + pd); } } // // /** // * 啓動流程實例 // */ @Test public void testStartProcess() { securityUtil.logInAs("salaboy"); ProcessInstance pi = processRuntime.start(ProcessPayloadBuilder.start().withProcessDefinitionKey("myProcess_1") .build()); System.out.println("流程實例ID:" + pi.getId()); //流程實例ID:6d2a9bc1-0cee-11ea-acf5-f894c25ebadd } // /** * 查詢任務,並完成本身的任務 */ @Test public void testTask() { securityUtil.logInAs("ryandawsonuk"); //指定用戶認證信息 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("任務:"+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("任務:"+taskPage2.getContent()); } //任務:TaskImpl{id='6d310464-0cee-11ea-acf5-f894c25ebadd', owner='null', assignee='null', name='first', description='null', createdDate=Fri Nov 22 14:07:56 CST 2019, claimedDate=null, dueDate=null, priority=50, processDefinitionId='myProcess_1:1:7f72b399-0cec-11ea-8c61-f894c25ebadd', processInstanceId='6d2a9bc1-0cee-11ea-acf5-f894c25ebadd', parentTaskId='null', status=CREATED} //任務:[TaskImpl{id='b3cecc85-0cf0-11ea-89ae-f894c25ebadd', owner='null', assignee='null', name='second', description='null', createdDate=Fri Nov 22 14:24:13 CST 2019, claimedDate=null, dueDate=null, priority=50, processDefinitionId='myProcess_1:1:7f72b399-0cec-11ea-8c61-f894c25ebadd', processInstanceId='6d2a9bc1-0cee-11ea-acf5-f894c25ebadd', parentTaskId='null', status=CREATED}] } }
Activiti 新的 API 介紹
https://github.com/Activiti/activiti-7-developers-guide/blob/51a1681c0e4bb5e2f96a6dea73516c9fd53d8521/getting-started/getting-started-activiti-core.md
數據庫