在项目开发中，如果业务有定时任务的需求，我们会使用linux的crontab来解决，但是它的最小粒度是分钟级的。如果要求的粒度在秒级，即使是毫秒级，crontab也无法满足。好在swoole提供的强大的毫秒定时器。应用场景举例我们可能会遇到这样的场景：场景一：每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();//计算内存使用echodate('Y-m-dH:i:s').'当前内存使用情况：'.$memPercent."\n";});对于场景2，如果直接定义xx时间执行某项任务，貌似crontab比较难，但是使用swoole_timer_after可以实现：swoole_timer_after(120000,function()use($str){//Executeafter2minutes$this->sendReport();//发送报告echo"sendreport,$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);//停止定时器echodate('Y-m-dH:i:s')."请求接口任务执行成功\n";}else{echodate('Y-m-dH:i:s')."请求接口失败，5分钟后重试\n";}});示例代码新建文件\src\App\Task.php：namespaceHelloweba\Swoole；使用swoole_server；/***任务调度*/classTask{protected$serv;受保护的$host='127.0.0.1';受保护的$port=9506;//进程名称protected$taskName='swooleTask';//PID路径受保护$pidPath='/runswooletask.pid';//设置运行时参数protected$options=['worker_num'=>4,//worker进程数，一般设置为CPU数的1-4倍'daemonize'=>true,//启用daemonProcess'log_file'=>'/data/log/swoole-task.log',//指定swoole错误日志文件'log_level'=>0,//日志级别范围为0-5,0-DEBUG,1-TRACE,2-信息，3-通知，4-警告，5-ERROR'dispatch_mode'=>1,//包分发策略，1-pollingmode'task_worker_num'=>4,//任务进程数'task_ipc_mode'=>3,//使用消息队列通信，并设置为scramble模式];公共函数__construct($options=[]){date_default_timezone_set('PRC');//构造一个Server对象，监听127.0.0.1:9506端口$this->server=newswoole>($this->serv=newswoole>host,$this->port);如果(!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('接收',[$this,'onReceive']);$this->serv->on('Task',[$this,'onTask']);$this->serv->on('完成',[$this,'onFinish']);$this->serv->on('关闭',[$this,'onClose']);}publicfunctionstart(){//运行worker$this->serv->start();}publicfunctiononStart($serv){id//设置进程名cli_set_Nameprocess_titlesk/$this->process,ta脚本实现自动重启$pid="{$serv->master_pid}\\n{$serv->经理_pid}”；file_put_contents($this->pidPath,$pid);}}//监听连接入口事件publicfunctiononConnect($serv,$fd,$from_id){$serv->send($fd,"Hello{$fd}!");}//监听数据接收事件publicfunctiononReceive(swoole_server$serv,$fd,$from_id,$data){echo"GetMessageFromClient{$fd}:{$data}\n";//$this->writeLog('接收客户端参数：'.$fd.'-'.$data);$res['结果']='成功';$serv->send($fd,json_encode($res));//同步返回消息给客户端$serv->task($data);//异步执行任务}/***@param$servswoole_serverswoole_serverobject*@param$task_idinttaskid*@param$from\idint下发任务的worker_id*@param$datastring下发数据*/publicfunctiononTask(swoole_server$serv,$task_id,$from_id,$data){swoole_timer_tick(30000,function($timer)use($task_id){//启用定时器并每30秒执行一次$memPercent=$this->getMemoryUsage();echodate('Y-m-dH:i:s').'Currentmemoryusage:'.$memPercent."\n";});}/***@param$servswoole_serverswoole_serverobject*@param$task_idint任务id*@param$datastring任务返回数据*/publicfunctiononFinish(swoole_server$serv,$task_id,$data){//}}//监听连接关闭事件publicfunctiononClose($serv,$fd,$from_id){echo"Client{$fd}closeconnection\n";{}publicfunction$)stop(this->serv->stop();}privatefunctiongetMemoryUsage(){//MEMORYif(false===($str=@file("/proc/meminfo")))返回假；$str=内爆("",$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)?回合（$memUsed/$memTotal*100,2）：0；返回$memPercent；我们以场景一为例，在onTask中开启定时任务，每30秒计算一次内存占用在实际应用中，可以将计算出来的内存按照时间写入数据库等存储，然后根据前端的需求，用来渲染统计图表，比如：那么服务端代码public\taskServer.php:false];$ser=新任务($opt);$ser->start();客户端代码public\taskClient.php:client=newswoole_client(SWOOLE_SOCK_TCP);}publicfunctionconnect(){这个连接！lient->if(("127.0.0.1",9506,1)){echo"错误:{$this->client->errMsg}[{$this->client->errCode}]\n";}}fwrite(STDOUT,"请输入信息请输入信息：");$msg=trim(fgets(STDIN));$this->client->send($msg);$message=$this->client->recv();echo"从服务器获取消息:{$message}\n";}}$client=newClient();$客户端->连接（）；验证效果1.启动服务器：phptaskServer.php2。客户端输入：打开另一个命令行窗口，执行[root@localhostpublic]#phptaskClient.phpPleaseinputmessagePleaseinputmsg:helloGetMessageFromServer:{"result":"success"}[root@localhostpublic]#3.服务端返回：如果返回上图的结果，说明定时任务运行正常，我们会发现每隔30秒就会输出一条消息。更多学习内容，可以访问【BandmarkingFactory】精品PHP架构师教程目录很全，只要看得懂保证你的薪水更上一层楼（持续更新中），以上内容希望大家帮助大家。很多PHPer在进阶的时候总会遇到一些问题和瓶颈，业务代码写多了没有方向。我不知道从哪里开始改进。我整理了一些资料，包括但不限于：分布式架构、高扩展性、高性能、高并发、服务器性能调优、TP6、laravel、YII2、Redis、Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、需要进阶干货的微服务、Nginx等知识点免费分享给你，点击链接获取进阶PHP月薪30k>>>架构师成长之路【免费获取视频和面试资料】
