百木园-与人分享，
就是让自己快乐。
当前位置：百木园 > 野生技术 > 正文

Activiti7+SpringBoot

2022-12-08 分类：野生技术 阅读(203) 评论(0)

1. 版本问题

1.1. Activiti版本

7.1.0-M6是最后一个支持JDK1.8的版本，此后的版本都要求JDK11以上

目前，Activiti最新版本是7.6.0，它是用JDK11编译的，因此要想使用最新版7.6.0必须升级JDK版本，不能再用1.8

同时，7.6.0依赖的SpringBoot版本是2.7.5

1.2. SpringBoot版本

最新的SpringBoot版本是3.0.0，这个版本不支持JDK1.8，对JDK的最小版本是17

目前可用比较多的Java版本是Java 17 和 Java 19

综合来看，我们采用Java 17+SpringBoot 2.7.5+Activiti 7.6.1

补充：52 = Java 8  55 = Java 11

2. Maven仓库设置

首先要添加Activiti组件的仓库，不然找不到jar包，可用配置在全局的settings.xml文件中，也可以配置在项目pom.xml中

<repositories>
    <repository>
        <id>activiti-releases</id>
        <url>https://artifacts.alfresco.com/nexus/content/repositories/activiti-releases</url>
    </repository>
</repositories>

如果settings.xml中有镜像，并且所有镜像都使用一个仓库的话（即，morrorOf配置的是*），要注意将新加的这个仓库排除

https://maven.apache.org/guides/mini/guide-mirror-settings.html

举个例子：

3. 依赖管理

Activiti依赖管理

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-dependencies</artifactId>
            <version>7.6.1</version>
            <scope>import</scope>
            <type>pom</type>
        </dependency>
    </dependencies>
</dependencyManagement>

Dubbo依赖管理

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-bom</artifactId>
            <version>3.1.3</version>
            <scope>import</scope>
            <type>pom</type>
        </dependency>
    </dependencies>
</dependencyManagement>

完整的父POM如下：

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd\">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <!--<version>3.0.0</version>-->
        <version>2.7.5</version>
        <relativePath/>
    </parent>
    <groupId>com.cjs.example</groupId>
    <artifactId>activiti7-sample</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>pom</packaging>

    <name>activiti7-sample</name>

    <modules>
        <module>activiti7-sample-provider-api</module>
        <module>activiti7-sample-provider</module>
    </modules>

    <properties>
        <java.version>17</java.version>
        <maven.compiler.source>17</maven.compiler.source>
        <maven.compiler.target>17</maven.compiler.target>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <!--
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-spring-boot-starter</artifactId>
                <version>7.1.0.M6</version>
            </dependency>
            -->
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-dependencies</artifactId>
                <version>7.6.1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-bom</artifactId>
                <version>3.1.3</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <dependency>
                <groupId>com.baomidou</groupId>
                <artifactId>mybatis-plus-boot-starter</artifactId>
                <version>3.5.2</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <repositories>
	    <repository>
            <id>activiti-releases</id>
            <url>https://artifacts.alfresco.com/nexus/content/repositories/activiti-releases</url>
        </repository>
    </repositories>
</project>

4. Activiti  API使用

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 https://maven.apache.org/xsd/maven-4.0.0.xsd\">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.cjs.example</groupId>
        <artifactId>activiti7-sample</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </parent>
    <groupId>com.cjs.example</groupId>
    <artifactId>activiti7-sample-provider</artifactId>
    <version>${parent.version}</version>

    <name>activiti7-sample-provider</name>

    <properties>
        <java.version>17</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>com.cjs.example</groupId>
            <artifactId>activiti7-sample-provider-api</artifactId>
            <version>${project.version}</version>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-nacos</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-spring-boot-starter</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-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-security</artifactId>
        </dependency>

        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.mysql</groupId>
            <artifactId>mysql-connector-j</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>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

application.yml

server:
  port: 8080
  servlet:
    context-path: /activiti7
spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/activiti7?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&nullCatalogMeansCurrent=true&serverTimezone=Asia/Shanghai
    username: root
    password: 123456
  activiti:
    check-process-definitions: false
    database-schema-update: \"false\" # 第一次运行时设置为true，待表生成完以后改成false，以后就不用再更新表结构了
    db-history-used: true
    history-level: full
    deployment-mode: \"never-fail\" # org.activiti.spring.autodeployment.AbstractAutoDeploymentStrategy
dubbo:
  application:
    name: activiti7-sample-provider
  protocol:
    name: dubbo
    port: -1
  registry:
    address: nacos://127.0.0.1:8848
  config-center:
    address: nacos://127.0.0.1:8848
  metadata-report:
    address: nacos://127.0.0.1:8848

启动项目后，生成的表结构如图：

也可以自己执行SQL脚本，脚本在源码包activiti-engine-7.6.1.jar里面

