PHP中Swoole怎么做毫秒定时计划任务-群英
首页
产品
数据中心
行业资讯
最新更新
关于我们
登录
注册有礼
资讯首页
服务器
数据库
开发技术
网络安全
网络推广
互联网资讯
云安全
高防云
HOT
立体智能护盾、T级高防御、海量清洗
高防服务器
抗D防C，多线接入互联互通
高防IP
源IP隐形防护、多层防御体系、定制式防护
智防系统
HOT
新型云防、无限DDos防御、智能CC防御
云计算
裸金属
HOT
物理性能，云上资源
鹰云•性价王
HOT
快速稳定，高性价比
鹰云服务器
弹性伸缩，按需选购
租用托管
服务器租用
T级带宽，独立机房
服务器托管
资深工程师专业运维，稳定可靠
海外服务器租用
HOT
国际优质带宽资源，访问快
大带宽租用
高品质网络环境，T级充足带宽
机柜租用
省骨干网络，尊贵VIP运维服务
域名主机
域名注册
双认证域名注册商
虚拟主机
多功能性空间主机
广东精品数据中心
广东高速数据中心
广州BGP数据中心
广州大学城BGP数据中心
深圳BGP数据中心
华北BGP数据中心
华东高速数据中心
华中云数据中心
南宁二枢纽
您现在的位置是：群英 >
开发技术 >
PHP语言
PHP中Swoole怎么做毫秒定时计划任务
Admin发表于 2022-08-24 16:47:15148 次浏览
关于“PHP中Swoole怎么做毫秒定时计划任务”的知识点有一些人不是很理解，对此小编给大家总结了相关内容，文中的内容简单清晰，易于学习与理解，具有一定的参考学习价值，希望能对大家有所帮助，接下来就跟随小编一起学习一下“PHP中Swoole怎么做毫秒定时计划任务”吧。
项目开发中，如果有定时任务的业务要求，我们会使用linux的crontab来解决，但是它的最小粒度是分钟级别，如果要求粒度是秒级别的，甚至毫秒级别的，crontab就无法满足，值得庆幸的是swoole提供的强大的毫秒定时器。【推荐：PHP视频教程】应用场景举例我们可能会遇到这样的场景：场景一：每隔30秒获取一次本机内存使用率场景二：2分钟后执行报表发送任务场景三：每天凌晨2点钟定时请求第三方接口，如果接口有数据返回则停止任务，如果接口由于某种原因没有响应或者没有数据返回则5分钟后继续尝试请求该接口，尝试5次后仍然失败则停止该任务以上的三个场景我们都可以归纳为定时任务的范畴。Swoole毫秒定时器Swoole提供了异步毫秒定时器函数：swoole_timer_tick(int $msec, callable $callback)：设置一个间隔时钟定时器，每隔$msec毫秒执行一次$callback，类似于javascript中的setInterval()。swoole_timer_after(int $after_time_ms, mixed $callback_function)：在指定的时间$after_time_ms后执行$callback_function，类似于javascript的setTimeout()。swoole_timer_clear(int $timer_id)：删除指定id的定时器，类似于javascript的clearInterval()。解决方案对于场景一，经常用在系统检测统计方面，实时性要求比较高，但又能控制好频率，多用于后台服务器性能监控，可以生成可视化图表。可以是30秒获取一次内存使用率，也可以是10秒，而crontab最小粒度只能设置为1分钟。swoole_timer_tick(30000, function($timer) use ($task_id) { // 启用定时器，每30秒执行一次
$memPercent = $this->getMemoryUsage(); //计算内存使用率
echo date('Y-m-d H:i:s') . '当前内存使用率：'.$memPercent."\n";
});对于场景二，直接定义xx时间后执行某项任务的话，貌似crontab比较困难，而使用swoole的swoole_timer_after可以实现：swoole_timer_after(120000, function() use ($str) { //2分钟后执行
$this->sendReport(); //发送报表
echo "send report, $str\n";
});对于场景三，用来作尝试请求，请求失败后继续，如果成功则停止请求。用crontab也能解决，但是比较傻，比如设置每隔5分钟请求一次，不管成功会失败都会去执行一次。而用swoole定时器则智能多了。swoole_timer_tick(5*60*1000, function($timer) use ($url) { // 启用定时器，每5分钟执行一次
$rs = $this->postUrl($url);
if ($rs) {
//业务代码...
swoole_timer_clear($timer); // 停止定时器
echo date('Y-m-d H:i:s'). "请求接口任务执行成功\n";
} else {
echo date('Y-m-d H:i:s'). "请求接口失败，5分钟后再次尝试\n";
});示例代码新建文件\src\App\Task.php：namespace Helloweba\Swoole;
use swoole_server;
/**
* 任务调度
*/
class Task
protected $serv;
protected $host = '127.0.0.1';
protected $port = 9506;
// 进程名称
protected $taskName = 'swooleTask';
// PID路径
protected $pidPath = '/run/swooletask.pid';
// 设置运行时参数
protected $options = [
'worker_num' => 4, //worker进程数,一般设置为CPU数的1-4倍
'daemonize' => true, //启用守护进程
'log_file' => '/data/log/swoole-task.log', //指定swoole错误日志文件
'log_level' => 0, //日志级别 范围是0-5，0-DEBUG，1-TRACE，2-INFO，3-NOTICE，4-WARNING，5-ERROR
'dispatch_mode' => 1, //数据包分发策略,1-轮询模式
'task_worker_num' => 4, //task进程的数量
'task_ipc_mode' => 3, //使用消息队列通信，并设置为争抢模式
];
public function __construct($options = [])
date_default_timezone_set('PRC');
// 构建Server对象，监听127.0.0.1:9506端口
$this->serv = new swoole_server($this->host, $this->port);
if (!empty($options)) {
$this->options = array_merge($this->options, $options);
$this->serv->set($this->options);
// 注册事件
$this->serv->on('Start', [$this, 'onStart']);
$this->serv->on('Connect', [$this, 'onConnect']);
$this->serv->on('Receive', [$this, 'onReceive']);
$this->serv->on('Task', [$this, 'onTask']);
$this->serv->on('Finish', [$this, 'onFinish']);
$this->serv->on('Close', [$this, 'onClose']);
public function start()
// Run worker
$this->serv->start();
public function onStart($serv)
// 设置进程名
cli_set_process_title($this->taskName);
//记录进程id,脚本实现自动重启
$pid = "{$serv->master_pid}\\n{$serv->manager_pid}";
file_put_contents($this->pidPath, $pid);
//监听连接进入事件
public function onConnect($serv, $fd, $from_id)
$serv->send( $fd, "Hello {$fd}!" );
// 监听数据接收事件
public function onReceive(swoole_server $serv, $fd, $from_id, $data)
echo "Get Message From Client {$fd}:{$data}\n";
//$this->writeLog('接收客户端参数：'.$fd .'-'.$data);
$res['result'] = 'success';
$serv->send($fd, json_encode($res)); // 同步返回消息给客户端
$serv->task($data); // 执行异步任务
/**
* @param $serv swoole_server swoole_server对象
* @param $task_id int 任务id
* @param $from\id int 投递任务的worker_id
* @param $data string 投递的数据
*/
public function onTask(swoole_server $serv, $task_id, $from_id, $data)
swoole_timer_tick(30000, function($timer) use ($task_id) { // 启用定时器，每30秒执行一次
$memPercent = $this->getMemoryUsage();
echo date('Y-m-d H:i:s') . '当前内存使用率：'.$memPercent."\n";
});
/**
* @param $serv swoole_server swoole_server对象
* @param $task_id int 任务id
* @param $data string 任务返回的数据
*/
public function onFinish(swoole_server $serv, $task_id, $data)
//
// 监听连接关闭事件
public function onClose($serv, $fd, $from_id) {
echo "Client {$fd} close connection\n";
public function stop()
$this->serv->stop();
private function getMemoryUsage()
// MEMORY
if (false === ($str = @file("/proc/meminfo"))) return false;
$str = implode("", $str);
preg_match_all("/MemTotal\s{0,}\:+\s{0,}([\d\.]+).+?MemFree\s{0,}\:+\s{0,}([\d\.]+).+?Cached\s{0,}\:+\s{0,}([\d\.]+).+?SwapTotal\s{0,}\:+\s{0,}([\d\.]+).+?SwapFree\s{0,}\:+\s{0,}([\d\.]+)/s", $str, $buf);
//preg_match_all("/Buffers\s{0,}\:+\s{0,}([\d\.]+)/s", $str, $buffers);
$memTotal = round($buf[1][0]/1024, 2);
$memFree = round($buf[2][0]/1024, 2);
$memUsed = $memTotal - $memFree;
$memPercent = (floatval($memTotal)!=0) ? round($memUsed/$memTotal*100,2):0;
return $memPercent;
}我们以场景一为例，在onTask启用定时任务，每隔30秒计算一次内存使用率。实际应用中可以把计算好的内存按时间写入数据库等存储中，然后可以根据前端需求用来渲染成统计图表，如：接着服务端代码 public\taskServer.php ：<?php
require dirname(__DIR__) . '/vendor/autoload.php';
use Helloweba\Swoole\Task;
$opt = [
'daemonize' => false
];
$ser = new Task($opt);
$ser->start();客户端代码 public\taskClient.php :<?php
class Client
private $client;
public function __construct() {
$this->client = new swoole_client(SWOOLE_SOCK_TCP);
public function connect() {
if( !$this->client->connect("127.0.0.1", 9506 , 1) ) {
echo "Error: {$this->client->errMsg}[{$this->client->errCode}]\n";
fwrite(STDOUT, "请输入消息 Please input msg：");
$msg = trim(fgets(STDIN));
$this->client->send( $msg );
$message = $this->client->recv();
echo "Get Message From Server:{$message}\n";
$client = new Client();
$client->connect();验证效果1.启动服务端：php taskServer.php2.客户端输入：另开命令行窗口，执行[root@localhost public]# php taskClient.php请输入消息 Please input msg：helloGet Message From Server:{"result":"success"}
[root@localhost public]#3.服务端返回：如果返回上图中的结果，则定时任务正常运行，我们会发现每隔30秒会输出一条信息。现在大家对于PHP中Swoole怎么做毫秒定时计划任务的内容应该都清楚了吧，希望大家阅读完这篇文章能有所收获。最后，想要了解更多PHP中Swoole怎么做毫秒定时计划任务的知识，欢迎关注群英网络，群英网络将为大家推送更多相关知识点的文章。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：mmqy2019@163.com进行举报，并提供相关证据，查实之后，将立刻删除涉嫌侵权内容。
标签：
php
上一篇： 怎么使用PHP数据库迁移工具“Phinx”
下一篇： 怎么对PHP排序稳定性问题的深思
相关信息推荐
Java常用代码段你都了解多少？
2022-02-08 20:09:45　
摘要：这篇文章给大家分享的是Java常用代码段。小编觉得挺实用的，因此分享给大家做个参考，文中的示例代码介绍得很详细，有需要的朋友可以参考，接下来就跟随小编一起了解看看吧。
C语言中的输出格式如何定义为长整形
2022-10-13 17:45:08　
摘要：在C语言中，长整型的输出格式为“printf("%ld",元素);”。函数在输入输出的时候都有一个参数为格式化字符串, 当需要输入输出变量值时，就需要用对应的格式化字符来替代，其中“%ld”表示数据按十进制有符号长型整数输入或输出。
Android实现保存QQ账号和密码的方法是什么
2022-05-17 11:49:37　
摘要：大家好，我是汤姆凯特。写在前面：今天用保存qq账号和密码的实战演练，带大家掌握android存储中最基本的文件存储方式文件存储是android中最基本的一种数据存储方式，它与java中的文件存储类似，
推荐内容
PHP中替换第一位字符的方法和代码是什么 2022-12-14 11:21:38
Python使用中有哪些高效、实用的高级技巧 2022-08-19 17:53:01
新手学习Python有哪些关键字要掌握 2022-08-19 17:51:59
热门关键词
php生成器
php魔术方法
php字符串转大写
php判断数组中空值
php数组去掉0
php替换字符
php数组键值对
php对象转索引数组
php数组只保留键名
php去除字符
php去掉大写字母
php字符串转小写
php去掉回车符
php剔除字符串后
php字符串判断
php增加数组元素
php最大和最小值
php数组去重
php数组求交集
php关联数组
php求数组最小值
php查询结果
php无法修改数据库
php v版本不正确
php函数加减乘除
php pdo错误
php返回json
php警告变量
php特点
ubuntu不解析php
热门信息
Python怎么样创建txt文件，写入方法是什么？ 2022-01-24 19:23:44
pycharm怎么完全卸载？两个步骤帮你搞定 2022-01-04 18:53:44
Java中map判断是否存在key怎样做？教你两个方法 2022-01-26 18:39:38
Python中如何求阶乘？教你四个方法 2022-02-25 17:19:26
Python中怎样利用while求1到100的和？ 2021-11-20 17:46:01
Java中string转date有哪些方式，怎样实现？ 2022-01-18 18:00:09
用python如何读取csv文件，你知道几种方法？ 2021-11-22 17:53:55
laravel下怎样设置、获取和删除缓存，方法是什么？ 2021-11-29 17:58:44
python中怎样统计元素出现的次数，方法有哪些？ 2021-11-20 17:45:40
Python将数据写入txt的操作步骤是什么？ 2022-01-29 17:58:22
群英网络助力开启安全的云计算之旅
立即注册，领取新人大礼包
专业资深工程师驻守
7X24小时极速响应
一站式无忧技术支持
免费备案服务
产品服务
鹰云•性价王
鹰云服务器
裸金属
高防云
高防服务器
高防IP
智防系统
帮助文档
备案中心
行业资讯
关于我们
群英网络简介
公司动态
联系我们
联系我们
24小时售后：4006784567
24小时TEL ：0668-2555666
售前咨询TEL：400-678-4567
官方微信
官方微信
Copyright © QY Network Company Ltd. All Rights Reserved. 2003-2019 群英网络 版权所有 茂名市群英网络有限公司
增值电信经营许可证 : B1.B2-20140078 粤ICP备09006778号
免费拨打 400-678-4567 或 0668-2555555
返回顶部