swoole 清除定时器提示no timer

Posted 2020-08-18

首页确定一个核心概念

clearTimer仅可清除当前进程的定时器

server代码如下：

<?php
class Server
{
    private $serv;
    private $timer;

    public function __construct()
    {
        $this->serv = new swoole_server("0.0.0.0", 9501);
        $this->serv->set([
            'worker_num' => 8,
            'daemonize' => false,
        ]);

        $this->serv->on('Start', [$this, 'onStart']);
        $this->serv->on('Connect', [$this, 'onConnect']);
        $this->serv->on('Receive', [$this, 'onReceive']);
        $this->serv->on('Close', [$this, 'onClose']);

        $this->serv->start();
    }

    public function onStart($serv)
    {
        $this->echoStr("Server Starting");
        $this->timer = $serv->tick(1000, function(){
            $this->echoStr("timer waiting");
        });
        // $this->timer = swoole_timer_tick(1000, function() {
        // });
    }

    public function onConnect($serv, $fd, $from_id)
    {
        // swoole_timer_clear($this->timer);
        $serv->clearTimer($this->timer);
        $this->echoStr("Connecting! Clear Timer!");
        // $serv->send($fd, "Hello {$fd}!");
    }

    public function onReceive(swoole_server $serv, $fd, $from_id, $data)
    {
        $this->echoStr("Get Message From Client {$fd}:{$data}");
        $serv->send($fd, $data);
    }

    public function onClose($serv, $fd, $from_id)
    {
        $this->echoStr("Client {$fd} close connection");
    }

    public function echoStr($msg)
    {
        echo '[' . date('Y-m-d H:i:s') . ']: ' . $msg . PHP_EOL;
    }
}
// 启动服务器 Start the server
$server = new Server();

本意图实现server启动后循环输出“timer waiting”，client连接后清除定时器的效果，然而onStart事件是在Master进程的主线程中被调用，而onConnect事件是在work进程中被回调，这里不属于同一进程，故client连接后会提示：

PHP Warning: SwooleServer::clearTimer(): no timer...

原文地址：https://segmentfault.com/a/1190000016558928