最近一直研究springboot，根据工作需求，工作流需要作为一个单独的微服务工程来提供给其他服务调用，现在简单的写下工作流（使用的activiti）微服务的搭建与简单使用

jdk：1.8

数据库：mysql  5.7

IDE：eclipse

springboot：1.5.8

activiti：6.0.0

1.新建空白的maven微服务架构

新建maven项目的流程不在阐述，这里添加上activiti、myslq连接的依赖，只贴主要代码

pox.xml



    
 
  1. 
  
    <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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    2. 
 
  2. 
  
    <modelVersion>4.0.0</modelVersion>
    3. 
 
  3. 
  
    <groupId>com.xxx</groupId>
    4. 
 
  4. 
  
    <artifactId>xxx</artifactId>
    5. 
 
  5. 
  
    <version>0.0.1-SNAPSHOT</version>
    6. 
 
  6. 
  
    <properties>
    7. 
 
  7. 
  
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    8. 
 
  8. 
  
    <java.version>1.8</java.version>
    9. 
 
  9. 
  
    </properties>
    10. 
 
  10. 
 
  11. 
  
    <parent>
    12. 
 
  12. 
  
    <groupId>org.springframework.boot</groupId>
    13. 
 
  13. 
  
    <artifactId>spring-boot-starter-parent</artifactId>
    14. 
 
  14. 
  
    <version>1.5.8.RELEASE</version>
    15. 
 
  15. 
  
    </parent>
    16. 
 
  16. 
  
    <dependencies>
    17. 
 
  17. 
  
    <dependency>
    18. 
 
  18. 
  
    <groupId>org.springframework.boot</groupId>
    19. 
 
  19. 
  
    <artifactId>spring-boot-starter-web</artifactId>
    20. 
 
  20. 
  
    </dependency>
    21. 
 
  21. 
  
    <dependency>
    22. 
 
  22. 
  
    <groupId>org.activiti</groupId>
    23. 
 
  23. 
  
    <artifactId>activiti-spring-boot-starter-basic</artifactId>
    24. 
 
  24. 
  
    <version>6.0.0</version>
    25. 
 
  25. 
  
    </dependency>
    26. 
 
  26. 
  
    <dependency>
    27. 
 
  27. 
  
    <groupId>org.springframework.boot</groupId>
    28. 
 
  28. 
  
    <artifactId>spring-boot-starter-data-jpa</artifactId>
    29. 
 
  29. 
  
    </dependency>
    30. 
 
  30. 
  
    <dependency>
    31. 
 
  31. 
  
    <groupId>org.springframework.boot</groupId>
    32. 
 
  32. 
  
    <artifactId>spring-boot-starter-thymeleaf</artifactId>
    33. 
 
  33. 
  
    </dependency>
    34. 
 
  34. 
  
    <dependency>
    35. 
 
  35. 
  
    <groupId>org.springframework.boot</groupId>
    36. 
 
  36. 
  
    <artifactId>spring-boot-starter-web</artifactId>
    37. 
 
  37. 
  
    </dependency>
    38. 
 
  38. 
 
  39. 
  
    <dependency>
    40. 
 
  40. 
  
    <groupId>mysql</groupId>
    41. 
 
  41. 
  
    <artifactId>mysql-connector-java</artifactId>
    42. 
 
  42. 
  
    <scope>runtime</scope>
    43. 
 
  43. 
  
    </dependency>
    44. 
 
  44. 
  
    <dependency>
    45. 
 
  45. 
  
    <groupId>org.springframework.boot</groupId>
    46. 
 
  46. 
  
    <artifactId>spring-boot-starter-tomcat</artifactId>
    47. 
 
  47. 
  
    </dependency>
    48. 
 
  48. 
  
    <dependency>
    49. 
 
  49. 
  
    <groupId>org.springframework.boot</groupId>
    50. 
 
  50. 
  
    <artifactId>spring-boot-starter-test</artifactId>
    51. 
 
  51. 
  
    <scope>test</scope>
    52. 
 
  52. 
  
    </dependency>
    53. 
 
  53. 
  
    </dependencies>
    54. 
 
  54. 
  
    <build>
    55. 
 
  55. 
  
    <plugins>
    56. 
 
  56. 
  
    <plugin>
    57. 
 
  57. 
  
    <groupId>org.springframework.boot</groupId>
    58. 
 
  58. 
  
    <artifactId>spring-boot-maven-plugin</artifactId>
    59. 
 
  59. 
  
    </plugin>
    60. 
 
  60. 
  
    </plugins>
    61. 
 
  61. 
  
    </build>
    62. 
 
  62. 
  
    </project>
    63. 



