Activiti定时任务示例

工作流其实做的事情还是很多的，
这不，这周公司经理叫我在前段时间的基础上，把项目中的一个客户回访计划的提醒功能也加到工作流当中，对于没有接触过定时任务的我来说，又有的一番研究了。
在 咖啡兔 http://weibo.com/kafeituzi 的提醒下，使用了边界定时事件 + Job的方式成功实现了，任务定时启动，任务超时过期处理的功能，必须得感谢兔子，感谢他对Activiti在国内的普及所作出的努力。也希望Activiti的路越走越远，现在5.11版本还是和以前老版本有了很多的变化了，好用，简单实用的API，有了native query，也方便自己扩展。
好了，废话不多说，开始分析实例：
1.开启JOB引擎，在activiti配置文件中：

<property name="jobExecutorActivate" value="true" />

这个必须开启，如果没有开启的话，定时任务是启动不了的。呵呵，
其实这个功能开启过后，在后台的实现是这样饿，它会定时的查询act_ru_job这一张表，看见我们的某一条记录的时间要求达到了，就会执行这一个JOB。是不是就明白了？如果是web项目，你打开LOG功能，在控制台是可以看见日志输出的，其实就是这个JOB引擎在工作。
2.下面就是流程图设计。

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 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" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
  <process id="notify" name="任务计划" isExecutable="true">
    <userTask id="usertask1" name="任务等待"></userTask>
    <endEvent id="endevent1" name="End"></endEvent>
    <startEvent id="startevent1" name="Start"></startEvent>
    <sequenceFlow id="flow5" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow>
    <boundaryEvent id="boundarytimer1" name="Timer" attachedToRef="usertask1" cancelActivity="true">
      <timerEventDefinition>
        <timeDate>${qishi}</timeDate>
      </timerEventDefinition>
    </boundaryEvent>
    <userTask id="usertask2" name="任务提醒" activiti:candidateUsers="123">
      <extensionElements>
        <activiti:taskListener event="create" delegateExpression="${notifyHandler}"></activiti:taskListener>
      </extensionElements>
    </userTask>
    <sequenceFlow id="flow6" sourceRef="boundarytimer1" targetRef="usertask2"></sequenceFlow>
    <serviceTask id="servicetask3" name="任务处理" activiti:expression="${myHandler}"></serviceTask>
    <sequenceFlow id="flow7" sourceRef="usertask2" targetRef="servicetask3"></sequenceFlow>
    <sequenceFlow id="flow8" sourceRef="servicetask3" targetRef="endevent1"></sequenceFlow>
    <boundaryEvent id="boundarytimer2" name="Timer" attachedToRef="usertask2" cancelActivity="true">
      <timerEventDefinition>
        <timeDate>${jieshu}</timeDate>
      </timerEventDefinition>
    </boundaryEvent>
    <serviceTask id="servicetask4" name="任务过期" activiti:delegateExpression="${myHandler2}"></serviceTask>
    <sequenceFlow id="flow9" sourceRef="boundarytimer2" targetRef="servicetask4"></sequenceFlow>
    <sequenceFlow id="flow10" sourceRef="servicetask4" targetRef="endevent1"></sequenceFlow>
  </process>
  <bpmndi:BPMNDiagram id="BPMNDiagram_notify">
    <bpmndi:BPMNPlane bpmnElement="notify" id="BPMNPlane_notify">
      <bpmndi:BPMNShape bpmnElement="usertask1" id="BPMNShape_usertask1">
        <omgdc:Bounds height="55.0" width="105.0" x="180.0" y="110.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="boundarytimer1" id="BPMNShape_boundarytimer1">
        <omgdc:Bounds height="30.0" width="30.0" x="271.0" y="124.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
        <omgdc:Bounds height="35.0" width="35.0" x="670.0" y="120.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">
        <omgdc:Bounds height="35.0" width="35.0" x="70.0" y="120.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="usertask2" id="BPMNShape_usertask2">
        <omgdc:Bounds height="55.0" width="105.0" x="330.0" y="110.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="servicetask3" id="BPMNShape_servicetask3">
        <omgdc:Bounds height="55.0" width="105.0" x="500.0" y="110.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="boundarytimer2" id="BPMNShape_boundarytimer2">
        <omgdc:Bounds height="30.0" width="30.0" x="405.0" y="150.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNShape bpmnElement="servicetask4" id="BPMNShape_servicetask4">
        <omgdc:Bounds height="55.0" width="105.0" x="500.0" y="210.0"></omgdc:Bounds>
      </bpmndi:BPMNShape>
      <bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">
        <omgdi:waypoint x="105.0" y="137.0"></omgdi:waypoint>
        <omgdi:waypoint x="180.0" y="137.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow6" id="BPMNEdge_flow6">
        <omgdi:waypoint x="301.0" y="139.0"></omgdi:waypoint>
        <omgdi:waypoint x="330.0" y="137.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow7" id="BPMNEdge_flow7">
        <omgdi:waypoint x="435.0" y="137.0"></omgdi:waypoint>
        <omgdi:waypoint x="500.0" y="137.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow8" id="BPMNEdge_flow8">
        <omgdi:waypoint x="605.0" y="137.0"></omgdi:waypoint>
        <omgdi:waypoint x="670.0" y="137.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow9" id="BPMNEdge_flow9">
        <omgdi:waypoint x="420.0" y="180.0"></omgdi:waypoint>
        <omgdi:waypoint x="419.0" y="237.0"></omgdi:waypoint>
        <omgdi:waypoint x="500.0" y="237.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
      <bpmndi:BPMNEdge bpmnElement="flow10" id="BPMNEdge_flow10">
        <omgdi:waypoint x="605.0" y="237.0"></omgdi:waypoint>
        <omgdi:waypoint x="687.0" y="237.0"></omgdi:waypoint>
        <omgdi:waypoint x="687.0" y="155.0"></omgdi:waypoint>
      </bpmndi:BPMNEdge>
    </bpmndi:BPMNPlane>
  </bpmndi:BPMNDiagram>
