首页 > 其他 > 详细

swoole 定时器 swoole_time_tick 和 swoole_time_after

时间:2019-06-06 14:08:13      阅读:207      评论:0      收藏:0      [点我收藏+]
<?php

class myticker
{
public $server = null;
CONST host = ‘127.0.0.1‘;
CONST port = 9502;
public function __construct()
{
$this->server = new swoole_websocket_server(myticker::host,myticker::port);
$this->server->on(‘open‘,[$this,‘onopen‘]);
$this->server->on(‘message‘,[$this,‘onmessage‘]);
$this->server->on(‘close‘,[$this,‘onclose‘]);

$this->server->start();
}
public function onopen($serv,$request)
{
echo "接通!来自{$request->fd}的问候\n";
if ($request->fd==2)
{
swoole_timer_tick(3000,function($timer_id)
{
//swoole_timer_tick 表示每几秒执行一次操作,第一个参数精确到毫秒
//回调函数中的$timer_id用来标注识别定时器ID,这一定时器id还用于time::clear()清楚定时器
//回调函数中还可使用其他参数,只不过是可选的
echo "3秒后,{$timer_id}开始执行\n";
});
}
}

public function onmessage($serv,$frame)
{
echo "接到来自客户句柄----{$frame->fd}的问候,其操作类型为--{$frame->opcode},数据帧的完整状态{$frame->finish}\n";
swoole_timer_after(5000,function() use($serv,$frame){
echo "5秒后,返回客户端{$frame->fd}的数据{$frame->data}\n";
$serv->push("推送到达的时间".date(‘Y-m-d H:i:s‘)."\n");
});
$serv->push($frame->fd,$frame->data);
}
public function onclose($serv,$fd)
{
echo "关闭来自{$fd}的连接\n";
}
}
$cpc=new myticker();
?>

swoole 定时器 swoole_time_tick 和 swoole_time_after

原文:https://www.cnblogs.com/saintdingspage/p/10984523.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!