crontab定时任务-干货案例

Posted 2020-10-19 lewo的博客

自定义需求：实现消息队列。

1.创建一张mysql表结构

2.编写php脚本，便于sh文件执行

3.编写sh脚本，便于crontab定时执行

4.crontab -e 注册定时任务，如果此步不清楚请参照：http://www.cnblogs.com/jiangxiaobo/p/8194371.html

******************************************************************************************************************************

1.创建一张mysql表结构(仅供参考)

-- ----------------------------
-- Table structure for `message_queue`
-- ----------------------------
-- DROP TABLE IF EXISTS `message_queue`;
-- CREATE TABLE `message_queue` (
CREATE TABLE IF NOT EXISTS `message_queue` (
    `id` int unsigned NOT NULL AUTO_INCREMENT,
    `type` tinyint unsigned NOT NULL DEFAULT 0 COMMENT \'消息类型\', # 0-普通消息,1-邮件消息
    `status` tinyint unsigned NOT NULL DEFAULT 0, # 0-未处理,1-处理完成,2-处理中
    `head` text COMMENT \'消息头部\',
    `body` text COMMENT \'消息主体\',
    `createtime` int(10) unsigned NOT NULL DEFAULT 0 COMMENT \'创建时间\',
    `updatetime` int(10) unsigned NOT NULL DEFAULT 0 COMMENT \'修改时间\',
    PRIMARY KEY (`id`),
    KEY `type` (`type`),
    KEY `status` (`status`)
) ENGINE=MyISAM  DEFAULT CHARSET=utf8 COMMENT \'消息队列表\';

2.编写php脚本，便于sh文件执行

这里可以脱离php框架，也可以依赖php框架，看个人，为了便捷，实现，依赖thinkphp框架为例。

MessageQueueModel:

<?php
/*
 * 消息队列模型
 * 用于定时任务处理
 */
namespace Cli\\Model;
use Think\\Model;
use Org\\Util\\String;
/*
-- ----------------------------
-- Table structure for `message_queue`
-- ----------------------------
-- DROP TABLE IF EXISTS `message_queue`;
-- CREATE TABLE `message_queue` (
CREATE TABLE IF NOT EXISTS `message_queue` (
    `id` int unsigned NOT NULL AUTO_INCREMENT,
    `type` tinyint unsigned NOT NULL DEFAULT 0 COMMENT \'消息类型\', # 0-普通消息,1-邮件消息
    `status` tinyint unsigned NOT NULL DEFAULT 0, # 0-未处理,1-处理完成,2-处理中
    `head` text COMMENT \'消息头部\',
    `body` text COMMENT \'消息主体\',
    `createtime` int(10) unsigned NOT NULL DEFAULT 0 COMMENT \'创建时间\',
    `updatetime` int(10) unsigned NOT NULL DEFAULT 0 COMMENT \'修改时间\',
    PRIMARY KEY (`id`),
    KEY `type` (`type`),
    KEY `status` (`status`)
) ENGINE=MyISAM  DEFAULT CHARSET=utf8 COMMENT \'消息队列表\';
 */
class MessageQueueModel extends Model{
    // protected $connection = \'MSG_QUE_DB_DSN\';
    // 模型表实际名称
    protected $trueTableName = \'message_queue\';
    // 命名范围
    protected $_scope = array(
        // 取出未处理的消息
        \'not_processed\' => array(
            \'where\' => array(\'status\'=>0),
            \'field\' => \'id,type,head,body\',
            \'order\' => \'createtime asc\'
        )
    );
    /**
     * 架构函数
     * @access public
     * @param string $name 模型名称
     * @param string $tablePrefix 表前缀
     * @param mixed $connection 数据库连接信息
     */
    // public function __construct($name=\'\',$tablePrefix=\'\',$connection=\'\'){
    //     $this->trueTableName = C(\'TABLE_MESSAGE_QUEUE\');
    //     parent::__construct($name,$tablePrefix,$connection);
    // }
    /**
     * 获取一条未处理的消息
     * @access public
     */
    public function get_message(&$msg){
        // 取出最远的一条未处理的消息
        $msg = $this->scope(\'not_processed\')->fetchSql(false)->find();
        $msg[\'head\'] = json_decode(base64_decode($msg[\'head\']),true);
        return $msg;
    }
    /**
     * 将消息状态改成处理中
     * @access public
     */
    public function lock($id){
        $map[\'id\'] = $id;
        $data[\'status\'] = 2;
        return $this->where($map)->save($data);
    }
    /**
     * 将消息状态改成处理完成
     * @access public
     */
    public function unlock($id){
        $map[\'id\'] = $id;
        $data[\'status\'] = 1;
        return $this->where($map)->save($data);
    }
    /**
     * 将消息转为字符串
     * @access public
     */
    public function toString(&$msg){
        return date("Y-m-d H:i:s # ").C(\'DB_NAME\').".".$this->trueTableName.".id = ".$msg[\'id\']." Processed!<br>\\r\\n";
    }
    /**
     * 添加测试数据
     * @access public
     */
    public function randData(){
        $emails = array(
            \'[e-mail]\',
            \'[e-mail]\',
            \'[e-mail]\',
        );
        for($i=0;$i<100;$i++){
            $list[$i][\'type\'] = mt_rand(0,1);
            $list[$i][\'status\'] = mt_rand(0,2);
            if($list[$i][\'type\'] == 1){
                $head1[\'email\'] = $emails[mt_rand(0,2)];
                $list[$i][\'head\'] = base64_encode(json_encode($head1));
            }else{
                $head0[\'uid\'] = mt_rand(1,1000000);
                $list[$i][\'head\'] = base64_encode(json_encode($head0));
            }
            $list[$i][\'body\'] = String::randString(mt_rand(200,1000),4);
            $list[$i][\'createtime\'] = time();
        }
        return $this->addAll($list);
    }
}

MessageQueueController:

<?php
namespace Cli\\Controller;
use Think\\Controller;
use Cli\\Model\\MessageQueueModel;
class MessageQueueController extends Controller {
    public function index(){
        $MessageQueue = new MessageQueueModel();
        $MessageQueue->get_message($msg);
        $MessageQueue->lock($msg[\'id\']) or die;
        if($msg[\'type\'] == 0){
            // 处理普通消息
            file_put_contents(C("LOG_ROOT_PATH").MODULE_NAME."/message_queue.log", $MessageQueue->toString($msg), FILE_APPEND);
        }else if($msg[\'type\'] == 1){
            $to = $msg[\'head\'][\'email\'];
            if(empty($to)) die;
            // 处理邮件消息
            import(\'Common.phpMailer.class\',\'\',\'.phpmailer.php\');
            $mail = new \\PHPMailer();
            $mail->IsSMTP();
            $mail->CharSet = \'UTF-8\'; // 设置邮件的字符编码，这很重要，不然中文乱码 
            $mail->SMTPAuth = true; // 开启认证
            $mail->Port = C(\'SMTP_PROT\');
            $mail->Host = C(\'SMTP_HOST\');
            $mail->Username = C(\'SMTP_USERNAME\');
            $mail->Password = C(\'SMTP_PASSWORD\');
            // $mail->IsSendmail(); // 如果没有sendmail组件就注释掉，否则出现“Could not execute: /var/qmail/bin/sendmail ”的错误提示 
            $mail->AddReplyTo(C(\'SMTP_REPLY_TO_ADDRESS\'),C(\'SMTP_REPLY_TO_NAME\')); // 回复地址
            $mail->From = C(\'SMTP_FROM\');
            $mail->FromName = C(\'SMTP_FROM_NAME\');
            $mail->AddAddress($to);
            $mail->WordWrap = C(\'SMTP_WORD_WRAP\'); // 设置每行字符串的长度

            $mail->Subject = "定时任务";
            $mail->Body = $msg[\'body\'];
            // $mail->AltBody = "测试主体"; // 当邮件不支持html时备用显示，可以省略 
            // $mail->AddAttachment("f:/test.png"); // 可以添加附件
            $mail->IsHTML(true);
            $mail->Send();
        }
        $MessageQueue->unlock($msg[\'id\']) or die;
    }
}

3.编写sh脚本，便于crontab定时执行

cd /www/loveDove/www_admin_com
/usr/local/php5/bin/php index.php Cli/MessageQueue/index

或者将错误输出至相应的日志文件（error.log）

cd /www/loveDove/www_admin_com
/usr/local/php5/bin/php index.php Cli/MessageQueue/index >> /www/error/error.log 2>&1

注意：如果添加 php index.php Cli/MessageQueue/index 定时任务不执行，则需要将 php 命令改为全路径的命令 (which php查看全路径命令);另外，sh脚本必须在当前环境下进行创建则最为保险，不然会出现一些格式错误（touch index.sh来创建文件），如权限不够，则需要（chmod 777 index.sh来改变sh脚本文件的权限）。

4.crontab -e 注册定时任务

# Edit this file to introduce tasks to be run by cron.
#
# Each task to run has to be defined through a single line
# indicating with different fields when the task will be run
# and what command to run for the task
#
# To define the time you can provide concrete values for
# minute (m), hour (h), day of month (dom), month (mon),
# and day of week (dow) or use \'*\' in these fields (for \'any\').#
# Notice that tasks will be started based on the cron\'s system
# daemon\'s notion of time and timezones.
#
# Output of the crontab jobs (including errors) is sent through
# email to the user the crontab file belongs to (unless redirected).
#
# For example, you can run a backup of all your user accounts
# at 5 a.m every week with:
# 0 5 * * 1 tar -zcf /var/backups/home.tgz /home/
#
# For more information see the manual pages of crontab(5) and cron(8)
#
# m h  dom mon dow   command
# */1 * * * * date >> /www/loveDove/www_admin_com/App/Runtime/Logs/Cli/date.log
*/1 * * * * /www/aabb/ccdd/App/Cli/Sh/MessageQueue/index.sh
# 如果上诉不能执行，用标准的绝对sh命令的进行执行
*/1 * * * * /bin/sh /www/aabb/ccdd/App/Cli/Sh/MessageQueue/index.sh

最后设置完成，则可以进行定时任务了，亲测有效。