EAS后台事务服务介绍

目   录

1. 简介 

2. 功能说明 

2.1. 后台事务定义 

2.2. 后台事务定义列表 

2.3. 后台事务监控 

3. 主要类文件说明 

3.1. 服务端 （scheduler）

3.1.1. 后台事务服务启动 

3.1.2. 后台事务服务类 

3.1.3. 流程定义转后台事务定义 

3.1.4. 后台事务服务状态维护 

3.1.5. 后台事务实例加载器 

3.1.6. 后台事务触发器加载器 

3.1.7. 后台事务队列 

3.1.8. 后台事务定义触发 

3.2. 客户端 （bs_job） 

3.2.1. 后台事务定义配置 

3.2.2. 后台事务定义列表（已发布的） 

3.2.3. 后台事务实例列表 

4. 后台事务特性 

4.1. 非持久化后台事务 

4.2. 错过策略 

4.3. 人工干预（撤销，挂起，唤醒） 

4.4. 调度计划时间 

4.5. 事务动态优先级 

4.6. 互斥任务 

4.7. 日志消息 

4.8. 大小任务 

4.9. 配置文件参数说明 

5. 后台事务主要数据库表 

6. 隔离边界 

7. FAQ 

7.1. 如何开启和关闭后台事务服务 

7.2. 如何使用后台事务服务 

7.3. 后台事务服务堵塞，某个后台事务一直处于执行中，堵塞了其他后台事务。 

7.4. 后台事务增大并发数 

7.5. EAS高可用多机集群，后台事务集群分发配置 

1. 简介

什么是后台事务服务？

• 是后台运行的系统服务，类似windows执行计划；

• 一种后台运行的作业调度；

• 依赖于Quartz调度框架；

• 通过线程池来管理。

例如：有这样一个任务：每个月的最后一天，计算所有员工工资。则可以后台事务来实现和管理。

首先定义一个后台事务，然后选择相应的任务，这里的任务就是“计算所有员工资”，再选择调度计划或调度周期，这里调度计划就是“每个月的最后一天”，最后发布后台事务就可以了，到每月的最后一天自动会计算所有员工的工资。

2. 功能说明

2.1. 后台事务定义

可以通过后台事务定义，定义一个后台事务服务。

点击新增按钮。

输入后台事务名称

选择任务

从“选择任务”对话框中选择需要的任务点击确定退出

如果所选任务有参数请输入有意义的参数

设置调度计划也就是执行计划

选择调度计划类型

详细设置选定类型的调度计划

设置完成后点击完成，退出调度计划设置界面

设置互斥控制（后台事务互斥标识，一般保持默认即可，参考4.6互斥任务）

设置指定服务器（默认自动分配，也可指定到某一个实例上执行）

设置好后就可以点击“保存”按钮保存后台事务

保存成功

保存后的后台事务如果需要运行需要点击“发布”按钮进行发布

点击“发布”按钮后弹出“发布事务”对话框

点击“发布事务”对话框下面的“发布”按钮进行发布

这样一条后台事务就定义完成并已经生效

2.2. 后台事务定义列表

列出所有已经定义的后台事务，并可以启动/禁用后台事务

2.3. 后台事务监控

可以查看后台事务的运行情况，类似工作流监控。主要包括后台事务的名称、状态、发起人、创建时间等信息。

3. 主要类文件说明

3.1. 服务端（scheduler）

3.1.1. 后台事务服务启动

eas\server\profiles\server*\config\listenerconfig.data

<listener name="com.kingdee.bos.service.scheduler.BOSSchedulerService" enable="true" failOnError="false" />

主要功能：启动后台事务引擎

eas/server/profiles/server*/config/bosconfig.xml

<configitem name="scheduler">

<attribute key="enable" value="true" />

</configitem>

主要功能：启动后台事务服务，没有参数默认为true

注意：

在管理控制台反部署数据中心后，应该重启服务器；否则将导致服务器每隔一定时间输出数据中心无法访问的日志（除此之外，也就是浪费一点服务器内存，没有其他副作用）。

3.1.2. 后台事务服务类

com.kingdee.bos.service.job.core. JobService

3.1.3. 流程定义转后台事务定义

com.kingdee.bos.workflow.store.util. JobServiceUtil

3.1.4. 后台事务服务状态维护

com.kingdee.bos.service.job.core. ClusterStateManager

主要功能：

在数据 T_Job_Service 表中维护当前在线的后台事务服务器列表；

检查停止执行的后台事务服务器并回收其加载但未执行完的后台事务实例

3.1.5. 后台事务实例加载器

com.kingdee.bos.service.job.core. JobLoader

定期搜索T_Job_Inst表加载待执行的后台事务实例

3.1.6. 后台事务触发器加载器

com.kingdee.bos.service.job.core. TriggerLoader

