PHP使用Redis队列执行定时任务实例讲解

前言

定时任务是Web应用中常用的功能之一，例如发邮件、生成报表等等需要定时执行的任务。在执行定时任务时通常会使用到队列，常见的队列有RabbitMQ、Kafka、Redis等等。而本文主要介绍如何使用Redis队列来执行定时任务。

环境准备

在使用Redis队列前需要确保已经安装了Redis，可以使用redis-cli ping来测试Redis服务是否正常启动。

在本文中使用到的PHP版本为7.1，并且需要安装Redis扩展：pecl install redis。

实现思路

我们的思路是使用定时任务来轮询Redis队列，当有任务需要执行时，将任务从队列中取出并执行。

代码中使用到了PHP的Redis扩展和Symfony的Console组件来实现命令行运行。首先编写一个命令行命令，定时轮询Redis队列并执行任务。

<?php

require __DIR__.'/vendor/autoload.php';

use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Predis\Client;

class ExecuteCommand extends Command {
    private $redis;
    private $queueName;

    public function __construct() {
        parent::__construct();
        $this->redis = new Client();
        $this->queueName = 'task_queue';
    }

    protected function configure() {
        $this->setName('execute')
            ->setDescription('Execute a task');
    }

    protected function execute(InputInterface $input, OutputInterface $output) {
        while(true) {
            $task = $this->redis->rpop($this->queueName);
            if($task) {
                /// 执行任务
                $output->writeln($task);
            }
            sleep(1);
        }
    }
}

$command = new ExecuteCommand();
$command->run();

上面的代码中通过Predis类连接到了Redis服务器并从task_queue队列中取出了任务并执行。注意以上代码只是一个轮询函数，需要和其他代码搭配使用才能实现完整的定时任务。

示例1：网站报警

假设我们的Web应用需要每5分钟检测一次网站状态，如果发现网站无法提供服务则需要发出报警。我们可以将每次检测的任务放入到Redis队列中，并使用上面的代码轮询队列并执行任务。

代码如下：

<?php

require __DIR__.'/vendor/autoload.php';

use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Predis\Client;

class ExecuteCommand extends Command {
    private $redis;
    private $queueName;

    public function __construct() {
        parent::__construct();
        $this->redis = new Client();
        $this->queueName = 'task_queue';
    }

    protected function configure() {
        $this->setName('execute')
            ->setDescription('Execute a task');
    }

    protected function execute(InputInterface $input, OutputInterface $output) {
        while(true) {
            $task = $this->redis->rpop($this->queueName);
            if($task) {
                /// 执行任务
                // 模拟检测网站状态的代码
                $status = rand(0, 1);
                if($status === 0) {
                    $this->redis->lpush('alarm_queue', 'Website is down at ' . date('Y-m-d H:i:s'));
                }
            }
            sleep(1);
        }
    }
}

$command = new ExecuteCommand();
$command->run();

在上面的代码中，我们使用rand()方法模拟了网站检测的功能，当发现网站不可用时将报警信息推送到Redis的alarm_queue队列中。下面是如何将报警信息推送到队列中：

<?php

require __DIR__.'/vendor/autoload.php';

use Predis\Client;

$redis = new Client();
$redis->lpush('task_queue', 'Check website status');

以上代码中，Check website status是一个需要定时执行的任务，并且需要检测网站状态并给出相应的报警信息。通过将任务放入队列中以达到定时执行的目的。

示例2：发送邮件

假设需要定时给用户发送邮件，可以将每次发送邮件的任务放入Redis队列中，并使用上面的代码轮询队列并执行任务。

代码如下：

<?php

require __DIR__.'/vendor/autoload.php';

use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Predis\Client;

class ExecuteCommand extends Command {
    private $redis;
    private $queueName;

    public function __construct() {
        parent::__construct();
        $this->redis = new Client();
        $this->queueName = 'task_queue';
    }

    protected function configure() {
        $this->setName('execute')
            ->setDescription('Execute a task');
    }

    protected function execute(InputInterface $input, OutputInterface $output) {
        while(true) {
            $task = $this->redis->rpop($this->queueName);
            if($task) {
                /// 执行任务
                // 模拟发送邮件的代码
                $email = '[e-mail]';
                $title = 'Test email';
                $body = 'This is a test email';
                mail($email, $title, $body);
            }
            sleep(1);
        }
    }
}

$command = new ExecuteCommand();
$command->run();

在上面的代码中，我们使用PHP内置函数mail()模拟了发送邮件的功能，当发现需要发送邮件的任务时就执行邮件发送代码。下面是如何将发送邮件的任务添加到队列中：

<?php

require __DIR__.'/vendor/autoload.php';

use Predis\Client;

$redis = new Client();
$redis->lpush('task_queue', 'Send email');

以上代码中，Send email是一个每次都需要执行的任务，并且需要定时发送邮件给用户。通过将任务放入队列中以达到定时执行的目的。

总结

通过以上两个示例，我们可以看到如何使用Redis队列来实现定时任务。具体实现时，只需要将每次需要执行的任务放入队列中，在后台启动轮询程序不断地从队列中取出任务并执行即可。