X2内置计划任务分析

我们的论坛包含了很多计划任务相关的操作。
比如我们最常遇到的 每日的发贴 处理，该计划任务保证了我们能看到昨日发帖和今日发贴这样的数据。
还有比如，我们在论坛后台添加了一个到某个时间过期的广告，那么也是论坛的计划任务使得该广告到期后自动下架。

我们知道 PHP 本身是触发型语言，需要触发才能执行某个操作，而不像 linux 那样可以到指定时间执行指定的计划任务。
所以上面提到的计划任务，实际上都是需要我们触发才能执行的。

我们详细的分析下 X2 的计划任务执行的步骤，以及我们如何根据自己的需求写一个计划任务，并且加入到 X2 的系统运行中。

首先，我们看下 X2 中的核心代码 /source/core/class_core.php

discuz_core 类是我们程序的核心类，程序在执行的时候，首先会运行该类。

在该类中，我们能看到有一个方法：_init_cron() 。

该方法的代码是：

1. function _init_cron() {
   
2.                 if($this->init_cron && $this->init_setting) {
   
3.                         if($this->var['cache']['cronnextrun'] <= TIMESTAMP) {
   
4.                                 discuz_cron::run();
   
5.                         }
   
6.                 }
   
7.         }

复制代码

默认情况下，我们在前面能看到 init_cron 和 init_setting 为 true，
所以这里实际上是根据我们缓存中记录的一个下次执行计划的时间和当前时间的一个对比，如果该时间小于等于当前时间，我们则执行 计划任务 的run方法。
（我们暂时先不说这个计划任务的下次执行时间是如何来的，稍后会提到，暂时只要认为需要执行计划任务即可）

同样在这个文件中，找到 discuz_cron 类，我们重点看下该类中的 run 方法：

1. function run($cronid = 0) {
   
2. 
   
3.                 global $_G;
   
4.                 $timestamp = TIMESTAMP;
   
5.                 $cron = DB::fetch_first("SELECT * FROM ".DB::table('common_cron')."
   
6.                                 WHERE ".($cronid ? "cronid='$cronid'" : "available>'0' AND nextrun<='$timestamp'")."
   
7.                                 ORDER BY nextrun LIMIT 1");
   
8. 
   
9.                 $processname ='DZ_CRON_'.(empty($cron) ? 'CHECKER' : $cron['cronid']);
   
10. 
    
11.                 if($cronid && !empty($cron)) {
    
12.                         discuz_process::unlock($processname);
    
13.                 }
    
14. 
    
15.                 if(discuz_process::islocked($processname, 600)) {
    
16.                         return false;
    
17.                 }
    
18. 
    
19.                 if($cron) {
    
20. 
    
21.                         $cron['filename'] = str_replace(array('..', '/', '\\'), '', $cron['filename']);
    
22.                         $cronfile = DISCUZ_ROOT.'./source/include/cron/'.$cron['filename'];
    
23. 
    
24.                         $cron['minute'] = explode("\t", $cron['minute']);
    
25.                         discuz_cron::setnextime($cron);
    
26. 
    
27.                         @set_time_limit(1000);
    
28.                         @ignore_user_abort(TRUE);
    
29. 
    
30.                         if(!@include $cronfile) {
    
31.                                 return false;
    
32.                         }
    
33.                 }
    
34. 
    
35.                 discuz_cron::nextcron();
    
36.                 discuz_process::unlock($processname);
    
37.                 return true;
    
38.         }

复制代码

这个方法如果可以指定一个 任务id ，当然也可以为空。
如果这里指定了任务的 id，就可以执行我们指定的任务，比如在后台任务列表中，手动点击执行时。就会根据这个id执行。
如果为空，会根据 表 pre_common_cron 中得到的下一次执行的任务去执行。
执行的过程采用了加锁的方式，防止在任务被同时执行，导致数据出现错误。
这个加锁的过程，可以单独分析下 discuz_process 类，这里就先不细说这个了。
执行计划任务时，会把我们事先写好的计划任务脚本载入进来，所以我们的计划任务脚本里面直接可以用 $_G 等变量。
被载入进来的脚本直接执行，执行完以后，程序会通过 setnextime 方法设置下次计划任务执行的时间。

这样，整个计划任务就连贯起来可以执行了。