定期搜索T_Job_Trigger表加载新发布的后台事务触发器

3.1.7. 后台事务队列

com.kingdee.bos.service.job.core. WaitingJobs/ReadyJobs/RunningJobs

等待、就绪队列及当前执行任务（对已就绪的大事务及互斥事务进行了管理）

3.1.8. 后台事务定义触发

com.kingdee.bos.service.job.pulse. TimerPulseSource

定期检查后台事务触发器的触发时间，在下一个触发时刻“快”到达时，根据后台事务定义生成后台事务实例。

3.2. 客户端（bs_job）

3.2.1. 后台事务定义配置

com.kingdee.eas.base.job.client.JobProcessManager

3.2.2. 后台事务定义列表（已发布的）

com.kingdee.eas.base.job.client.JobProcessDefineListUI

注：以”~”开头的后台事务定义不允许禁用或启用。

3.2.3. 后台事务实例列表

com.kingdee.eas.base.job.client.JobProcessInstanceListUI

注：以”~”开头的后台事务实例不允许撤消或挂起。

4. 后台事务特性

4.1. 非持久化后台事务

后台事务分为持久化事务和非持久化事务，持久化事务指写入数据库持久化的事务，可以被其他实例加载执行，可以在后台事务监控查到执行记录；非持久化事务是系统内部缓存的事务，只能在本实例执行。

在登陆EAS系统后，进入后台事务管理，在后台事务定义的界面上我们是不能选择是定义持久化事务和非持久化事务的，通过在EAS系统中定义的后台事务默认都是持久化事务的。如果我们要定义非持久化后台事务，就必须通过代码来实现。

4.2. 错过策略

在后台事务定义的时候，可以进行设置后台事务的错过策略，有两种情况，一种是“立即执行”，另一种是“忽略不计”，其中这两种是怎样工作的呢？

在后台事务定义的时候，后台事务错过策略信息是保存在T_JOB_DEF的fmissedtimeout字段中，设置后台事务的错过策略为立即执行，这个字段保存的值为-1，设置为忽略不计，这个字段保存的值为0。

当生成后台事务任务时，如果过期时间为空，则首先判断JobDef的missedTimeout是否为0，如果为零，表示忽略不计，对忽略不计这种情况，系统会默认设置它的过期时间，在任务执行的时候，如果超过这个过期时间，就设置这个后台事务实例的状态为“已错过”；对于立即执行这种情况，就不会去设置它的过期时间，expiredTime这个值为null，表示永不过期。

4.3. 人工干预（撤销，挂起，唤醒）

对已接收，重新调度，已就绪，等待中的后台事务实例可进行撤销和挂起操作，对已挂起的后台事务实例可以进行唤醒操作，已错过的后台事务可以进行修复操作（其实质也就是重新调度），对运行中的后台事务不能够做任何操作。

4.4. 调度计划时间

依赖于Quartz调度框架，Quartz是opensymphony组织专攻job scheduling领域又一个开源利器，可以到http://www.opensymphony.com/quartz查看详细信息。

Quartz是轻量级的组件，开发人员只需要加载单独的jar包就可以利用Quartz强大的日程安排功能。当然，假如你为Quartz配备了数据库持久化任务的特性，Quartz也可以很好的利用这一点，从而在机器重启后还能够记住你原先安排的计划。

目前的Quartz实现中，存在两种Trigger,SimpleTrigger和CronTrigger。SimpleTrigger：用来完成一些比如固定时间执行的任务，比如：从现在开始1分钟后等等；CronTrigger：  用来执行calendar-like的任务，比如：每周五下午3：00，每月最后一天等等。

后台事务触发器的调度计划时间表达式是保存在数据库表T_JOB_TRIGGER的fschedulePlan字段中，String schedulePlan=schedule.getType().toString()+":"+schedule.getDefine();由这条语句可知，其值由两部分组成。分别为调度类别和调度的定义，其中调度定义是Quartz的cron 表达式的格式，后台事务获取下一次触发时间就是根据这个表达式来得到的，首先根据这个表达式可以新建一个CronTrigger对象，通过这个对象及上一次的触发时间就可以得到下一次触发时间了：quartzTrigger.getFireTimeAfter(lastTriggeredTime)。

下面是对Quartz的cron 表达式的格式的说明：

Quartz 用 cron 表达式存放执行计划。引用了 cron 表达式的 CronTrigger 在计划的时间里会与 job 关联上。Quartz 提供七个域。下表列出了 Quartz cron 表达式支持的七个域。

月份和星期的名称是不区分大小写的。FRI 和 fri 是一样的。域之间有空格分隔，这和 UNIX cron 一样。无可争辩的，我们能写的最简单的表达式看起来就是这个了：* * * ? * *，这个表达会每秒钟(每分种的、每小时的、每天的)激发一个部署的 job。