</definitions>

流程定义大致就这这个样子的，其中的两个定时时间的时间都是用的变量，
我是在启动流程的时候保存到流程变量里面的，然后引擎会自己到变量里面取值赋给它，
这个地方要注意，时间要ISO8601格式的， 类似 ： 2013-01-25T12:12:12

如有不明白之处大家可以共同讨论。
如果你有更好的方案，也可以提出来，大家共同探讨。

评论

10 楼 mazhi4562qq 2016-08-12  

你好， 可以请教个关于activiti定时边界事件的问题么？我的qq和微信都是这个：278205092，谢谢啊。

9 楼 wscxyok 2015-11-02  

hi ， 楼主，我遇到过类似的问题，我用的是timeDuration，我想实现的是让任务延迟10秒：
<intermediateCatchEvent id="sid-140BA4B7-61AC-419C-BBBF-F046F41E3D2E">
      <timerEventDefinition>
        <timeDuration>PT10S</timeDuration>
      </timerEventDefinition>
    </intermediateCatchEvent>
但10 秒之后，任务没有被认领，并且我也配置了 ：<property name="jobExecutorActivate" value="true" />，他的意思是让job 自动执行。奇怪的是只有当我重启服务器的时候，这个任务才会被认领（执行这个job），困扰几天了，求解答。

8 楼 programerje 2015-05-19  

你敢不敢把源码贴出来！

7 楼 星河630 2013-05-31  

[/img][/img]

6 楼 yangfq 2013-05-25  

楼主您好，能否给个demo可以参考下怎么使用呢，刚接触activiti，还望多多指教！谢谢

5 楼 旋风小皮皮 2013-03-14  

你好，我按照你的例子做了一个流程，用junit跑用例的时候报了一个错：
Timeout trying to lock table "ACT_RU_JOB"，请问是什么原因？

4 楼 wslovenide 2013-02-20  

org.activiti.engine.ActivitiOptimisticLockingException: TimerEntity[57812] was updated by another transaction concurrently

3 楼 lucky16 2013-02-20  

wslovenide 写道

监听器里面是delegateTask.getExecution().setVariable("dueTime", "PT60S"); 也不行

你能把你的错误关键代码贴出来一下吗？

2 楼 wslovenide 2013-02-20  

监听器里面是delegateTask.getExecution().setVariable("dueTime", "PT60S"); 也不行

1 楼 wslovenide 2013-02-20  

我遇到个问题，流程跟你这个类似，定时时间也是用的变量，但是变量不是在流程启动的时候就加上去的，在用户任务里面加了一个任务监听器，在这个任务监听器里面我从数据库中查询出定时时间，把这个时间设置到流程变量里面，但是总是报错。。。不知为何，若是启动流程的时候就把变量加上就不会出错.

<startEvent id="startevent1" name="Start"></startEvent>
    <userTask id="usertask1" name="User Task-fozzie" activiti:assignee="fozzie">
        <extensionElements>
            <activiti:taskListener event="create" class="com.activiti.testcase.timer.TaskListener1"></activiti:taskListener>
        </extensionElements>
    </userTask>
    <boundaryEvent id="boundarytimer1" cancelActivity="false" attachedToRef="usertask1">
      <timerEventDefinition>
          <timeDuration>${dueTime}</timeDuration>
      </timerEventDefinition>
    </boundaryEvent>

public class TaskListener1 implements TaskListener {

	public void notify(DelegateTask delegateTask) {
		delegateTask.getExecution().setVariable("dueTime22", "PT60S");
	}
}