Activiti 7 集成概述

Activiti流程引擎是BPMN开源产品中做得比较优秀的产品，经历了jbpm3,jbpm4,activiti5,activiti6的几代产品迭代，目前推出针对单体应用与云应用的activiti7，重构了原有的pvm的流程引擎机制，让流程执行效率更优，平台集成activiti7,只是使用了其流程定义与流程实例，流程待办的几块特性外，大部分进行了业务外围特性的扩展，同时保留了Activiti的其他引擎能力。

依赖导入

  1. <dependency>
  2.             <groupId>org.activiti</groupId>
  3.             <artifactId>activiti-spring-boot-starter</artifactId>
  4.             <version>7.1.0.M6</version>
  5.             <exclusions>
  6.                 <exclusion>
  7.                     <groupId>org.mybatis</groupId>
  8.                     <artifactId>mybatis</artifactId>
  9.                 </exclusion>
  10.                 <exclusion>
  11.                 <groupId>org.springframework.security</groupId>
  12.                 <artifactId>spring-security-core</artifactId>
  13.             </exclusion>
  14.             </exclusions>
  15.         </dependency>
  17.         <dependency>
  18.             <groupId>org.activiti</groupId>
  19.             <artifactId>activiti-image-generator</artifactId>
  20.             <version>7.1.0.M6</version>
  21.         </dependency>