Quartz cron 表达式支持用特殊字符来创建更为复杂的执行计划：

*星号：使用星号(*) 指示着你想在这个域上包含所有合法的值。例如，在月份域上使用星号意味着每个月都会触发这个 trigger。

表达式样例：0 * 17 * * ?

意义：每天从下午5点到下午5:59中的每分钟激发一次 trigger。它停在下午 5:59 是因为值 17 在小时域上，在下午 6 点时，小时变为 18 了，也就不再理会这个 trigger，直到下一天的下午5点，在你希望 trigger 在该域的所有有效值上被激发时使用 * 字符。

? 问号：? 号只能用在日和周域上，但是不能在这两个域上同时使用。你可以认为 ? 字符是 "我并不关心在该域上是什么值。" 这不同于星号，星号是指示着该域上的每一个值。? 是说不为该域指定值。

不能同时这两个域上指定值的理由是难以解释甚至是难以理解的。基本上，假定同时指定值的话，意义就会变得含混不清了：考虑一下，如果一个表达式在日域上有值11，同时在周域上指定了 WED。那么是要 trigger 仅在每个月的11号，且正好又是星期三那天被激发？还是在每个星期三的11号被激发呢？要去除这种不明确性的办法就是不能同时在这两个域上指定值。只要记住，假如你为这两域的其中一个指定了值，那就必须在另一个字值上放一个 ?。

表达式样例：0 10,44 14 ? 3 WEB

意义：在三月中的每个星期三的下午 2:10 和 下午 2:44 被触发。

, 逗号：逗号 (,) 是用来在给某个域上指定一个值列表的。例如，使用值 0,15,30,45 在秒域上意味着每15秒触发一个 trigger。

表达式样例： 0 0,15,30,45 * * * ?

意义：每刻钟触发一次 trigger。

/ 斜杠：斜杠 (/) 是用于时间表的递增的。我们刚刚用了逗号来表示每15分钟的递增，但是我们也能写成这样 0/15。

表达式样例： 0/15 0/30 * * * ?

意义：在整点和半点时每15秒触发 trigger。

- 中划线：中划线 (-) 用于指定一个范围。例如，在小时域上的 3-8 意味着 "3,4,5,6,7 和 8 点。"  域的值不允许回卷，所以像 50-10 这样的值是不允许的。

表达式样例： 0 45 3-8 ? * *

意义：在上午的3点至上午的8点的45分时触发 trigger。

L 字母： L 说明了某域上允许的最后一个值。它仅被日和周域支持。当用在日域上，表示的是在月域上指定的月份的最后一天。例如，当月域上指定了 JAN 时，在日域上的 L 会促使 trigger 在1月31号被触发。假如月域上是 SEP，那么 L 会预示着在9月30号触发。换句话说，就是不管指定了哪个月，都是在相应月份的时最后一天触发 trigger。

表达式样例： 0 0 8 L * ?

意义：在每个月最后一天的上午 8:00 触发 trigger。在月域上的 * 说明是 "每个月"。当 L 字母用于周域上，指示着周的最后一天，就是星期六 (或者数字7)。所以如果你需要在每个月的最后一个星期六下午的 11:59 触发 trigger，你可以用这样的表达式 0 59 23 ? * L。当使用于周域上，你可以用一个数字与 L 连起来表示月份的最后一个星期 X。例如，表达式 0 0 12 ? * 2L 说的是在每个月的最后一个星期一触发 trigger。

注意：不要让范围和列表值与 L 连用，虽然你能用星期数(1-7)与 L 连用，但是不允许你用一个范围值和列表值与 L 连用。这会产生不可预知的结果。

W 字母：W 字符代表着平日 (Mon-Fri)，并且仅能用于日域中。它用来指定离指定日的最近的一个平日。大部分的商业处理都是基于工作周的，所以 W 字符可能是非常重要的。例如，日域中的 15W 意味着 "离该月15号的最近一个平日。" 假如15号是星期六，那么 trigger 会在14号(星期四)触发，因为距15号最近的是星期一，这个例子中也会是17号（译者Unmi注：不会在17号触发的，如果是15W，可能会是在14号(15号是星期六)或者15号(15号是星期天)触发，也就是只能出现在邻近的一天，如果15号当天为平日直接就会当日执行）。W 只能用在指定的日域为单天，不能是范围或列表值。

# 井号：# 字符仅能用于周域中。它用于指定月份中的第几周的哪一天。例如，如果你指定周域的值为 6#3，它意思是某月的第三个周五 (6=星期五，#3意味着月份中的第三周)。另一个例子 2#1 意思是某月的第一个星期一 (2=星期一，#1意味着月份中的第一周)。注意，假如你指定 #5，然而月份中没有第 5 周，那么该月不会触发。

4.5. 事务动态优先级

动态优先级由两部分生成，一是计划执行时间，另一部分是静态优先级