文档章节

Swoole入门(4)☞创建毫秒级定时器

ali安东尼
 ali安东尼
发布于 2017/09/12 14:51
字数 801
阅读 4
收藏 0
点赞 0
评论 0

###crontab服务 VS 基于swoole的定时器

一般开发者都是使用linux自带的crontab定时处理服务,crontab服务够稳定,有日志,基于服务器,非常好用;但是有个缺点就是只支持分钟时间级别的定时器。

而swoole的timer定时器完全可以弥补这个缺点,支持毫秒级的定时器,同时支持异步操作

###timer定时器

timer定时器基于Reactor线程,在Worker进程和Task进程使用。

timer定时器基于epoll的timeout机制实现。

timer定时器使用最小堆数据结构存放定时任务,触发时间越短越靠近堆顶,大大提高了检索效率。

###示例代码

    <?php          class Test     {         public $index = 0;     }          class Server     {         private $serv;         private $test;              public function __construct() {             $this->serv = new swoole_server("0.0.0.0", 9501);             $this->serv->set(array(                 'worker_num' => 8,                 'daemonize' => false,                 'max_request' => 10000,                 'dispatch_mode' => 2,             ));             $this->serv->on('Start', array($this, 'onStart'));             $this->serv->on('Connect', array($this, 'onConnect'));             $this->serv->on('Receive', array($this, 'onReceive'));             $this->serv->on('Close', array($this, 'onClose'));             $this->serv->on('WorkerStart', array($this, 'onWorkerStart'));                  $this->serv->start();         }         public function onStart( $serv ) {             echo "Start\n";         }         public function onConnect( $serv, $fd, $from_id ) {             echo "Client {$fd} connect\n";         }         public function onClose( $serv, $fd, $from_id ) {             echo "Client {$fd} close connection\n";         }              public function onWorkerStart( $serv , $worker_id) {             if( $worker_id == 0 )             {                 $this->test=new Test();                 $this->test->index = 1;                 swoole_timer_tick(1000, array($this, 'onTick'), "Hello");             }         }              public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {             echo "Get Message From Client {$fd}:{$data}\n";                        echo "Continue Handle Worker\n";         }              public function onTick($timer_id,  $params = null) {             echo "Timer {$timer_id} running\n";             echo "Params: {$params}\n";                          echo "Timer running\n";             echo "recv: {$params}\n";                  var_dump($this->test);         }     }          $server = new Server();

####代码输出     root:/var/www/html/silence/swoole/timer# php timer.php      Start     Timer 1 running     Params: Hello     Timer running     recv: Hello     object(Test)#5 (1) {       ["index"]=>       int(1)     }     Timer 1 running     Params: Hello     Timer running     recv: Hello     object(Test)#5 (1) {       ["index"]=>       int(1)     }

####代码流程

定时器在worker进程启动时就启动,因为不希望每个worker进程都启动该定时器,所以用了workerid进行判断,只在第一个worker进程中启动。

swoole_timer_tick(int $ms, callable $callback, mixed $user_param);

设置一个间隔时钟定时器,该定时器会一直持续触发,直到调用swoole_timer_clear清除该定时器。

$ms 指定时间,单位为毫秒

$callback_function 时间到期后所执行的函数,必须是可以调用的。

$user_param 可以传一些业务参数, 该参数会被传递到$callback_function中. 如果有多个参数可以使用数组形式。

注意:

定时器仅在当前进程空间内有效

定时器是纯异步实现的,不能与阻塞IO的函数(如sleep()函数)一起使用,否则定时器的执行时间会发生错乱

与其相对立的是swoole_timer_after()函数,还函数只会调用一次。

onTick($timer_id,  $params = null);上文中的定时器异步回调函数是该函数。

$timer_id 定时器的ID,可用于swoole_timer_clear清除此定时器

$params 由swoole_timer_tick传入的第三个参数

swoole_timer_clear(int $timer_id)是使用定时器ID来删除定时器。

