应用篇：2.延时任务

// 我们定义一个abstract，定义两个方法，startAfter和startAt
<?php

abstract class DelayTask
{
    const DELAY_TASK = 'delayTask';
    /**
     * 延时时间，在触发时间后多久执行
     * @param $pushDelayTime
     */
    public function startAfter(int $pushDelayTime)
    {
        RedisManager::getRedis()->zAdd(self::DELAY_TASK, time() + $pushDelayTime, serialize($this));
    }
    /**
     * 定时时间，在未来某时刻执行
     * @param $pushDelayAt
     */
    public function startAt(int $pushDelayAt)
    {
        RedisManager::getRedis()->zAdd(self::DELAY_TASK, $pushDelayAt, serialize($this));
    }
    abstract function run();
}


class TestDelayTask extends DelayTask
{
    public function __construct($id)
    {
        $this->id = $id;
    }
    public function run()
    {
        $file  = 'text.txt';//要写入文件的文件名（可以是任意文件名），如果文件不存在，将会创建一个
        $content = "写入的内容".time()."\n";
        if($f = file_put_contents($file, $content,FILE_APPEND)){// 这个函数支持版本(PHP 5)
            echo "写入成功。<br />";
        }
    }
}

<?php

class RedisManager
{
    private static $instance = null;
    private function __construct()
    {
        self::$instance = new \Redis();
        $config = require 'Redis.config.php';
        self::$instance->connect($config['host'], $config['port'], $config['timeout']);
        if (isset($config['password'])) {
            self::$instance->auth($config['password']);
        }
    }
    /**
     * 获取静态实例
     */
    public static function getRedis()
    {
        if (!self::$instance) {
            new self;
        }
        return self::$instance;
    }
    /**
     * 禁止clone
     */
    private function __clone()
    {
    }
}

Redis 127.0.0.1:6379> ZADD saif 1 Redis
(integer) 1
Redis 127.0.0.1:6379> ZADD saif 2 mongodb
(integer) 1
Redis 127.0.0.1:6379> ZADD saif 4 mysql
(integer) 0
Redis 127.0.0.1:6379> ZRANGE saif 0 10 WITHSCORES

1) "Redis"
2) "1"
3) "mongodb"
4) "2"
5) "mysql"
6) "4"

我们先尝试写入任务：

(new TestDelayTask(4))->startAfter(900);
(new TestDelayTask(4))->startAfter(120);
(new TestDelayTask(4))->startAfter(600);
(new TestDelayTask(3))->startAt(158120384);
(new TestDelayTask(3))->startAt(158420380);
(new TestDelayTask(3))->startAt(158120900);

class DelayTaskTask
{
    const QueneName = 'delayTask';
    private $currentTime;
    private $once = 5;
    public function run()
    {
        $this->currentTime = time();
        error_reporting(error_reporting() & ~E_WARNING);
        while (true) {
            // 每次取出5条
            $list = RedisManager::getRedis()->zRange(self::QueneName, 0, $this->once, true);
            if (!empty($list)) {
                foreach ($list as $val=>$score) {
                    if ($score < $this->currentTime) {
                        unserialize($val)->run();
                        RedisManager::getRedis()->zDelete(self::QueneName, $val);
                    } else {
                        break 2;
                    }
                }
            } else {
                break;
            }
        }
    }
}
(new DelayTaskTask())->run();