SpringBoot中引擎配置入口

  1. package com.redxun.bpm.config;
  3. import com.redxun.bpm.activiti.event.GlobalEventListener;
  4. import com.redxun.bpm.activiti.ext.FlowDefCache;
  5. import com.redxun.bpm.activiti.ext.RxIdGenerator;
  6. import com.redxun.bpm.activiti.img.ActivitiDiagramGenerator;
  7. import com.redxun.datasource.DataSourceUtil;
  8. import org.activiti.api.runtime.shared.identity.UserGroupManager;
  9. import org.activiti.engine.cfg.ProcessEngineConfigurator;
  10. import org.activiti.engine.delegate.event.ActivitiEventListener;
  11. import org.activiti.engine.impl.bpmn.parser.factory.DefaultActivityBehaviorFactory;
  12. import org.activiti.image.ProcessDiagramGenerator;
  13. import org.activiti.spring.SpringAsyncExecutor;
  14. import org.activiti.spring.SpringProcessEngineConfiguration;
  15. import org.activiti.spring.boot.AbstractProcessEngineAutoConfiguration;
  16. import org.activiti.spring.boot.ActivitiProperties;
  17. import org.activiti.spring.boot.DefaultActivityBehaviorFactoryMappingConfigurer;
  18. import org.activiti.spring.boot.process.validation.AsyncPropertyValidator;
  19. import org.activiti.validation.ProcessValidatorImpl;
  20. import org.activiti.validation.validator.ValidatorSet;
  21. import org.springframework.beans.factory.annotation.Autowired;
  22. import org.springframework.beans.factory.annotation.Qualifier;
  23. import org.springframework.context.annotation.Bean;
  24. import org.springframework.context.annotation.Configuration;
  25. import org.springframework.context.annotation.Primary;
  26. import org.springframework.core.task.SyncTaskExecutor;
  27. import org.springframework.core.task.TaskExecutor;
  28. import org.springframework.transaction.PlatformTransactionManager;
  30. import javax.sql.DataSource;
  31. import java.io.IOException;
  32. import java.util.ArrayList;
  33. import java.util.HashSet;
  34. import java.util.List;
  36. /**
  37.  * Activiti流程引擎构建配置入口
  38.  * @author csx
  39.  * @since 1.0
  40.  */
  41. @Configuration
  42. public class ActivitiConfig extends AbstractProcessEngineAutoConfiguration {
  45.     @Bean
  46.     @Primary
  47.     public SpringProcessEngineConfiguration springProcessEngineConfiguration(
  48.             PlatformTransactionManager transactionManager,
  49.             SpringAsyncExecutor springAsyncExecutor,
  50.             ActivitiProperties activitiProperties,
  51.             @Autowired(required = false) DefaultActivityBehaviorFactoryMappingConfigurer processEngineConfigurationConfigurer,
  52.             @Autowired(required = false) List<ProcessEngineConfigurator> processEngineConfigurators,
  53.             UserGroupManager userGroupManager,
  54.             @Qualifier(DataSourceUtil.GLOBAL_DATASOURCE) DataSource dataSource) throws IOException {
  56.         SpringProcessEngineConfiguration conf = new SpringProcessEngineConfiguration();
  57.         conf.setConfigurators(processEngineConfigurators);
  58.         //设置数据源
  59.         conf.setDataSource(dataSource);
  60.         //设置全局事务管理器
  61.         conf.setTransactionManager(transactionManager);
  62.         if (springAsyncExecutor != null) {
  63.             conf.setAsyncExecutor(springAsyncExecutor);
  64.         }
  65.         //设置发布名
  66.         conf.setDeploymentName(activitiProperties.getDeploymentName());
  67.         conf.setDatabaseSchema(activitiProperties.getDatabaseSchema());
  68.         conf.setDatabaseSchemaUpdate(activitiProperties.getDatabaseSchemaUpdate());
  69.         conf.setDbHistoryUsed(activitiProperties.isDbHistoryUsed());
  70.         conf.setAsyncExecutorActivate(activitiProperties.isAsyncExecutorActivate());
  72.         if (!activitiProperties.isAsyncExecutorActivate()) {
  73.             ValidatorSet springBootStarterValidatorSet = new ValidatorSet("activiti-spring-boot-starter");
  74.             springBootStarterValidatorSet.addValidator(new AsyncPropertyValidator());
  75.             if (conf.getProcessValidator() == null) {
  76.                 ProcessValidatorImpl processValidator = new ProcessValidatorImpl();
  77.                 processValidator.addValidatorSet(springBootStarterValidatorSet);
  78.                 conf.setProcessValidator(processValidator);
  79.             } else {
  80.                 conf.getProcessValidator().getValidatorSets().add(springBootStarterValidatorSet);
  81.             }
  82.         }
  83.         //设置邮件发送配置
  84.         conf.setMailServerHost(activitiProperties.getMailServerHost());
  85.         conf.setMailServerPort(activitiProperties.getMailServerPort());
  86.         conf.setMailServerUsername(activitiProperties.getMailServerUserName());
  87.         conf.setMailServerPassword(activitiProperties.getMailServerPassword());
  88.         conf.setMailServerDefaultFrom(activitiProperties.getMailServerDefaultFrom());
  89.         conf.setMailServerUseSSL(activitiProperties.isMailServerUseSsl());
  90.         conf.setMailServerUseTLS(activitiProperties.isMailServerUseTls());
  92.         if (userGroupManager != null) {
  93.             conf.setUserGroupManager(userGroupManager);
  94.         }
  96.         conf.setHistoryLevel(activitiProperties.getHistoryLevel());
  97.         conf.setCopyVariablesToLocalForTasks(activitiProperties.isCopyVariablesToLocalForTasks());
  98.         conf.setSerializePOJOsInVariablesToJson(activitiProperties.isSerializePOJOsInVariablesToJson());
  99.         conf.setJavaClassFieldForJackson(activitiProperties.getJavaClassFieldForJackson());
  101.         if (activitiProperties.getCustomMybatisMappers() != null) {
  102.             conf.setCustomMybatisMappers(
  103.                     getCustomMybatisMapperClasses(activitiProperties.getCustomMybatisMappers()));
  104.         }
  106.         if (activitiProperties.getCustomMybatisXMLMappers() != null) {
  107.             conf.setCustomMybatisXMLMappers(
  108.                     new HashSet<>(activitiProperties.getCustomMybatisXMLMappers()));
  109.         }
  111.         if (activitiProperties.getCustomMybatisXMLMappers() != null) {
  112.             conf.setCustomMybatisXMLMappers(
  113.                     new HashSet<>(activitiProperties.getCustomMybatisXMLMappers()));
  114.         }
  116.         //设置其Id产生器
  117.         conf.setIdGenerator(new RxIdGenerator());
  119.         if (activitiProperties.getDeploymentMode() != null) {
  120.             conf.setDeploymentMode(activitiProperties.getDeploymentMode());
  121.         }
  123.         conf.setActivityBehaviorFactory(new DefaultActivityBehaviorFactory());
  125.         if (processEngineConfigurationConfigurer != null) {
  126.             processEngineConfigurationConfigurer.configure(conf);
  127.         }
  129.         //加上全局事件的控制
  130.         List<ActivitiEventListener> eventListeners=new ArrayList<>();
  131.         eventListeners.add(new GlobalEventListener());
  132.         conf.setEventListeners(eventListeners);
  133.         //修改其流程缓存
  134.         conf.setProcessDefinitionCache(new FlowDefCache());
  136.         return conf;
  137.     }
  139.     @Override
  140.     @Primary
  141.     @Bean
  142.     public TaskExecutor taskExecutor(){
  143.         return new SyncTaskExecutor();
  144.     }
  146.     @Bean
  147.     public ProcessDiagramGenerator activitiDiagramGenerator(){
  148.         return  new ActivitiDiagramGenerator();
  149.     }
  151. }