确认服务是可用




2.连接服务名、服务端口、数据库配置


在resources目录下的application.properties（项目定位原因没有使用yaml，可根据自己项目使用）




    
 
  1. 
  
    spring.datasource.driver-class-name=com.mysql.jdbc.Driver
    2. 
 
  2. 
  
    spring.datasource.url=jdbc:mysql://127.0.0.1:3306/activity?characterEncoding=utf8&useSSL=true
    3. 
 
  3. 
  
    spring.datasource.username=root
    4. 
 
  4. 
  
    spring.datasource.password=root
    5. 
 
  5. 
  
    spring.jpa.properties.hibernate.hbm2ddl.auto=update
    6. 
 
  6. 
  
    spring.jpa.show-sql=true
    7. 
 
  7. 
  
    server.port=8081
    8. 
 
  8. 
  
    server.context-path=/activity
    9. 
 
  9. 
  
    server.session.timeout=10
    10. 
 
  10. 
  
    server.tomcat.uri-encoding=UTF-8
    11. 



确认配置的数据库可用


3.main




    
 
  1. 
  
    import org.springframework.boot.SpringApplication;
    2. 
 
  2. 
  
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    3. 
 
  3. 
 
  4. 
  
    /**
    5. 
 
  5. 
  
    * Created by Guo on 2017/11/15.
    6. 
 
  6. 
  
    */
    7. 
 
  7. 
  
    @SpringBootApplication
    8. 
 
  8. 
  
    public class ActivityApp
    9. 
 
  9. 
  
    {
    10. 
 
  10. 
  
    public static void main(String[] args)
    11. 
 
  11. 
  
    {
    12. 
 
  12. 
  
    SpringApplication.run(ActivityApp.class, args);
    13. 
 
  13. 
  
    }
    14. 
 
  14. 
  
    }
    15. 



4.service及实现


service:




    
 
  1. 
  
    import org.activiti.engine.task.TaskQuery;
    2. 
 
  2. 
  
    import org.springframework.web.bind.annotation.RequestMapping;
    3. 
 
  3. 
  
    import org.springframework.web.bind.annotation.RequestMethod;
    4. 
 
  4. 
  
    import org.springframework.web.bind.annotation.RestController;
    5. 
 
  5. 
 
  6. 
  
    @RestController
    7. 
 
  7. 
  
    @RequestMapping("/activityService")
    8. 
 
  8. 
  
    public interface ActivityConsumerService {
    9. 
 
  9. 
  
    /**
    10. 
 
  10. 
  
    * 流程demo
    11. 
 
  11. 
  
    * @return
    12. 
 
  12. 
  
    */
    13. 
 
  13. 
  
    @RequestMapping(value="/startActivityDemo",method=RequestMethod.GET)
    14. 
 
  14. 
  
    public boolean startActivityDemo();
    15. 
 
  15. 
 
  16. 
  
    }
    17. 



