首页 文章 精选 留言 我的

探索BPMN—工作流技术的理论与实践｜得物技术

2024-07-23 307

一、前言

  • 19世纪70年代，流程管理思想萌芽阶段。

    怎样提高工作效率？

    泰勒：标准化个人操作流程

    亨利·福特：规定标准时间定额

    标准化、精简化、通用化、专业化。

  • 20世纪70年代，工作流技术起源于办公自动化领域的研究。由于当时计算机尚未普及，网络技术水平还很低以及理论基础匮乏，这项新技术并未取得成功，许多公司采用纸张表单，手工传递的方式，一级一级审批签字，工作效率非常低下。

  • 20世纪90年代，信息技术驱动流程自动化阶段。信息技术开始引入管理领域，对传统的业务进行自动化改造。

    产品：Sabre订票系统，MRP（物料需求计划），MIS（管理信息系统），CIMS（计算机集成制造系统）。

  • 21世纪初，BPM管理与治理结合。

    BPR/BPI：以信息技术为核心重新设计业务流程，失败率高达50%-70%；

    BPM：以业务流程为主导的管理思想；

    BPM治理思想：对BPM实施的成功率以及ROI的高要求，强调BPM与企业战略相结合。

二、BPMN介绍

BPMN（Business Process Modeling Notation，业务流程建模符号）是一种用于描述业务流程的标准化建模语言。它通过图形符号及规则，帮助企业建模、分析和优化各种业务流程。BPMN有两个主要版本：BPMN 1.0和BPMN 2.0。BPMN 1.0规范由标准组织BPMI（后并入到OMG）于2004年5月发布；BPMN 2.0标准由OMG于2011年推出。

2.0相对于1.0规范了流程引擎的语义和格式，利用标准的图元描述真实的业务发生过程，保证相同的流程在不同的流程引擎中得到一致的执行结果。

01.jpg

BPMN的理论基础

  • 流程建模：BPMN使用不同的图形符号来表示业务流程中的各项活动、任务、决策和事件等。这些符号包括任务、网关、事件等，每个符号都有特定的含义和用法。

  • 流程分析：通过BPMN模型，企业可以分析业务流程的效率、资源利用率和风险等，以便进行优化和改进。

  • 流程执行：BPMN不仅是一种建模语言，还可以将建模的业务流程实际执行起来，并进行监控和控制。

BPMN的优势

02.jpg

传统使用场景

  • 采购流程：通过BPMN建模，企业可以规范采购流程，包括需求确认、供应商选择、合同签订、物品收货等环节，提高采购效率。

  • 请假审批流程：BPMN模型可以帮助企业规范请假审批流程，包括员工请假申请、直属主管审批、人力资源部门审批等环节，减少误差和纠纷。

  • 客户投诉处理流程：利用BPMN，企业可以清晰地展示客户投诉处理流程，包括客户投诉登记、处理人员分配、处理过程跟踪、客户反馈等环节，提高客户满意度。

三、实践举例：XX平台XXX商家合规治理任务优化项目（非真实场景）

背景目标

  • 商家合规治理手段的单一性和对线下人工的过度依赖方面需要优化，通过整合商家合规治理策略，并实现这些策略的可在线化配置。这一举措将打破传统的手工操作模式，允许业务方直接在系统中配置和更新治理策略，减少人工干预，提高治理效率。同时，在线化配置也便于策略的快速部署和灵活调整，以应对不同业务场景下的合规要求。

  • 各商家的合规治理进度和状态的透明度方面需要优化，为改变这一现状，我们需要搭建一套高效的工作流引擎。该引擎将支持商家合规治理流程的编排和自动化流转，从任务触发到完成审核、记录反馈等各个环节都将实现自动化处理。同时，内置的进度跟踪机制将确保业务团队能够实时查看各商家的治理进度，及时发现问题并采取相应措施。这将大大提高治理的透明度和可控性。

  • 评估治理成果和手段的有效性分析方面需要优化，将合规治理成果的数据可视化，通过强大的数据分析与可视化系统，我们将关键指标（如治理效率、违规率、改进情况等）以图表、报告等形式直观展现。同时，通过持续的数据分析与改进循环，我们将逐步优化治理策略和方式，最终形成商家合规治理的闭环机制。

方案

业务流程