$timer_id,定时器ID,调用swoole_timer_tick、swoole_timer_after后会返回一个整数的ID

swoole_timer_clear不能用于清除其他进程的定时器,只作用于当前进程

###结语

接下来继续给大家讲讲进程相关知识,同时学习对swoole进程的使用。

由睿江云人员提供,想了解更多,请登陆www.eflycloud.com

© 著作权归作者所有

共有 人打赏支持
ali安东尼
粉丝 3
博文 192
码字总数 173101
作品 0
广州
PHP的异步并行扩展Swoole发布1.7版本

Swoole 1.7.0 发布了,该版本主要改进内容包括: reactor线程与writer线程合并 对send优化,加入out_buffer机制 增加AIO异步读写文件的API 增加DNS异步查询函数 swooleclient在php-fpm或apa...

matyhtf ⋅ 2014/04/17 ⋅ 39

Swoole入门指南:PHP7安装Swoole详细教程

Swoole简介 Swoole是:PHP语言的高性能网络通信框架,提供了PHP语言的异步多线程服务器,异步TCP/UDP网络客户端,异步MySQL,数据库连接池,AsyncTask,消息队列,毫秒定时器,异步文件读写,...

阿泽Aze ⋅ 01/05 ⋅ 1

swoole-1.7.7 发布,Http 服务器性能大幅提升

swoole-1.7.7 发布,内置Http服务器性能是Node.js的12倍 PHP的异步并发扩展swoole发布了 1.7.7 版本,此版本主要有: 增加对cygwin环境的支持 增加单次定时器的after接口 onClose事件调整为在...

matyhtf ⋅ 2014/10/28 ⋅ 65

PHP 框架 Swoole

Swoole:重新定义PHP PHP语言的高性能网络通信框架,提供了PHP语言的异步多线程服务器,异步TCP/UDP网络客户端,异步MySQL,数据库连接池,AsyncTask,消息队列,毫秒定时器,异步文件读写,...

lilugirl ⋅ 2015/10/28 ⋅ 0

重新定义PHP : swool

使用PHP+Swoole作为网络通信框架,可以使企业IT研发团队的效率大大提升,更加专注于开发创新产品。 Swoole底层内置了异步非阻塞、多线程的网络IO服务器。PHP程序员仅需处理事件回调即可,无需...

旋转木马-千里马 ⋅ 2015/12/29 ⋅ 0

PHP的异步并行网络扩展Swoole已发布1.7.5版本

PHP的异步并行网络扩展Swoole今天发布了最新的1.7.5版本。 项目主页:http://www.swoole.com/ 文档页面:http://wiki.swoole.com/ 源代码:https://github.com/swoole/swoole-src 1.7.4版本:...

matyhtf ⋅ 2014/09/10 ⋅ 31

使用php开发,基于swoole扩展开发的工具--swoole-crontab

Swoole-Crontab(基于Swoole扩展) 1.概述 基于swoole的定时器程序,支持秒级处理. 异步多进程处理。 完全兼容crontab语法,且支持秒的配置,可使用数组规定好精确操作时间 单中心-多客户端模式...

ClownFish ⋅ 2014/12/29 ⋅ 2

花花世界欢乐多/swoole-worker

swoole-worker 关于本项目 此项目是workerman(v3.4.5)的swoole移植版本,移除了对pcntl,libevent,event,ev扩展的依赖,转而使用swoole提供的swooleprocess和swooleevent,定时器采用swoole的s...

花花世界欢乐多 ⋅ 2017/08/15 ⋅ 0

PHP并发IO编程之路

并发IO问题一直是后端编程中的技术挑战,从最早的同步阻塞Fork进程,到多进程/多线程,到现在的异步IO、协程。PHP程序员因为有强大的LAMP框架,对底层方面的知识知之甚少,本文目的就是详细介...

snowing1990 ⋅ 2016/03/24 ⋅ 0