impl




    
 
  1. 
  
    import java.util.HashMap;
    2. 
 
  2. 
  
    import java.util.Map;
    3. 
 
  3. 
 
  4. 
  
    import org.activiti.engine.RuntimeService;
    5. 
 
  5. 
  
    import org.activiti.engine.TaskService;
    6. 
 
  6. 
  
    import org.activiti.engine.impl.persistence.entity.ExecutionEntity;
    7. 
 
  7. 
  
    import org.activiti.engine.task.Task;
    8. 
 
  8. 
  
    import org.activiti.engine.task.TaskQuery;
    9. 
 
  9. 
  
    import org.apache.commons.lang3.StringUtils;
    10. 
 
  10. 
  
    import org.springframework.beans.factory.annotation.Autowired;
    11. 
 
  11. 
  
    import org.springframework.stereotype.Service;
    12. 
 
  12. 
 
  13. 
  
    import com.hongguaninfo.activity.service.ActivityConsumerService;
    14. 
 
  14. 
  
    @Service("activityService")
    15. 
 
  15. 
  
    public class ActivityConsumerServiceImpl implements ActivityConsumerService {
    16. 
 
  16. 
 
  17. 
  
    @Autowired
    18. 
 
  18. 
  
    private RuntimeService runtimeService;
    19. 
 
  19. 
  
    @Autowired
    20. 
 
  20. 
  
    private TaskService taskService;
    21. 
 
  21. 
 
  22. 
  
    @Override
    23. 
 
  23. 
  
    public boolean startActivityDemo() {
    24. 
 
  24. 
  
    System.out.println("method startActivityDemo begin....");
    25. 
 
  25. 
  
    Map<String,Object> map = new HashMap<String,Object>();
    26. 
 
  26. 
  
    map.put("apply","zhangsan");
    27. 
 
  27. 
  
    map.put("approve","lisi");
    28. 
 
  28. 
  
    //流程启动
    29. 
 
  29. 
  
    ExecutionEntity pi1 = (ExecutionEntity) runtimeService.startProcessInstanceByKey("leave",map);
    30. 
 
  30. 
  
    String processId = pi1.getId();
    31. 
 
  31. 
  
    String taskId = pi1.getTasks().get(0).getId();
    32. 
 
  32. 
  
    taskService.complete(taskId, map);//完成第一步申请
    33. 
 
  33. 
 
  34. 
  
    Task task = taskService.createTaskQuery().processInstanceId(processId).singleResult();
    35. 
 
  35. 
  
    String taskId2 = task.getId();
    36. 
 
  36. 
  
    map.put("pass", false);
    37. 
 
  37. 
  
    taskService.complete(taskId2, map);//驳回申请
    38. 
 
  38. 
  
    System.out.println("method startActivityDemo end....");
    39. 
 
  39. 
  
    return false;
    40. 
 
  40. 
  
    }
    41. 
 
  41. 
  
    }
    42. 



5.bpmn


在resources目录下新建文件夹：processes，并在processes创建一个新的bpmn文件，如图




