常规定时器基于linux的crontab来实现,无法满足毫秒级、秒级处理任务的场景。
swoole提供了类似JavaScript的setInterval/setTimeout异步高精度定时器Timer,粒度为毫秒级。使用也非常简单。
在同步进程中使用setitimer和信号实现,如Manager和TaskWorker进程;
在异步进程中使用epoll_wait/kevent/poll/select超时时间实现。
函数列表
//每隔2000ms触发一次
swoole_timer_tick(2000, function ($timer_id) {
echo "tick-2000ms\n";
});
//3000ms后执行此函数
swoole_timer_after(3000, function () {
echo "after 3000ms.\n";
});
swoole_timer_tick函数就相当于setInterval,是持续触发的
swoole_timer_after函数相当于setTimeout,仅在约定的时间触发一次
swoole_timer_tick和swoole_timer_after函数会返回一个整数,表示定时器的ID
可以使用 swoole_timer_clear 清除此定时器,参数为定时器ID
性能
底层使用最小堆数据结构实现定时器,定时器的添加和删除,全部为内存操作,因此性能是非常高的。官方的基准测试脚本 https://github.com/swoole/swoole-src/blob/master/benchmark/timer.php 中,添加或删除10万
个随机时间的定时器耗时为0.08s
左右。
定时器是内存操作,无IO消耗
~/workspace/swoole/benchmark$ php timer.php
add 100000 timer :0.091133117675781s
del 100000 timer :0.084658145904541s
差异
Timer与PHP本身的pcntl_alarm是不同的。pcntl_alarm是基于时钟信号 + tick函数实现存在一些缺陷:
最大仅支持到秒,而Timer可以到毫秒级别
不支持同时设定多个定时器程序
pcntl_alarm依赖declare(ticks = 1),性能很差
零毫秒定时器
底层不支持时间参数为0的定时器。这与Node.js等编程语言不同。在Swoole里可以使用Swoole\Event::defer实现类似的功能。
Swoole\Event::defer(function () {
echo "hello\n";
});
上述代码与JS中的setTimeout(func, 0)效果是完全一致的。
示例
启动HTTP服务
启动WebSocket服务
在控制台可以看到,客户端先接收到服务端返回的日期,5秒后在接收到服务端返回的server-time-after字符串。
但是在服务端代码中,返回日期的代码逻辑是写在返回server-time-after字符串的后边的,这是因为swoole实现了task任务的异步处理,不用等5秒逻辑执行完才执行后边的逻辑。
1、当websocket服务端连接到websocket客户端后,每隔两秒输出一次定时器ID。
2、Websocket服务端接收到客户端的数据5秒后打印5s-after,并给客户端发送消息。
注意:在swoole_timer_after()函数中使用到了PHP的闭包,不懂可以查阅官方文档。