【swoole】如果使用好定時器功能

swoole中提供了一個定期器的用法

$server->tick(1000, function() use ($server, $fd) {
        $server->send($fd, "hello world");
    });

開始的時候我是這么用的，看下代碼

<?php

$serv = new Swoole\Server("0.0.0.0", 9501);

$serv->set(array(
    'worker_num' => 1,    //worker process num
));

$serv->on('connect', function ($serv, $fd){
    echo "客戶端 ".$fd."連接成功 \n";
});
$serv->on('receive', function ($serv, $fd, $reactor_id, $data) {
    echo "客戶端 ".$fd."發來消息：".$data."\n";
    $serv->send($fd, 'Swoole已經介紹到您發送的消息: '.$data);
});
$serv->on('close', function ($serv, $fd) {
    echo "客戶端 {$fd}關閉連接\n";
});

$serv->on('WorkerStart', function ($serv, $worker_id){
    $serv->tick(2000, function(){
        echo "執行定時器任務 ".time()." \n";
    });
});

$serv->start();

開始使用定時器的時候我放到了 onWorkStart 中執行，這樣做的話可以保證在單個worker進程的情況下定時器可以正常運行，但是對於swoole來說讓它單進程工作顯然辱沒了它的 "才華" ，於是我將 work_num 設置為2 然后意外就發生啦,如圖

我們可以看到有兩個定期器在工作一個任務執行了相同的兩次，於是這種方法是不對的，當然我們可以在 onWorkStart 中通過判斷 worker_id 來避免這種情況，但是后來我發現其實還有另外一種相對來說好點的方法，就是使用 用戶自定義進程來做

bool Server->addProcess(Process $process);

代碼如下：

<?php

$serv = new Swoole\Server("0.0.0.0", 9501);

$serv->set(array(
    'worker_num' => 2,    //worker process num
));

//創建自定義進程
$process = new Swoole\Process(function($process) use ($serv) {
    $serv->tick(2000, function(){
        echo "執行定時器任務 ".time()." \n";
    });
});

$serv->addProcess($process);

$serv->on('connect', function ($serv, $fd){
    echo "客戶端 ".$fd."連接成功 \n";
});
$serv->on('receive', function ($serv, $fd, $reactor_id, $data) {
    echo "客戶端 ".$fd."發來消息：".$data."\n";
    $serv->send($fd, 'Swoole已經介紹到您發送的消息: '.$data);
});
$serv->on('close', function ($serv, $fd) {
    echo "客戶端 {$fd}關閉連接\n";
});

$serv->start();

執行效果：

ok！完美執行