继续转 [转]php版本的cron定时任务执行器

由于服务器crontab只能精确到分钟，那程序的起点也是分钟。 一共包括但部分： 一、配置文件： 配置文件是用来返回要执行的定时任务文件，注意一下*的使用就行了，有两个模式，就是 Y-m-d H:i ：年 月 日 时 分N H:i ：星期(1 - 7|周一 - 周日) 时 分 配置文

由于服务器crontab只能精确到分钟，那程序的起点也是分钟。

一共包括但部分：

一、配置文件：

配置文件是用来返回要执行的定时任务文件，注意一下*的使用就行了，有两个模式，就是

Y-m-d H:i        ：年 月 日 时 分
N H:i            ：星期(1 - 7|周一 - 周日) 时 分

配置文件：croning.php

<span>/*</span><span>*
 * 任务管理器配置文件
 * 
 * Y-m-d H:i        ：年 月 日 时 分
 * N H:i            ：星期(1 - 7|周一 - 周日) 时 分
 * 
 * 2013-12-25 19:49 : 固定时间，只执行一次
 * *-12-25 20:00    : 每年的某月某日 某小时某分
 * 2013-12-25 *:49  : 某天的每个小时的49分都执行一次
 * *-*-* 20:00      : 每天晚上8点0分执行
 * *-*-* *:*        ：每分钟都在执行
 * 2 20:01          ：每周二的20:01时间都执行一次
 * 
 * * 号表示当前位置的任何时间。以此类推....
 * 
 * 格式：
 * array(
 *      key=>value,
 * );
 * 
 * 说明：
 * key是定义的执行时间，value是执行的文件，可以是数组或者字符串，当同一时间有多个任务执行时，为了避免key的覆盖请用一维数组模式。
 * 
 </span><span>*/</span>
<span>return</span> <span>array</span><span>(
    </span>'2013-12-25 19:49'=>'123.php',
    '2013-12-* 18:00'=>'456.php',
    '1 08:00'=>'6546.php',
    '*-12-25 19:49'=><span>array</span>('444.php','456.php'<span>)
);</span>

 

二、服务器cronjob主要执行的php文件：

主要处理与分析哪些文件是当时可以执行的。以及写入执行记录文件。

<span>php
</span><span>/*</span><span>*
 * cron任务统一执行的文件，没有超时
 </span><span>*/</span>
<span>header</span>('Content-Type:text/html; charset=utf-8'<span>);
</span><span>set_time_limit</span>(0<span>);
</span><span>define</span>('APP_ROOT', <span>dirname</span>(<span>__FILE__</span><span>));
</span><span>define</span>('AHA_ROOT', <span>dirname</span><span>(APP_ROOT));
</span><span>define</span>('CORE_ROOT', AHA_ROOT . '/__core'<span>);
</span><span>define</span>('DATA_ROOT', AHA_ROOT . '/data'<span>);
</span><span>define</span>('MODEL_ROOT', APP_ROOT . '/model'<span>);
</span><span>define</span>('ONING_ROOT', APP_ROOT . '/oning'); <span>//</span><span>定时执行文件目录</span>
<span>require</span> CORE_ROOT . '/Common.php'<span>;
</span><span>require</span> CORE_ROOT . '/AHA.php'; <span>//</span><span>载入框架核心文件</span>
spl_autoload_register(<span>array</span>('Common', 'loadClassFile'<span>));
AHA</span>::initConfig(<span>include</span> APP_ROOT . '/_config/inc.php'); <span>//</span><span>载入配置文件
//不存在执行的配置文件时</span>
<span>if</span> (!<span>file_exists</span>(APP_ROOT . '/_config/croning.php'<span>)) {
    </span><span>exit</span>('cron failed,please check the cron config!'<span>);
}

</span><span>$__all</span> = <span>include</span> APP_ROOT . '/_config/croning.php'<span>;
</span><span>//</span><span>数据不合法时</span>
<span>if</span> (!<span>$__all</span> || !<span>is_array</span>(<span>$__all</span><span>)) {
    </span><span>exit</span>('cron failed,please check the cron config!'<span>);
}

</span><span>$__echo</span> = <span>true</span>; <span>//</span><span>是否输出到屏幕</span>

<span>$__time_star</span> = <span>microtime</span>(<span>true</span><span>);
</span><span>$__now</span> = <span>time</span><span>();

Common</span>::fileLog(DATA_ROOT . '/log/cron_index.log', '执行cron开始******************************' . <span>date</span>('Y-m-d H:i:s', <span>$__now</span>) . '******************************', <span>$__echo</span><span>);