03.jpg

治理流程1

04.jpg

治理流程2

系统架构图

05.jpg

流程编排

06.jpg

工作流技术选型

07.jpg

SmartEngine详细介绍

E-R图

08.jpg

CREATE TABLE `se_deployment_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL   COMMENT 'create time' ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time'  ,
  `process_definition_id` varchar(255) NOT NULL  COMMENT 'process definition id'  ,
  `process_definition_version` varchar(255) DEFAULT NULL  COMMENT 'process definition version'  ,
  `process_definition_type` varchar(255) DEFAULT NULL  COMMENT 'process definition type'  ,
  `process_definition_code` varchar(255) DEFAULT NULL  COMMENT 'process definition code'  ,
  `process_definition_name` varchar(255) DEFAULT NULL  COMMENT 'process definition name'  ,
  `process_definition_desc` varchar(255) DEFAULT NULL  COMMENT 'process definition desc'  ,
  `process_definition_content` mediumtext NOT NULL  COMMENT 'process definition content'  ,
  `deployment_user_id` varchar(128) NOT NULL  COMMENT 'deployment user id' ,
  `deployment_status` varchar(64) NOT NULL   COMMENT 'deployment status' ,
  `logic_status` varchar(64) NOT NULL  COMMENT 'logic status' ,

  PRIMARY KEY (`id`)
) COMMENT='流程定义表' ;

CREATE TABLE `se_process_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT  COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL  COMMENT 'create time' ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time' ,
  `process_definition_id_and_version` varchar(128) NOT NULL  COMMENT 'process definition id and version'  ,
  `process_definition_type` varchar(255) DEFAULT NULL COMMENT 'process definition type'  ,
  `status` varchar(64) NOT NULL COMMENT ' 1.running 2.completed 3.aborted',
  `parent_process_instance_id` bigint(20) unsigned DEFAULT NULL   COMMENT 'parent process instance id' ,
  `parent_execution_instance_id` bigint(20) unsigned DEFAULT NULL   COMMENT 'parent execution instance id' ,
  `start_user_id` varchar(128) DEFAULT NULL  COMMENT 'start user id' ,
  `biz_unique_id` varchar(255) DEFAULT NULL  COMMENT 'biz unique id' ,
  `reason` varchar(255) DEFAULT NULL   COMMENT 'reason' ,
  `comment` varchar(255) DEFAULT NULL   COMMENT 'comment' ,
  `title` varchar(255) DEFAULT NULL  COMMENT 'title' ,
  `tag` varchar(255) DEFAULT NULL  COMMENT 'tag' ,

  PRIMARY KEY (`id`)
) COMMENT='流程实例表' ;

CREATE TABLE `se_activity_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT  COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL   COMMENT 'create time' ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time'  ,
  `process_instance_id` bigint(20) unsigned DEFAULT NULL  COMMENT 'process instance id'  ,
  `process_definition_id_and_version` varchar(255) NOT NULL  COMMENT 'process definition id and version'  ,
  `process_definition_activity_id` varchar(64) NOT NULL COMMENT 'process definition activity id'   ,
  PRIMARY KEY (`id`)
) COMMENT='活动节点实例表' ;

CREATE TABLE `se_task_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT  COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL   COMMENT 'create time' ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time'  ,
  `process_instance_id` bigint(20) unsigned NOT NULL  COMMENT 'process instance id'  ,
  `process_definition_id_and_version` varchar(128) DEFAULT NULL  COMMENT 'process definition id and version'  ,
  `process_definition_type` varchar(255) DEFAULT NULL  COMMENT 'process definition type'  ,
  `activity_instance_id` bigint(20) unsigned NOT NULL   COMMENT 'activity instance id' ,
  `process_definition_activity_id` varchar(255) NOT NULL  COMMENT 'process definition activity id' ,
  `execution_instance_id` bigint(20) unsigned NOT NULL  COMMENT 'execution instance id'  ,
  `claim_user_id` varchar(255) DEFAULT NULL   COMMENT 'claim user id' ,
  `title` varchar(255) DEFAULT NULL COMMENT 'title'   ,
  `priority` int(11) DEFAULT 500 COMMENT 'priority' ,
  `tag` varchar(255) DEFAULT NULL  COMMENT 'tag'  ,
  `claim_time` datetime(6) DEFAULT NULL COMMENT 'claim time'   ,
  `complete_time` datetime(6) DEFAULT NULL COMMENT 'complete time'   ,
  `status` varchar(255) NOT NULL COMMENT 'status'     ,
  `comment` varchar(255) DEFAULT NULL  COMMENT 'comment'  ,
  `extension` varchar(255) DEFAULT NULL COMMENT 'extension'  ,

  PRIMARY KEY (`id`)
) COMMENT='人工任务节点实例表'  ;