文件内容：




    
 
  1. 
  
    <?xml version="1.0" encoding="UTF-8"?>
    2. 
 
  2. 
  
    <definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/testm1510735932336" id="m1510735932336" name="">
    3. 
 
  3. 
  
    <process id="leave" isExecutable="true" isClosed="false" processType="None">
    4. 
 
  4. 
  
    <startEvent id="_2" name="StartEvent"></startEvent>
    5. 
 
  5. 
  
    <endEvent id="_3" name="EndEvent"></endEvent>
    6. 
 
  6. 
  
    <userTask id="approve" name="经理审批" activiti:assignee="${approve}"></userTask>
    7. 
 
  7. 
  
    <exclusiveGateway id="_5" name="ExclusiveGateway"></exclusiveGateway>
    8. 
 
  8. 
  
    <sequenceFlow id="_6" sourceRef="approve" targetRef="_5"></sequenceFlow>
    9. 
 
  9. 
  
    <sequenceFlow id="_7" name="通过" sourceRef="_5" targetRef="_3">
    10. 
 
  10. 
  
    <conditionExpression xsi:type="tFormalExpression"><![CDATA[${pass}]]></conditionExpression>
    11. 
 
  11. 
  
    </sequenceFlow>
    12. 
 
  12. 
  
    <userTask id="application" name="提交申请" activiti:assignee="${apply}"></userTask>
    13. 
 
  13. 
  
    <sequenceFlow id="_9" sourceRef="_2" targetRef="application"></sequenceFlow>
    14. 
 
  14. 
  
    <sequenceFlow id="_10" sourceRef="application" targetRef="approve"></sequenceFlow>
    15. 
 
  15. 
  
    <userTask id="modify" name="修改申请" activiti:assignee="${apply}"></userTask>
    16. 
 
  16. 
  
    <sequenceFlow id="_12" name="不通过" sourceRef="_5" targetRef="modify">
    17. 
 
  17. 
  
    <conditionExpression xsi:type="tFormalExpression"><![CDATA[${!pass}]]></conditionExpression>
    18. 
 
  18. 
  
    </sequenceFlow>
    19. 
 
  19. 
  
    <sequenceFlow id="_13" sourceRef="modify" targetRef="approve"></sequenceFlow>
    20. 
 
  20. 
  
    </process>
    21. 
 
  21. 
  
    <bpmndi:BPMNDiagram id="BPMNDiagram_leave">
    22. 
 
  22. 
  
    <bpmndi:BPMNPlane bpmnElement="leave" id="BPMNPlane_leave">
    23. 
 
  23. 
  
    <bpmndi:BPMNShape bpmnElement="_2" id="BPMNShape__2">
    24. 
 
  24. 
  
    <omgdc:Bounds height="35.0" width="35.0" x="15.0" y="60.0"></omgdc:Bounds>
    25. 
 
  25. 
  
    </bpmndi:BPMNShape>
    26. 
 
  26. 
  
    <bpmndi:BPMNShape bpmnElement="_3" id="BPMNShape__3">
    27. 
 
  27. 
  
    <omgdc:Bounds height="35.0" width="35.0" x="630.0" y="63.0"></omgdc:Bounds>
    28. 
 
  28. 
  
    </bpmndi:BPMNShape>
    29. 
 
  29. 
  
    <bpmndi:BPMNShape bpmnElement="approve" id="BPMNShape_approve">
    30. 
 
  30. 
  
    <omgdc:Bounds height="55.0" width="85.0" x="315.0" y="50.0"></omgdc:Bounds>
    31. 
 
  31. 
  
    </bpmndi:BPMNShape>
    32. 
 
  32. 
  
    <bpmndi:BPMNShape bpmnElement="_5" id="BPMNShape__5">
    33. 
 
  33. 
  
    <omgdc:Bounds height="40.0" width="40.0" x="505.0" y="60.0"></omgdc:Bounds>
    34. 
 
  34. 
  
    </bpmndi:BPMNShape>
    35. 
 
  35. 
  
    <bpmndi:BPMNShape bpmnElement="application" id="BPMNShape_application">
    36. 
 
  36. 
  
    <omgdc:Bounds height="55.0" width="85.0" x="135.0" y="50.0"></omgdc:Bounds>
    37. 
 
  37. 
  
    </bpmndi:BPMNShape>
    38. 
 
  38. 
  
    <bpmndi:BPMNShape bpmnElement="modify" id="BPMNShape_modify">
    39. 
 
  39. 
  
    <omgdc:Bounds height="55.0" width="85.0" x="315.0" y="150.0"></omgdc:Bounds>
    40. 
 
  40. 
  
    </bpmndi:BPMNShape>
    41. 
 
  41. 
  
    <bpmndi:BPMNEdge bpmnElement="_6" id="BPMNEdge__6">
    42. 
 
  42. 
  
    <omgdi:waypoint x="400.0" y="77.0"></omgdi:waypoint>
    43. 
 
  43. 
  
    <omgdi:waypoint x="505.0" y="80.0"></omgdi:waypoint>
    44. 
 
  44. 
  
    </bpmndi:BPMNEdge>
    45. 
 
  45. 
  
    <bpmndi:BPMNEdge bpmnElement="_7" id="BPMNEdge__7">
    46. 
 
  46. 
  
    <omgdi:waypoint x="545.0" y="80.0"></omgdi:waypoint>
    47. 
 
  47. 
  
    <omgdi:waypoint x="630.0" y="80.0"></omgdi:waypoint>
    48. 
 
  48. 
  
    </bpmndi:BPMNEdge>
    49. 
 
  49. 
  
    <bpmndi:BPMNEdge bpmnElement="_9" id="BPMNEdge__9">
    50. 
 
  50. 
  
    <omgdi:waypoint x="50.0" y="77.0"></omgdi:waypoint>
    51. 
 
  51. 
  
    <omgdi:waypoint x="135.0" y="77.0"></omgdi:waypoint>
    52. 
 
  52. 
  
    </bpmndi:BPMNEdge>
    53. 
 
  53. 
  
    <bpmndi:BPMNEdge bpmnElement="_10" id="BPMNEdge__10">
    54. 
 
  54. 
  
    <omgdi:waypoint x="220.0" y="77.0"></omgdi:waypoint>
    55. 
 
  55. 
  
    <omgdi:waypoint x="315.0" y="77.0"></omgdi:waypoint>
    56. 
 
  56. 
  
    </bpmndi:BPMNEdge>
    57. 
 
  57. 
  
    <bpmndi:BPMNEdge bpmnElement="_12" id="BPMNEdge__12">
    58. 
 
  58. 
  
    <omgdi:waypoint x="525.0" y="100.0"></omgdi:waypoint>
    59. 
 
  59. 
  
    <omgdi:waypoint x="525.0" y="177.0"></omgdi:waypoint>
    60. 
 
  60. 
  
    <omgdi:waypoint x="400.0" y="177.0"></omgdi:waypoint>
    61. 
 
  61. 
  
    </bpmndi:BPMNEdge>
    62. 
 
  62. 
  
    <bpmndi:BPMNEdge bpmnElement="_13" id="BPMNEdge__13">
    63. 
 
  63. 
  
    <omgdi:waypoint x="357.0" y="150.0"></omgdi:waypoint>
    64. 
 
  64. 
  
    <omgdi:waypoint x="357.0" y="105.0"></omgdi:waypoint>
    65. 
 
  65. 
  
    </bpmndi:BPMNEdge>
    66. 
 
  66. 
  
    </bpmndi:BPMNPlane>
    67. 
 
  67. 
  
    </bpmndi:BPMNDiagram>
    68. 
 
  68. 
  
    </definitions>
    69. 