常驻内存型 PHP 框架--easySwoole

EasySwoole 是一款基于Swoole Server 开发的常驻内存型PHP框架,专为API而生,摆脱传统PHP运行模式在进程唤起和文件加载上带来的性能损失。EasySwoole 高度封装了Swoole Server 而依旧维持S...

easySwoole ⋅ 2017/11/07 ⋅ 1

没有更多内容

加载失败,请刷新页面

加载更多

下一页

linux 安装docker

通过以下命令下载安装docker wget -qO- https://get.docker.com | sh 执行以上命令后输出以下内容说明安装成功,注意红框中的内容,docker安装成功后默认只有root能使用,红框中给出的提示是...

haoyuehong ⋅ 2分钟前 ⋅ 0

482. License Key Formatting - LeetCode

Question 482. License Key Formatting Solution 思路:字符串转化为char数组,从后遍历,如果是大写字母就转化为小写字母,如果是-就忽略,如果遍历了k个字符(排除-)就追加一个-。 Java实现...

yysue ⋅ 21分钟前 ⋅ 0

聊聊spring cloud gateway的LoadBalancerClientFilter

序 本文主要研究一下spring cloud gateway的LoadBalancerClientFilter GatewayLoadBalancerClientAutoConfiguration spring-cloud-gateway-core-2.0.0.RELEASE-sources.jar!/org/springfram......

go4it ⋅ 45分钟前 ⋅ 0

详解:Nginx反代实现Kibana登录认证功能

Kibana 5.5 版后,已不支持认证功能,也就是说,直接打开页面就能管理,想想都不安全,不过官方提供了 X-Pack 认证,但有时间限制。毕竟X-Pack是商业版。 下面我将操作如何使用Nginx反向代理...

问题终结者 ⋅ 52分钟前 ⋅ 0

002、nginx配置虚拟主机

一、nginx配置虚拟主机可分为三种方式,分别为: 1、基于域名的虚拟主机,通过域名来区分虚拟主机——应用:外部网站 2、基于端口的虚拟主机,通过端口来区分虚拟主机——应用:公司内部网站...

北岩 ⋅ 55分钟前 ⋅ 0

shell脚本之死循环写法

最近在学习写shell脚本,在练习if while等流程控制时,突然它们的死循环写法是怎么样的?经过百度与亲测记录如下: for死循环 #! /bin/bashfor ((;;));do date sleep 1d...

hensemlee ⋅ 57分钟前 ⋅ 0

苹果的ARKit2.0有多可怕,看了就知道

序言 ARKit主要由三部分组成: 跟踪(Tracking) 跟踪是ARKit的核心组件之一,其提供了设备在物理世界中的位置与方向信息,并对物体进行跟踪,如人脸。 2.场景理解(Scene Understanding) 场...

_小迷糊 ⋅ 58分钟前 ⋅ 0

5.1 vim介绍 5.2 vim移动光标 5.3 ,5.4vim一般模式下移动光标,复制粘贴

vim命令 vim是vi的一个升级版;vim可以显示文字的颜色 安装vim这一个包vim-enhanced 如果不知道安装包,可以使用 命令下面命令来查看vim命令是那个包安装的。 [root@linux-128 ~]# yum prov...

Linux_老吴 ⋅ 今天 ⋅ 0

vim一般模式

vim 是什么 vim是什么 ? 在之前接触Linux,编辑网卡配置文件的时候我们用过了vi ,vim简单说就是vi的升级版,它跟vi一样是Linux系统中的一个文本编辑工具。 如果系统中没有vim ,需要安装一...

李超小牛子 ⋅ 今天 ⋅ 0

docker实战

构建企业级Docker虚拟化平台实战 重点剖析虚拟化和云计算概念; 分析Docker虚拟化的概念和原理; 从0开始实战Docker虚拟化平台; 基于Docker构建Nginx WEB服务器和CentOS虚拟机; 基于开源监...

寰宇01 ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部