CREATE TABLE `se_task_assignee_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT  COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL  COMMENT 'create time'  ,
  `gmt_modified` datetime(6) NOT NULL   COMMENT 'modification time' ,
  `process_instance_id` bigint(20) unsigned NOT NULL  COMMENT 'process instance id'  ,
  `task_instance_id` bigint(20) unsigned NOT NULL  COMMENT 'task instance id'  ,
  `assignee_id` varchar(255) NOT NULL  COMMENT 'assignee id'  ,
  `assignee_type` varchar(128) NOT NULL  COMMENT 'assignee type'  ,
  PRIMARY KEY (`id`)
) COMMENT='人工任务节点代理人实例表'  ;

CREATE TABLE `se_execution_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'PK'   ,
  `gmt_create` datetime(6) NOT NULL   COMMENT 'create time' ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time'  ,
  `process_instance_id` bigint(20) unsigned NOT NULL  COMMENT 'process instance id'  ,
  `process_definition_id_and_version` varchar(255) NOT NULL  COMMENT 'process definition id and version'  ,
  `process_definition_activity_id` varchar(255) NOT NULL COMMENT 'process definition activity id'   ,
  `activity_instance_id` bigint(20) unsigned NOT NULL COMMENT 'activity instance id'   ,
  `active` tinyint(4) NOT NULL COMMENT '1:active 0:inactive',
  PRIMARY KEY (`id`)
) COMMENT='执行节点实例表-最细粒度的实例'   ;


CREATE TABLE `se_variable_instance` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT  COMMENT 'PK'  ,
  `gmt_create` datetime(6) NOT NULL  COMMENT 'create time'  ,
  `gmt_modified` datetime(6) NOT NULL  COMMENT 'modification time'  ,
  `process_instance_id` bigint(20) unsigned NOT NULL   COMMENT 'process instance id' ,
  `execution_instance_id` bigint(20) unsigned DEFAULT NULL   COMMENT 'execution instance id' ,
  `field_key` varchar(128) NOT NULL   COMMENT 'field key' ,
  `field_type` varchar(128) NOT NULL   COMMENT 'field type' ,
  `field_double_value` decimal(65,30) DEFAULT NULL   COMMENT 'field double value' ,
  `field_long_value` bigint(20) DEFAULT NULL  COMMENT 'field long value'  ,
  `field_string_value` varchar(4000) DEFAULT NULL  COMMENT 'field string value' ,

  PRIMARY KEY (`id`)
) COMMENT='执行节点变量量表' ;

代码实操

第一步，要选择正确的SmartEngine版本，将其添加到pom依赖中。 com.alibaba.smart.framework

smart-engine-extension-storage-custom

3.0.0

第二步，完成SmartEngine初始化。在初始化时，一般要加载流程定义到应用中。集群情况下，要注意流程定义的一致性（如果纯静态记载则无此类问题）。在初始化时，可以根据需要定义Bean的加载优先级。

import com.alibaba.smart.framework.engine.SmartEngine;
import com.alibaba.smart.framework.engine.configuration.InstanceAccessor;
import com.alibaba.smart.framework.engine.configuration.ProcessEngineConfiguration;
import com.alibaba.smart.framework.engine.configuration.impl.DefaultProcessEngineConfiguration;
import com.alibaba.smart.framework.engine.configuration.impl.DefaultSmartEngine;
import com.alibaba.smart.framework.engine.exception.EngineException;
import com.alibaba.smart.framework.engine.service.command.RepositoryCommandService;
import com.alibaba.smart.framework.engine.util.IOUtil;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.annotation.Order;
import org.springframework.core.io.Resource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import java.io.InputStream;

import static org.springframework.core.Ordered.LOWEST_PRECEDENCE;


