发表新帖

swoole 1.8+ tick里用mysql pdo句柄失效

请问峰哥，怎么用在以下方式加个定时器，谢谢，峰哥！！！！！
并在定时器里面用mysql pdo句柄！！！！！

程序如下：
{{{
class CollectLogServer
{
    public function __construct(){
         $this->serv = new swoole_server(xx,xx); //tcp,udp服务 这里是伪代码
         $this->serv->on('Start', array($this, 'onStart'));
        $this->serv->on('WorkerStart', array($this, 'onWorkerStart'));
        $this->serv->on('connect', array($this, 'onConnect'));
        $this->serv->on('Receive', array($this, 'onReceive'));
        $this->serv->on('Close', array($this, 'onClose'));
        $this->serv->on('Task', array($this, 'onTask'));
        $this->serv->on('Finish', array($this, 'onFinish'));
        $this->serv->on('Tick', array($this, 'onTick'));
        $this->serv->start();
    }

public function onTick($id,$serv)
    {
       //这里是要定时执行的任务
       $serv->pdo //峰哥 我这里获取不到mysql pdo句柄啊？？？？？
    }

public function onWorkerStart($serv, $worker_id)
    {
      
        if ($worker_id >= $serv->setting['worker_num']) {
            $serv->pdo = new \PDO(
                "mysql:host=127.0.0.1;port=3306;dbname=aa",
                "test",
                "1234",
                array(
                    \PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'UTF8';",
                    \PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION,
                    \PDO::ATTR_PERSISTENT => true
                )
            );
        } 
        if (!$serv->taskworker) {
            $serv->tick(4000,$this->onTick($worker_id,$serv));
        }

}
}

new CollectLogServer();
}}}

发布于6年前 · 0 次浏览 · 来自提问

用

用心看世界

swoole 1.8+ tick里用mysql pdo句柄失效

请问峰哥，怎么用在以下方式加个定时器，谢谢，峰哥！！！！！
并在定时器里面用mysql pdo句柄！！！！！

public function onTick($id,$serv)
    {
       //这里是要定时执行的任务
       $serv->pdo //峰哥 我这里获取不到mysql pdo句柄啊？？？？？
    }

}
}

new CollectLogServer();
}}}