Timer定时器

框架对Swoole毫秒级定时器进行了封装，方便开发者快速上手。

循环执行

设置一个间隔时钟定时器，每隔一定的时间定时触发，直到进行 clear 操作才会停止，对应 Swoole 原生的定时器函数为 swoole_timer_tick

函数原型

/**
* 循环调用
* @param int      $ms 循环执行的间隔毫秒数 传入整数型
* @param \Closure $callback 定时器需要执行的操作 传入一个闭包
* @param string    $name 定时器名称,用于取消该定时器
* @param mixed ...$params 传入定时器的参数
* @return int 返回整数型的定时器编号 可以用该编号停止定时器
*/
public function loop(int $ms, callable $callback, $name = null, ...$params)

示例代码

// 每隔 10 秒执行一次
\EasySwoole\Component\Timer::getInstance()->loop(10 * 1000, function () {
    echo "this timer runs at intervals of 10 seconds\n";
});

延时执行

设置一个延时定时器，延时指定的时间后触发对应的操作，只会执行一次操作，对应Swoole 原生的定时器函数为 swoole_timer_after

函数原型

/**
* 延时调用
* @param int      $ms 需要延迟执行的时间
* @param \Closure $callback 定时器需要执行的操作 传入一个闭包
* @param mixed ...$params 传入定时器的参数
* @return int 返回整数型的定时器编号 
*/
public function after(int $ms, callable $callback, ...$params)

示例代码

// 10 秒后执行一次
\EasySwoole\Component\Timer::getInstance()->after(10 * 1000, function () {
    echo "ten seconds later\n";
});

清除定时器

定时器创建成功时，会返回一个整数型编号，调用本函数传入该编号，即可提前停止定时器，对应 Swoole 原生的定时器函数为 swoole_timer_clear

函数原型

/**
* 清除定时器
* @param mixed $timerIdOrName 定时器编号或名称
* @return bool
*/
public function clear($timerIdOrName)

示例代码

// 创建一个2秒定时器
$timerId = \EasySwoole\Component\Timer::getInstance()->loop(2 * 1000, function () {
    echo "timeout\n";
},'time');

// 清除该定时器
var_dump(\EasySwoole\Component\Timer::getInstance()->clear($timerId)); // bool(true)
var_dump($timerId); // int(1)

// 定时器得不到执行 不输出：timeout

应用实例

// 为第一个 Worker 添加定时器
if ($workerId == 0) {
    \EasySwoole\Component\Timer::getInstance()->loop(10 * 1000, function () {
        echo "timer in the worker number 0\n";
    });
}

public static function mainServerCreate(EventRegister $register)
{
    $register->add(EventRegister::onWorkerStart, function (\swoole_server $server, $workerId) {
        //如何避免定时器因为进程重启而丢失
        //例如在第一个进程 添加一个10秒的定时器
        if ($workerId == 0) {
            \EasySwoole\Component\Timer::getInstance()->loop(10 * 1000, function () {
                // 从数据库，或者是redis中，去获取下个就近10秒内需要执行的任务
                // 例如:2秒后一个任务，3秒后一个任务 代码如下
                \EasySwoole\Component\Timer::getInstance()->after(2 * 1000, function () {
                    //为了防止因为任务阻塞，引起定时器不准确，把任务给异步进程处理
                    Logger::getInstance()->console("time 2", false);
                });
                \EasySwoole\Component\Timer::getInstance()->after(3 * 1000, function () {
                    //为了防止因为任务阻塞，引起定时器不准确，把任务给异步进程处理
                    Logger::getInstance()->console("time 3", false);
                });
            });
        }
    });
}

经典案例-订单状态超时监控

场景说明：在很多抢购的场景中，订单下单完成后，需要限制其付款时间，或者是在棋牌游戏中，需要对房间状态进行监控。那么我们可以先把待监控的订单或者是房间压入redis 队列中。那么就可以利用 定时器 + 异步进程，去实现对订单状态的循环监控。