@Order(LOWEST_PRECEDENCE)
[@Configuration](https://my.oschina.net/pointdance)
@ConditionalOnClass(SmartEngine.class)
public class SmartEngineAutoConfiguration implements ApplicationContextAware {

    private ApplicationContext applicationContext;

    [@Bean](https://my.oschina.net/bean)
    @ConditionalOnMissingBean
    public SmartEngine constructSmartEngine() {
        ProcessEngineConfiguration processEngineConfiguration = new DefaultProcessEngineConfiguration();
        // 实现InstanceAccessor接口
        processEngineConfiguration.setInstanceAccessor(new CustomInstanceAccessService());

        SmartEngine smartEngine = new DefaultSmartEngine();
        smartEngine.init(processEngineConfiguration);

        // 加载流程定义
        deployProcessDefinition(smartEngine);

        return smartEngine;
    }

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }

    private class CustomInstanceAccessService implements InstanceAccessor {
        @Override
        public Object access(String name) {
            return applicationContext.getBean(name);
        }
    }

    private void deployProcessDefinition(SmartEngine smartEngine) {
        RepositoryCommandService repositoryCommandService = smartEngine
                .getRepositoryCommandService();

        PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
        try {
            Resource[] resources = resolver.getResources("classpath*:/smart-engine/*.xml");
            for (Resource resource : resources) {
                InputStream inputStream = resource.getInputStream();
                repositoryCommandService.deploy(inputStream);
                IOUtil.closeQuietly(inputStream);
            }
        } catch (Exception e) {
            throw new EngineException(e);
        }

    }
}

BMPN2.0 xml举例

09.jpg

附言：排他网关的条件表达式是跟着线条绑定的，要自己确保条件的是和否加在一起的总概率是100%，如果不是100%，小概率执行节点会卡在排他网关走不下去。例如：线条"否"的条件表达式为：条件1为假且条件2为假，线条"是"的条件表达式为条件1为真且条件2为真，则其他条件会卡死在排他网关流程走不下去。

test1.bpmn

<?xml version="1.0" encoding="UTF-8"?>
<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:modeler="http://camunda.org/schema/modeler/1.0" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" id="Definitions_1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Web Modeler" exporterVersion="b1a091a" modeler:executionPlatform="Camunda Cloud" modeler:executionPlatformVersion="8.5.0" camunda:diagramRelationId="2a2c997b-ff2f-49b0-9ba8-3c4860d223e7">
  <bpmn:process id="Process_1qijgvk" name="test1" isExecutable="true">
    <bpmn:startEvent id="StartEvent_1">
      <bpmn:outgoing>Flow_0soou9n</bpmn:outgoing>
    </bpmn:startEvent>
    <bpmn:sequenceFlow id="Flow_0soou9n" sourceRef="StartEvent_1" targetRef="Activity_02gdgyk" />
    <bpmn:endEvent id="Event_1i2y4ym">
      <bpmn:incoming>Flow_07mf0sc</bpmn:incoming>
      <bpmn:incoming>Flow_1nd3369</bpmn:incoming>
      <bpmn:incoming>Flow_160ji3a</bpmn:incoming>
    </bpmn:endEvent>
    <bpmn:exclusiveGateway id="Gateway_1kykneu" name="检查是否5天内完成治理">
      <bpmn:extensionElements />
      <bpmn:incoming>Flow_0exjsc9</bpmn:incoming>
      <bpmn:outgoing>Flow_0hj860q</bpmn:outgoing>
      <bpmn:outgoing>Flow_1oqjt08</bpmn:outgoing>
    </bpmn:exclusiveGateway>
    <bpmn:sequenceFlow id="Flow_0hj860q" name="否" sourceRef="Gateway_1kykneu" targetRef="Activity_1ms8vu6" />
    <bpmn:serviceTask id="Activity_02gdgyk" name="站内通知商户去治理">
      <bpmn:extensionElements />
      <bpmn:incoming>Flow_0soou9n</bpmn:incoming>
      <bpmn:outgoing>Flow_0exjsc9</bpmn:outgoing>
    </bpmn:serviceTask>
    <bpmn:sequenceFlow id="Flow_0exjsc9" sourceRef="Activity_02gdgyk" targetRef="Gateway_1kykneu" />
    <bpmn:serviceTask id="Activity_1ms8vu6" name="发送sms通知商户">
      <bpmn:incoming>Flow_0hj860q</bpmn:incoming>
      <bpmn:outgoing>Flow_0bemgki</bpmn:outgoing>
    </bpmn:serviceTask>
    <bpmn:sequenceFlow id="Flow_0bemgki" sourceRef="Activity_1ms8vu6" targetRef="Gateway_1dyp6hh" />
    <bpmn:sequenceFlow id="Flow_1oqjt08" name="是" sourceRef="Gateway_1kykneu" targetRef="Activity_1c9i1el" />
    <bpmn:exclusiveGateway id="Gateway_1dyp6hh" name="是否10天内完成治理">
      <bpmn:incoming>Flow_0bemgki</bpmn:incoming>
      <bpmn:outgoing>Flow_07xq405</bpmn:outgoing>
      <bpmn:outgoing>Flow_1w4qeti</bpmn:outgoing>
    </bpmn:exclusiveGateway>
    <bpmn:sequenceFlow id="Flow_07xq405" name="是" sourceRef="Gateway_1dyp6hh" targetRef="Activity_0m5dsna" />
    <bpmn:serviceTask id="Activity_1c9i1el" name="发放奖励给到商户">
      <bpmn:incoming>Flow_1oqjt08</bpmn:incoming>
      <bpmn:outgoing>Flow_1t7ectj</bpmn:outgoing>
    </bpmn:serviceTask>
    <bpmn:sequenceFlow id="Flow_1t7ectj" sourceRef="Activity_1c9i1el" targetRef="Activity_1p6mkdy" />
    <bpmn:task id="Activity_0m5dsna" name="任务完成">
      <bpmn:incoming>Flow_07xq405</bpmn:incoming>
      <bpmn:outgoing>Flow_07mf0sc</bpmn:outgoing>
    </bpmn:task>
    <bpmn:sequenceFlow id="Flow_07mf0sc" sourceRef="Activity_0m5dsna" targetRef="Event_1i2y4ym" />
    <bpmn:sequenceFlow id="Flow_1w4qeti" name="否" sourceRef="Gateway_1dyp6hh" targetRef="Activity_1gud1rw" />
    <bpmn:task id="Activity_1p6mkdy" name="任务完成">
      <bpmn:incoming>Flow_1t7ectj</bpmn:incoming>
      <bpmn:outgoing>Flow_1nd3369</bpmn:outgoing>
    </bpmn:task>
    <bpmn:sequenceFlow id="Flow_1nd3369" sourceRef="Activity_1p6mkdy" targetRef="Event_1i2y4ym" />
    <bpmn:serviceTask id="Activity_1gud1rw" name="通知运营下线商户店铺">
      <bpmn:incoming>Flow_1w4qeti</bpmn:incoming>
      <bpmn:outgoing>Flow_0vr5zs3</bpmn:outgoing>
    </bpmn:serviceTask>
    <bpmn:sequenceFlow id="Flow_0vr5zs3" sourceRef="Activity_1gud1rw" targetRef="Activity_1pfbnmo" />
    <bpmn:task id="Activity_1pfbnmo" name="任务结束">
      <bpmn:incoming>Flow_0vr5zs3</bpmn:incoming>
      <bpmn:outgoing>Flow_160ji3a</bpmn:outgoing>
    </bpmn:task>
    <bpmn:sequenceFlow id="Flow_160ji3a" sourceRef="Activity_1pfbnmo" targetRef="Event_1i2y4ym" />
  </bpmn:process>
  <bpmndi:BPMNDiagram id="BPMNDiagram_1">
    <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="Process_1qijgvk">
      <bpmndi:BPMNShape id="_BPMNShape_StartEvent_2" bpmnElement="StartEvent_1">
        <dc:Bounds x="152" y="232" width="36" height="36" />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Gateway_1kykneu_di" bpmnElement="Gateway_1kykneu" isMarkerVisible="true">
        <dc:Bounds x="465" y="225" width="50" height="50" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="448" y="188" width="84" height="27" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Activity_02gdgyk_di" bpmnElement="Activity_02gdgyk">
        <dc:Bounds x="270" y="210" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Activity_1ms8vu6_di" bpmnElement="Activity_1ms8vu6">
        <dc:Bounds x="630" y="210" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Event_1i2y4ym_di" bpmnElement="Event_1i2y4ym">
        <dc:Bounds x="1182" y="232" width="36" height="36" />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Gateway_1dyp6hh_di" bpmnElement="Gateway_1dyp6hh" isMarkerVisible="true">
        <dc:Bounds x="825" y="225" width="50" height="50" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="810" y="285" width="79" height="27" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Activity_1c9i1el_di" bpmnElement="Activity_1c9i1el">
        <dc:Bounds x="630" y="320" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Activity_0m5dsna_di" bpmnElement="Activity_0m5dsna">
        <dc:Bounds x="950" y="210" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="BPMNShape_0ab1d2g" bpmnElement="Activity_1p6mkdy">
        <dc:Bounds x="840" y="320" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="Activity_1gud1rw_di" bpmnElement="Activity_1gud1rw">
        <dc:Bounds x="800" y="80" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape id="BPMNShape_02s3tua" bpmnElement="Activity_1pfbnmo">
        <dc:Bounds x="950" y="80" width="100" height="80" />
        <bpmndi:BPMNLabel />
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge id="Flow_0soou9n_di" bpmnElement="Flow_0soou9n">
        <di:waypoint x="188" y="250" />
        <di:waypoint x="270" y="250" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_0exjsc9_di" bpmnElement="Flow_0exjsc9">
        <di:waypoint x="370" y="250" />
        <di:waypoint x="465" y="250" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_0hj860q_di" bpmnElement="Flow_0hj860q">
        <di:waypoint x="515" y="250" />
        <di:waypoint x="630" y="250" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="567" y="232" width="11" height="14" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_1oqjt08_di" bpmnElement="Flow_1oqjt08">
        <di:waypoint x="490" y="275" />
        <di:waypoint x="490" y="360" />
        <di:waypoint x="630" y="360" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="544" y="373" width="11" height="14" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_0bemgki_di" bpmnElement="Flow_0bemgki">
        <di:waypoint x="730" y="250" />
        <di:waypoint x="825" y="250" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_1t7ectj_di" bpmnElement="Flow_1t7ectj">
        <di:waypoint x="730" y="360" />
        <di:waypoint x="840" y="360" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_07mf0sc_di" bpmnElement="Flow_07mf0sc">
        <di:waypoint x="1050" y="250" />
        <di:waypoint x="1182" y="250" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_07xq405_di" bpmnElement="Flow_07xq405">
        <di:waypoint x="875" y="250" />
        <di:waypoint x="950" y="250" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="899" y="232" width="11" height="14" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_1w4qeti_di" bpmnElement="Flow_1w4qeti">
        <di:waypoint x="850" y="225" />
        <di:waypoint x="850" y="160" />
        <bpmndi:BPMNLabel>
          <dc:Bounds x="853" y="186" width="11" height="14" />
        </bpmndi:BPMNLabel>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_1nd3369_di" bpmnElement="Flow_1nd3369">
        <di:waypoint x="940" y="360" />
        <di:waypoint x="1120" y="360" />
        <di:waypoint x="1120" y="250" />
        <di:waypoint x="1182" y="250" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_0vr5zs3_di" bpmnElement="Flow_0vr5zs3">
        <di:waypoint x="900" y="120" />
        <di:waypoint x="950" y="120" />
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge id="Flow_160ji3a_di" bpmnElement="Flow_160ji3a">
        <di:waypoint x="1050" y="120" />
        <di:waypoint x="1120" y="120" />
        <di:waypoint x="1120" y="250" />
        <di:waypoint x="1182" y="250" />
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>
</bpmn:definitions>

  • process，表示一个流程。

  • id="exclusiveTest" version="1.0.0"，分别表示流程定义的id和版本。这两个字段唯一区分一个流程定义。

  • startEvent，表示流程开始节点。只允许有一个开始节点。

  • endEvent，表示流程结束节点。可以有多个结束节点。

  • sequenceFlow，表示环节流转关系。sourceRef="theStart" targetRef="submitTask" 分别表示起始节点和目标节点。该节点有个子节点， approve == 'agree'，这个片段很重要，用来描述流程流转的条件。approve == 'upgrade'使用的是MVEL表达式语法。另外，还值得注意的是，在驱动流程运转时，需要传入正确的参数。比如说，在后面介绍的api中，通常会需要在Map中传递业务请求参数。那么需要将Map中的key和Mvel的运算因子关联起来。以这个例子来说，request.put("approve", "agree")；里面的approve和approve == 'agree'命名要一致。

  • exclusiveGateway，表示互斥网关。该节点非常重要。用来区分流程节点的不同转向。互斥网关在引擎执行conditionExpression后，有且只能选择一条匹配的sequenceFlow继续执行。

  • serviceTask，服务任务，用来表示执行一个服务，所以他会有引擎默认的扩展:smart:class="com.alibaba.smart.framework.example.AuditProcessServiceTaskDelegation". Client Developer使用时，需要自定义对应的业务实现类。在该节点执行时，它会自动执行服务调用，执行smart:class 这个 delegation。该节点不暂停，会自动往下一个流转。

  • receiveTask，接收任务。在引擎遇到此类型的节点时，引擎执行会自动暂停，等待外部调用signal方法。当调用signal方法时，会驱动流程当前节点离开。在离开该节点时，引擎会自动执行smart:class 这个delegation。在一般业务场景中，我们通常使用receiveTask来表示等需要等待外部回调的节点。

  • userTask，表示用户任务节点，仅用于DataBase模式。该节点需要人工参与处理，并且通常需要在待办列表中展示。在Custom模式下，建议使用receiveTask来代替。

  • parallelGateway，这个节点并未在上述流程定义中体现，这里详细说一下。parallelGateway 首先必须成对出现，分别承担fork和join职责。其次，在join时需要实现分布式锁接口：LockStrategy。第三，fork默认是顺序遍历多个sequeceFlow，但是你如果需要使用并发fork功能的话，则需要实现该接口：ExecutorService。

重要领域对象

  • 部署实例: DeploymentInstance，描述这个流程定义是谁发布的，当前处于什么状态。

  • 流程定义: ProcessDefinition，描述一个流程有几个环节，之间的流转关系是什么样子的。

  • 流程实例: ProcessInstance，可以简单理解为我们常见的一个工单。

  • 活动实例: ActivityInstance，主要是描述流程实例（工单）的流转轨迹。

  • 执行实例: ExecutionInstance，主要根据该实例的状态，来判断当前流程处在哪个节点上。

  • 任务实例: TaskInstance，用来表示人工任务处理的，可以理解为一个需要人工参与处理的环节。

  • 任务处理：TaskAssigneeInstance，用来表示当前任务共有几个处理者。通常在代办列表中用到此实体。

  • 变量实例：VariableInstance，用来存储流程实例上下文。

SmartEngine引擎源码地址：https://github.com/alibaba/SmartEngine/tree/master

SmartEngine UserGuide: https://github.com/alibaba/SmartEngine/wiki/SmartEngine-UserGuide--Chinese-Version-%28%E4%B8%AD%E6%96%87%E7%89%88%29

Camunda开源流程设计器（支持在线和本地node.js部署两种方式）：https://camunda.com/download/modeler/

Camunda设计器学习文档：https://docs.camunda.io/docs/components/modeler/bpmn/bpmn-primer/

四、总结与建议

优点

  • 业务流程可视化与实际系统流程可视化高度一致，所见即所得。

  • 调整效率高（业务平均每个月会升级一次治理流程），如果业务流程1.0要升级到1.1，只需要重新复制一份bpmn.xml流程模板重新编排为1.1，并下发流程实例即可，不影响原有的流程模板和流程实例执行（调整效率由原来的一周缩短到1小时）。

  • 流程实例和流程节点实例可视，方便监控各个节点的执行和数据报表的产出。

缺点

  • 异常处理的支持度不够友好（SmartEngine是异常丢弃），如果在某一个节点上执行失败（一般情况是业务接口执行失败导致），默认当前流程进度是卡在该节点的，需要设计张异常表，把当前流程实例，节点实例以及变量都保存下载，通过job重新拉起重试去驱动流程继续执行，并需要做好告警监控，以及任务实例和流程实例的核对。

  • 高并发场景的支持度并不是太友好，要通过异步消息的方式来控制创建流程实例的速度，目前得到的创建流程实例的TPS是100/s单台，只是相对于activiti来说并发支持度要高，超过这个上限的场景建议谨慎使用。

  • 可扩展性不足，例如：ProcessQueryService只支持findById，findList，count；ExecutionQueryService只支持findActiveExecutionList，findAll这些基本查询 ，复杂查询需要新写SmartEngine核心包，升级jar包版本后才可使用。

  • 无历史记录表，每隔一段时间要清理表中流程实例已经完结的相关数据，否则历史数据堆积影响查询效率。

建议

如果业务流程的复杂度一般，且经常会调整，并发量并不高的情况下，建议使用；如果业务复杂度过高，或并发量TPS超过单台100/s，不建议使用。

*文 / 冬冬

本文属得物技术原创，更多精彩文章请看：得物技术

未经得物技术许可严禁转载，否则依法追究法律责任！

上一篇 下一篇
优秀的个人博客,低调大师

微信关注我们

原文链接：https://my.oschina.net/u/5783135/blog/12871636

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

英伟达又向开源迈了一步「GitHub 热点速览」

大家是否还记得 2012 年，Linux 之父 Linus Torvalds 在一次活动中"愤怒"地表达了对英伟达闭源 Linux GPU 驱动的不满？这个场景曾是热门表情包，程序员人手一个。 Linux 开发者们苦此久已，十年后（2022），英伟达终于向开源迈出了第一步，开源了 Linux GPU 内核驱动（R515），尽管这未必与 Linus 的批评直接相关🤷，但却标志着英伟达对于开源的转变。如今两年过去了，英伟达再次向开源迈出重要一步，宣布"全面转向开源 GPU 内核模块"，将在即将发布的 R560 驱动版本中采用开源内核取代闭源驱动，这一行为"利好"开发者： 性能优化：开源驱动允许开发者直接优化和调整 GPU 性能，提升游戏的运行效率和图形表现 更好支持新技术：更快地支持最新的图形 API 和硬件特性，使游戏开发者能充分利用最新的图形技术。 增强兼容性：更容易与各种 Linux 发行版和内核版本兼容，减少开发者在不同环境中适配驱动的负担。 不过，对于普通 Linux 使用来说，要在 Linux 上玩 3A 游戏巨作，还为时尚早... 说回本周的开源热搜项目，写爬虫最怕被"认"...
2024-07-23
288
上一篇

Databend 开源周报第 154 期

Databend 是一款现代云数仓。专为弹性和高效设计，为您的大规模分析需求保驾护航。自由且开源。即刻体验云服务：https://app.databend.cn 。 What's On In Databend 探索 Databend 本周新进展，遇到更贴近你心意的 Databend。 为窗口排名函数添加 [IGNORE | RESPECT NULLS] 选项 在窗口函数的使用中，处理 NULL 值是一个常见且重要的问题。为了提供更加灵活和精确的查询能力，Databend 正在为窗口排名函数 first_value、last_value 和 nth_value 添加 IGNORE NULLS 和 RESPECT NULLS 选项。这两个选项的具体功能如下： 使用 IGNORE NULLS 选项时，函数会跳过 NULL 值，仅考虑非 NULL 的数据。例如：first_value(col) IGNORE NULLS 会返回第一个非 NULL 的值。这种方式在数据集中存在大量 NULL 值的情况下非常有用，因为它能有效避免 NULL 值对结果的干扰。 使用 RESPECT NULLS 选项时...
2024-07-23
293
下一篇

相关文章

发表评论

资源下载

更多资源
优质分享App

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

时间: 2025-12-03 大小: 4.36MB 下载: 23次
Mario

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

时间: 2025-12-12 大小: 211.28KB 下载: 54次
腾讯云软件源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

时间: 2026-03-01 大小: 1MB 下载: 6次
Rocky Linux

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

时间: 2026-03-02 大小: 1.42GB 下载: 3次
手机查看

扫码在手机上查看文章

扫描二维码，手机阅读更方便

热门标签
Gemini3 SpringBoot4 Service Mesh Docker Jdk25 Rocky Kubernetes SpringCloud DeepSeek OpenAi Redis Nacos3 HarmonyOS6

欢迎您来访！

登录后，您将获得更多功能！
热门文章
联系我们

有任何问题或合作意向欢迎联系我们

Email: 99873273@qq.com

QQ: 99873273

用户登录
用户注册