需要认知的问题：.项目启动的时候，activiti会自动在mysql中创建activiti相关表，不用像oracle那样需要手动去创建


6.验证


启动项目前，连接数据库，查看需要连接数据库中没有表，启动项目完成后，刷新数据库，activiti已经创建相关表，打开act_re_procdef表，流程数据已经存在，即流程已经部署成功。


用浏览器访问地址：http://127.0.0.1:8081/activity/activityService/startActivityDemo打印了预计的日志，没有报错信息，查看数据库中的act_ru_task表，发现刚才执行形成的数据，项目成功。


PS:只是简单的微服务，没有去写注册服务、网关配置、熔断机制等等，仅用于activiti与springboot的结合


=========================后续==========================


1.在项目单独作为一个引擎，本身不部署流程的时候，如果resources目录没有“processes”目录，启动项目报错--找不到processes目录。需要在配置文件中添加一下内容：




    
 
  1. 
  
    spring: 
    2. 
 
  2. 
  
    activiti: 
    3. 
 
  3. 
  
    ####校验流程文件，默认校验resources下的processes文件夹里的流程文件
    4. 
 
  4. 
  
    check-process-definitions: false
    5. 



即启动项目，不去校验processes。


   


原文地址：https://blog.csdn.net/kkkder/article/details/78562349


 
 
  

        # spring
      
  
 
 Logo 
魔乐社区
 
魔乐社区（Modelers.cn) 是一个中立、公益的人工智能社区，提供人工智能工具、模型、数据的托管、展示与应用协同服务，为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作，由全产业链共同建设、共同运营、共同享有，推动国产AI生态繁荣发展。
 
 
  
更多推荐
  
cover
 
全家桶集齐！Qwen3.5四款小模型上线魔乐社区，附昇腾全套实践教程
 
 
avatar 魔乐社区
 
 
Pont - 搭建前后端之桥：高效、灵活的接口管理工具
 
Pont 是一款强大的数据服务层解决方案，它能够帮助开发者快速搭建前后端之间的桥梁，实现接口的高效管理和代码自动生成。无论是新手还是有经验的开发者，都能通过 Pont 轻松处理接口文档、生成类型安全的 API 代码，从而显著提升开发效率。[![Pont 工具标志](https://raw.gitcode.com/gh_mirrors/po/pont/raw/3f1b7d4bbba3fd2dda
 
avatar 魔乐社区
 
 
如何快速上手 hvac：HashiCorp Vault Python 客户端零基础入门指南
 
**hvac** 是 HashiCorp Vault 的 Python 3.X 客户端库，专为开发者提供简单高效的 Vault 交互方式。无论你是需要管理密钥、配置身份验证，还是实现安全的秘密数据存储，hvac 都能帮助你轻松搞定 Vault 的各项操作。本文将带你零基础快速入门，从安装到基础操作，让你在几分钟内即可上手使用这个强大的工具。[![hvac 客户端 Logo](https://r
 
avatar 魔乐社区