</span><span>$__onFile</span> = <span>array</span><span>();
</span><span>if</span> (<span>$__all</span><span>) {
    </span><span>foreach</span> (<span>$__all</span> <span>as</span> <span>$__key</span> => <span>$__value</span><span>) {
        </span><span>if</span> (<span>strpos</span>(<span>$__key</span>, '-') === <span>false</span>) {<span>//</span><span>每周的处理</span>
            <span>preg_match</span>('@^([\d\*]+) ([\d\*]+):([\d\*]+)$@U', <span>$__key</span>, <span>$match</span><span>);
        } </span><span>else</span> {<span>//</span><span>正常的处理</span>
            <span>preg_match</span>('@^([\d\*]+)\-([\d\*]+)\-([\d\*]+) ([\d\*]+):([\d\*]+)$@U', <span>$__key</span>, <span>$match</span><span>);
        }
        </span><span>if</span> (<span>$match</span><span>) {
            </span><span>array_shift</span>(<span>$match</span><span>);
            </span><span>if</span> (__getPreg(<span>$match</span>, <span>$__now</span>)) {<span>//</span><span>是否是要执行的文件</span>
                <span>$__onFile</span> = <span>array_merge</span>(<span>$__onFile</span>, <span>is_array</span>(<span>$__value</span>) ? <span>$__value</span> : <span>array</span>(<span>$__value</span><span>));
            }
        }
    }
}
</span><span>if</span> (<span>$__onFile</span><span>) {
    </span><span>$__onFile</span> = <span>array_unique</span>(<span>$__onFile</span><span>);
    </span><span>foreach</span> (<span>$__onFile</span> <span>as</span> <span>$__value</span><span>) {
        </span><span>if</span> (<span>file_exists</span>(ONING_ROOT . '/' . <span>$__value</span><span>)) {
            </span><span>$__time_star2</span> = <span>microtime</span>(<span>true</span><span>);
            Common</span>::fileLog(DATA_ROOT . '/log/cron_index.log', <span>$__value</span> . ' 执行开始----------' . <span>date</span>('Y-m-d H:i:s') . '-----------', <span>$__echo</span><span>);
            </span><span>include</span> ONING_ROOT . '/' . <span>$__value</span><span>;
            Common</span>::fileLog(DATA_ROOT . '/log/cron_index.log', <span>$__value</span> . ' 执行结束(花费时间：' . ((<span>microtime</span>(<span>true</span>) - <span>$__time_star2</span>) * 1000) . 'ms)-------------', <span>$__echo</span><span>);
        }
    }
}
Common</span>::fileLog(DATA_ROOT . '/log/cron_index.log', '执行cron结束(一共执行时间：' . ((<span>microtime</span>(<span>true</span>) - <span>$__time_star</span>) * 1000) . 'ms)*************' . <span>date</span>('Y-m-d H:i:s') . '*****************' . "\n\n", <span>$__echo</span><span>);

</span><span>/*</span><span>*
 * 处理正则结果并返回该文件是否是当时要执行
 * @param array $match      正则结果，数组
 * @param integer $__now    当时时间戳
 * @return bool
 </span><span>*/</span>
<span>function</span> __getPreg(<span>$match</span>, <span>$__now</span><span>) {
    </span><span>$back</span> = <span>false</span><span>;
    </span><span>list</span>(<span>$__Y</span>, <span>$__m</span>, <span>$__d</span>, <span>$__N</span>, <span>$__H</span>, <span>$__i</span>) = <span>explode</span>('-', <span>date</span>('Y-m-d-N-H-i', <span>$__now</span><span>));
    </span><span>$argc</span> = <span>count</span>(<span>$match</span><span>);
    </span><span>if</span> (<span>$argc</span> === 3<span>) {
        </span><span>$argc</span> = <span>$match</span>[0] === '*' ? <span>$__N</span> : <span>$match</span>[0<span>];
        </span><span>$argc</span>.=' '<span>;
        </span><span>$argc</span>.=<span>$match</span>[1] === '*' ? <span>$__H</span> : <span>$match</span>[1<span>];
        </span><span>$argc</span>.=':'<span>;
        </span><span>$argc</span>.=<span>$match</span>[2] === '*' ? <span>$__i</span> : <span>$match</span>[2<span>];
        </span><span>$back</span> = <span>date</span>('N H:i', <span>$__now</span>) === <span>date</span>(<span>$argc</span>, <span>$__now</span>) ? <span>true</span> : <span>false</span><span>;
    } </span><span>elseif</span> (<span>$argc</span> === 5<span>) {
        </span><span>$argc</span> = <span>$match</span>[0] === '*' ? <span>$__Y</span> : <span>$match</span>[0<span>];
        </span><span>$argc</span>.='-'<span>;
        </span><span>$argc</span>.=<span>$match</span>[1] === '*' ? <span>$__m</span> : <span>$match</span>[1<span>];
        </span><span>$argc</span>.='-'<span>;
        </span><span>$argc</span>.=<span>$match</span>[2] === '*' ? <span>$__d</span> : <span>$match</span>[2<span>];
        </span><span>$argc</span>.=' '<span>;
        </span><span>$argc</span>.=<span>$match</span>[3] === '*' ? <span>$__H</span> : <span>$match</span>[3<span>];
        </span><span>$argc</span>.=':'<span>;
        </span><span>$argc</span>.=<span>$match</span>[4] === '*' ? <span>$__i</span> : <span>$match</span>[4<span>];
        </span><span>$back</span> = <span>date</span>('Y-m-d H:i', <span>$__now</span>) === <span>date</span>(<span>$argc</span>, <span>$__now</span>) ? <span>true</span> : <span>false</span><span>;
    }
    </span><span>return</span> <span>$back</span><span>;
}</span>

<br>

三、众多要执行的定时文件：

这个是真正要执行的代码：包括采集，数据整理与分析。。。。，文件路径写到配置文件的value中去。同一时间执行的文件，记得一维数组模式。

 

来源：http://www.pangyiguang.com/a_76