Swoole入门 - 毫秒定时器

常规定时器基于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服务


启动HTTP服务

启动WebSocket服务


启动WebSocket服务

在控制台可以看到,客户端先接收到服务端返回的日期,5秒后在接收到服务端返回的server-time-after字符串。
但是在服务端代码中,返回日期的代码逻辑是写在返回server-time-after字符串的后边的,这是因为swoole实现了task任务的异步处理,不用等5秒逻辑执行完才执行后边的逻辑。

1、当websocket服务端连接到websocket客户端后,每隔两秒输出一次定时器ID。


5秒等待

2、Websocket服务端接收到客户端的数据5秒后打印5s-after,并给客户端发送消息。


5s结束

每隔2s执行

注意:在swoole_timer_after()函数中使用到了PHP的闭包,不懂可以查阅官方文档。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容