在application.yml配置数据源

  1. defaultDs:
  2.   string:
  3. #    url: jdbc:dm://localhost:5236/JPAASBPM?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=utf-8
  4. #    username: JPAASBPM
  5. #    password: JPAASBPM
  6. #    driver-class-name: dm.jdbc.driver.DmDriver
  7. #    connection-init-sqls: SET SCHEMA JPAASBPM
  8.     #url: ${bpm.datasource.url}://${bpm.datasource.ip}:${bpm.datasource.port}/${bpm.datasource.name}?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&serverTimezone=GMT%2B8
  9.     url: ${bpm.datasource.url}?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&serverTimezone=GMT%2B8
  10.     username: ${bpm.datasource.username}
  11.     password: ${bpm.datasource.password}
  12.     driver-class-name: ${bpm.datasource.driver}
  13.     connection-init-sqls: ${bpm.datasource.connection}
  14.     validationQuery: select 1
  15.     filters: stat
  16.   int:
  17.     initialSize: 5
  18.     minIdle: 5
  19.     maxActive: 10
  20.     maxPoolPreparedStatementPerConnectionSize: 20
  21.   long:
  22.     maxWait: 60000
  23.     timeBetweenEvictionRunsMillis: 60000
  24.     minEvictableIdleTimeMillis: 300000
  25.   boolean:
  26.     testWhileIdle: true
  27.     testOnBorrow: false
  28.     testOnReturn: false
  29.     poolPreparedStatements: true
  32. mybatis:
  33.   mapper-locations: classpath:/mapper/**/*Mapper.xml

在application.yml引入seata支持分布式事务

  1. seata:
  2.   enabled: true
  3.   application-id: ${spring.application.name}
  4.   tx-service-group: bpm_tx_group
  5.   enable-auto-data-source-proxy: true
  7.   registry:
  8.     type: nacos
  9.     nacos:
  10.       application: seata-server
  11.       server-addr: ${nacos.address}
  12.       group: DEFAULT_GROUP
  13.       userName: nacos
  14.       password: nacos
  16.   config:
  17.     type: nacos
  18.     nacos:
  19.       namespace:
  20.       serverAddr: ${nacos.address}
  21.       group: SEATA_GROUP
  22.       cluster: default
  23.       userName: nacos
  24.       password: nacos

在业务服务类中使用Activiti服务类

  1. @Service
  2. public class ActRepService {
  4.     @Resource
  5.     RepositoryService repositoryService;
  7.     @Resource
  8.     ManagementService managementService;
  10.     @Resource
  11.     RuntimeService runtimeService;
  12.     @Resource
  13.     TaskService taskService;
  14. ｝
文档更新时间: 2020-10-12 09:25   作者：csx