Activiti 表结构

Activiti数据库支持： Activiti的后台是有数据库的支持，所有的表都以ACT开头。 第二部分是表示表的用途的两个字母标识。 用途也和服务的API对应。 ACT_RE: ‘RE’表示repository。 这个前缀的表包含了流程定义和流程静态资源 （图片，规则，等等）。 ACTRU: ‘RU’表示runtime。 这些运行时的表，包含流程实例，任务，变量，异步任务，等运行中的数据。 Activiti只在流程实例执行过程中保存这些数据， 在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。 ACTID: ‘ID’表示identity。 这些表包含身份信息，比如用户，组等等。 ACTHI: ‘HI’表示history。 这些表包含历史数据，比如历史流程实例， 变量，任务等等。 ACTGE*: 通用数据， 用于不同场景下，如存放资源文件。

表结构操作： 1：资源库流程规则表 1) act_re_deployment 部署信息表 2) act_re_model 流程设计模型部署表 3) act_re_procdef 流程定义数据表 2：运行时数据库表 1) act_ru_execution 运行时流程执行实例表 2) act_ru_identitylink 运行时流程人员表，主要存储任务节点与参与者的相关信息 3) act_ru_task 运行时任务节点表 4) act_ru_variable 运行时流程变量数据表 3：历史数据库表 1) act_hi_actinst 历史节点表 2) act_hi_attachment 历史附件表 3) act_ih_comment 历史意见表 4) act_hi_identitylink 历史流程人员表 5) act_hi_detail 历史详情表，提供历史变量的查询 6) act_hi_procinst 历史流程实例表 7) act_hi_taskinst 历史任务实例表 8) act_hi_varinst 历史变量表 4：组织机构表 1) act_id_group 用户组信息表 2) act_id_info 用户扩展信息表 3) act_id_membership 用户与用户组对应信息表 4) act_id_user 用户信息表 这四张表很常见，基本的组织机构管理，关于用户认证方面建议还是自己开发一套，组件自带的功能太简单，使用中有很多需求难以满足 5：通用数据表 1) act_ge_bytearray 二进制数据表 2) act_ge_property 属性数据表存储整个流程引擎级别的数据,初始化表结构时，会默认插入三条记录，

Async serviceTask的事务问题

Activiti中serviceTask如果设置为异步执行，该task其实是由activiti的jobExecutor在事务环境中异步调用执行的，若该task是个长时间执行的任务，则在整个执行期间事务一直开启，一直占用数据库连接，在高并发高负载的环境下会破坏系统的可用性。

案例

比如下面的业务流程：

长时间任务的配置如下：

<serviceTask id="longTransactionTask" name="长时间任务" activiti:delegateExpression="${longTransactionTask}" activiti:async="true" />

若在此task中打一个断点，执行到断点时，可以看到该task运行在事务中，如下：

解决方案

因为业务逻辑放在工作流引擎中执行会占用事务资源，可以将长任务放在工作流引擎之外，待长任务执行完后，通知工作流引擎继续执行(async continuation), 这就要用到activiti的intermediate catching event机制了。

新的业务流程：

对应的BPMN流程描述：

<?xml version="1.0" encoding="UTF-8" ?>
<definitions id="definitions"
             targetNamespace="http://activiti.org/bpmn20"
             xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xmlns:activiti="http://activiti.org/bpmn">

  <message id="longTransactionTaskCompletedMessage" name="longTransactionTaskCompletedMessage" />

  <process id="test_intermediate_catch_event" name="测试intermediate catch event">


      <startEvent id="start" name="开始" />

      <sequenceFlow id="start2shortTransactionTask" sourceRef="start" targetRef="shortTransactionTask" />

      <serviceTask id="shortTransactionTask" name="短事务任务" activiti:delegateExpression="${shortTransactionTask}" activiti:async="true" />

      <sequenceFlow id="shortTransactionTask2messageCatch" sourceRef="shortTransactionTask" targetRef="longTransactionTaskCompletedMessageCatch" />

      <intermediateCatchEvent id="longTransactionTaskCompletedMessageCatch">
          <messageEventDefinition messageRef="longTransactionTaskCompletedMessage" />
      </intermediateCatchEvent>

      <sequenceFlow id="messageCatch2end" sourceRef="longTransactionTaskCompletedMessageCatch" targetRef="end" />

      <endEvent id="end" />

  </process>

</definitions>

长任务执行完后，通知工作流引擎继续执行的代码如下:

//找到要继续执行的工作流实例
Execution execution = runtimeService.createExecutionQuery()
                               .messageEventSubscriptionName("longTransactionTaskCompletedMessage")
                               .processVariableValueEquals("businessKey", "123456789")
                             .singleResult();
//通知工作流引擎继续执行
runtimeService.messageEventReceived("longTransactionTaskCompletedMessage", execution.getId());