由于Activit7集成了SpringSecurity，它用SpringSecurity来做权限管理，因此它需要一个UserDetailsService，不配做的话启动会报错。当然网上也有一种解决办法就是排除SpringSecurity相关的某些类，没试过，应该也是可以的吧。

按照Spring Security 5.7以后的新写法，我们来配置一下WebSecurity

https://docs.spring.io/spring-security/reference/servlet/configuration/java.html

https://github.com/spring-projects/spring-security-samples/tree/6.0.x/servlet/spring-boot/java/oauth2

package com.cjs.example.provider.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.config.Customizer;
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.WebSecurityCustomizer;
import org.springframework.security.core.userdetails.User;
import org.springframework.security.core.userdetails.UserDetails;
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 org.springframework.security.web.SecurityFilterChain;

/**
 * https://docs.spring.io/spring-security/reference/servlet/configuration/java.html
 * https://github.com/spring-projects/spring-security-samples/tree/6.0.x/servlet/spring-boot/java/oauth2
 *
 * @Author: ChengJianSheng
 * @Date:   2022/12/5
 */
@Configuration
@EnableWebSecurity
public class MyWebSecurityConfiguration {

    @Bean
    public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Exception {
        http.authorizeRequests(authorize -> authorize.anyRequest().authenticated())
                .formLogin(Customizer.withDefaults());
        return http.build();
    }

