Swoole非同步毫秒定時器
阿新 • • 發佈：2018-12-04
【使用函式】
swoole_timer_tick：設定一個間隔時鐘定時器。
swoole_timer_after：在指定的時間後執行函式（1.7.7以上）。
swoole_timer_clear：通過定時器ID刪除定時器。
【示例】
以建立一個WebSocket服務設定定時器為例：
ws_server.php：
<?php class Ws { public $ws = null; public function __construct() { $this->ws = new swoole_websocket_server("0.0.0.0", 9501); $this->ws->on("open", [$this, 'onOpen']); $this->ws->on("message", [$this, 'onMessage']); $this->ws->on("close", [$this, 'onClose']); $this->ws->start(); } //建立連接回調 public function onOpen($ws, $request) { echo "標識{$request->fd}建立了連線\n"; //每2秒執行定時器one $timer_one = swoole_timer_tick(2000, function($timer_id) use($request) { echo "標識{$request->fd}執行了定時器one,定時器ID:{$timer_id}\n"; }); //6秒後執行定時器two 刪除定時器one ($timer_one為定時器one的timer_id) $timer_two = swoole_timer_after(6000, function () use($timer_one, $request) { $res = swoole_timer_clear($timer_one);//刪除定時器 返回bool型別 if($res==true){ echo "標識{$request->fd}執行了定時器two,清除了定時器ID:{$timer_one}\n"; } }); } //接受訊息回撥 public function onMessage($ws, $frame) { //伺服器返回 echo "伺服器傳送訊息:{$frame->data}\n"; } //關閉連接回調 public function onClose($ws, $fd) { echo "{$fd}關閉了連線\n"; } } $obj = new Ws();
前端頁面js監聽：
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> <html xmlns="http://www.w3.org/1999/xhtml"> <head> <title>WebSocket</title> </head> <body> </body> <script type="text/javascript"> var websocket = new WebSocket('ws://127.0.0.1:9501'); websocket.onopen = function (evt) { onOpen(evt) }; websocket.onclose = function (evt) { onClose(evt) }; websocket.onmessage = function (evt) { onMessage(evt) }; websocket.onerror = function (evt) { onError(evt) }; function onOpen(evt) { console.log("Connected to WebSocket server."); //*傳送訊息到websocket伺服器 websocket.send('666'); } function onClose(evt) { console.log("Disconnected"); } function onMessage(evt) { console.log('Retrieved data from server: ' + evt.data); } function onError(evt) { console.log('Error occured: ' + evt.data); } </script> </html>
開啟WebSocket服務：
php ws_server.php重新整理頁面，WebSocket伺服器監聽結果：
（伺服器會先返回訊息給客戶端，然後再執行定時器）