    @Bean
    public WebSecurityCustomizer webSecurityCustomizer() {
        return (web) -> web.ignoring()
                // Spring Security should completely ignore URLs starting with /resources/
                .antMatchers(\"/resources/**\");
    }

    @Bean
    public UserDetailsService userDetailsService() {
        UserDetails admin = User.withUsername(\"tom\")
                .password(\"$2a$10$tk29HhXGXCZDOSvn.VZlFeBsLmtJrKE2Uv6zLrRpTyvZMu3ipQLgC\")
                .roles(\"ACTIVITI_USER\", \"ACTIVITI_ADMIN\", \"APPLICATION_MANAGER\")
                .build();
        UserDetails user = User.withUsername(\"jerry\")
                .password(\"$2a$10$tk29HhXGXCZDOSvn.VZlFeBsLmtJrKE2Uv6zLrRpTyvZMu3ipQLgC\")
                .roles(\"ACTIVITI_USER\", \"GROUP_BUSINESS_MANAGER\")
                .build();
        UserDetails zhangsan = User.withUsername(\"zhangsan\")
                .password(\"$2a$10$tk29HhXGXCZDOSvn.VZlFeBsLmtJrKE2Uv6zLrRpTyvZMu3ipQLgC\")
                .roles(\"ACTIVITI_USER\")
                .build();
        UserDetails lisi = User.withUsername(\"lisi\")
                .password(\"$2a$10$tk29HhXGXCZDOSvn.VZlFeBsLmtJrKE2Uv6zLrRpTyvZMu3ipQLgC\")
                .roles(\"ACTIVITI_USER\")
                .build();
        return new InMemoryUserDetailsManager(admin, user, zhangsan, lisi);
    }

    @Bean
    public PasswordEncoder passwordEncoder() {
        return new BCryptPasswordEncoder();
    }

    public static void main(String[] args) {
        System.out.println(new BCryptPasswordEncoder().encode(\"123456\"));
    }
}

在activiti-spring-boot-starter中新提供了ProcessRuntime 和 TaskRuntime用于流程和任务处理的API，调用它们需要当前操作的用户具有ACTIVITI_USER权限

因此，在使用这两个类之前要保证当前登录用户有这个权限。为了模拟登录，我们来写个登录方法。

package com.cjs.example.provider.util;

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;

/**
 * @Author: ChengJianSheng
 * @Date: 2022/12/6
 */
@Component
public class SecurityUtil {

    @Autowired
    private UserDetailsService userDetailsService;

    public void logInAs(String username) {
        UserDetails user = userDetailsService.loadUserByUsername(username);
        if (null == user) {
            throw new IllegalStateException(String.format(\"用户【%s】不存在\", 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);
    }
}

现在可以开始调用API操作流程了

package com.cjs.example.provider.service;

import com.cjs.example.provider.api.WorkflowService;
import com.cjs.example.provider.util.SecurityUtil;
import org.activiti.api.process.model.ProcessInstance;
import org.activiti.api.process.model.builders.ProcessPayloadBuilder;
import org.activiti.api.process.model.payloads.GetProcessInstancesPayload;
import org.activiti.api.process.runtime.ProcessRuntime;
import org.activiti.api.runtime.shared.query.Order;
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.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.repository.Deployment;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.Map;

/**
 * @Author: ChengJianSheng
 * @Date: 2022/12/6
 */
@DubboService
public class WorkflowServiceImpl implements WorkflowService {

    @Autowired
    private ProcessRuntime processRuntime;

    @Autowired
    private TaskRuntime taskRuntime;

    @Autowired
    private RuntimeService runtimeService;

    @Autowired
    private RepositoryService repositoryService;

    @Autowired
    private SecurityUtil securityUtil;


    @Override
    public void deploy() {
        Deployment deployment = repositoryService.createDeployment()
                .addClasspathResource(\"processes/leave.bpmn20.xml\")
                .name(\"请假\")
                .key(\"leave\")
                .category(\"AAA\")
                .tenantId(\"QingJia\")
                .deploy();
    }

    @Override
    public void start() {
        securityUtil.logInAs(\"tom\");
        ProcessInstance processInstance = processRuntime.start(ProcessPayloadBuilder.start()
                .withProcessDefinitionKey(\"leave\")
                .withVariable(\"hello\", \"world\")
                .withVariable(\"apple\", \"orange\")
                .withBusinessKey(\"1\")
                .build());
    }

    @Override
    public void startProcessInstance(String processDefinitionKey, String businessKey, Map<String, Object> variables, String tenantId) {
        runtimeService.startProcessInstanceByKeyAndTenantId(processDefinitionKey, businessKey, variables, tenantId);
    }

    @Override
    public void processInstancePage(int pageNo, int pageSize) {
        securityUtil.logInAs(\"tom\");
        GetProcessInstancesPayload payload = new GetProcessInstancesPayload();
        payload.setActiveOnly(true);
        Page<ProcessInstance> page = processRuntime.processInstances(Pageable.of(pageNo-1, pageSize, Order.by(\"start_time_\", Order.Direction.DESC)), payload);
        for (ProcessInstance ps : page.getContent()) {
            System.out.println(ps);
        }
    }

    @Override
    public void taskList() {
        securityUtil.logInAs(\"zhangsan\");
        Page<Task> taskPage = taskRuntime.tasks(Pageable.of(0, 10));
        System.out.println(taskPage.getTotalItems());

        securityUtil.logInAs(\"lisi\");
        taskPage = taskRuntime.tasks(Pageable.of(0, 10));
        System.out.println(taskPage.getTotalItems());
    }

    @Override
    public void claimTask() {
        securityUtil.logInAs(\"zhangsan\");
        String taskId = \"429ad159-754c-11ed-aaf8-84a9386654d8\";
        Task task = taskRuntime.task(taskId);
        taskRuntime.claim(TaskPayloadBuilder.claim().withTaskId(taskId).build());
    }

    @Override
    public void completeTask() {
        securityUtil.logInAs(\"zhangsan\");
        String taskId = \"429ad159-754c-11ed-aaf8-84a9386654d8\";
        taskRuntime.complete(TaskPayloadBuilder.complete().withTaskId(taskId).build());
    }
}

注意：可以把tenantId看成是某个业务，businessKey当做业务ID，比如：放款流程001。或者建一张中间表用于关联流程ID和业务ID。

最后，配置流程监听器

package com.cjs.example.provider.config;

import lombok.extern.slf4j.Slf4j;
import org.activiti.api.process.runtime.events.ProcessCompletedEvent;
import org.activiti.api.process.runtime.events.listener.ProcessRuntimeEventListener;
import org.activiti.api.task.runtime.events.TaskAssignedEvent;
import org.activiti.api.task.runtime.events.TaskCompletedEvent;
import org.activiti.api.task.runtime.events.listener.TaskRuntimeEventListener;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Author: ChengJianSheng
 * @Date: 2022/12/6
 */
@Slf4j
@Configuration
public class ListenerConfig {

    @Bean
    public ProcessRuntimeEventListener<ProcessCompletedEvent> processCompletedListener() {
        return processCompleted -> log.info(\">>> Process Completed: \'\"
                + processCompleted.getEntity().getName() +
                \"\' We can send a notification to the initiator: \" + processCompleted.getEntity().getInitiator());
    }

    @Bean
    public TaskRuntimeEventListener<TaskAssignedEvent> taskAssignedListener() {
        return taskAssigned -> log.info(\">>> Task Assigned: \'\"
                + taskAssigned.getEntity().getName() +
                \"\' We can send a notification to the assginee: \" + taskAssigned.getEntity().getAssignee());
    }

    @Bean
    public TaskRuntimeEventListener<TaskCompletedEvent> taskCompletedListener() {
        return taskCompleted -> log.info(\">>> Task Completed: \'\"
                + taskCompleted.getEntity().getName() +
                \"\' We can send a notification to the owner: \" + taskCompleted.getEntity().getOwner());
    }
}

代码：https://gitee.com/chengjiansheng/activiti7-sample

 

来源：https://www.cnblogs.com/cjsblog/p/16962719.html
本站部分图文来源于网络，如有侵权请联系删除。

未经允许不得转载：百木园 » Activiti7+SpringBoot
标签：

相关推荐

  • 暂无文章

热门文章