diff --git a/web/ws_task_real.php b/web/ws_task_real.php index 1d41eb9..b9271db 100644 --- a/web/ws_task_real.php +++ b/web/ws_task_real.php @@ -13,6 +13,7 @@ require_once __DIR__ . '../../source/application/common.php'; $config = require_once __DIR__ . '../../source/application/database.php'; $worker = new Worker('websocket://0.0.0.0:2000'); +$worker->count = 4; // 进程启动后定时推送数据给客户端 $worker->onWorkerStart = function($worker) use($config) { # 数据库链接不能在主进程,方法外是主进程 @@ -21,9 +22,13 @@ $worker->onWorkerStart = function($worker) use($config) { $time_interval = 3; Timer::add($time_interval, function()use($worker,$dm){ foreach($worker->connections as $connection) { + $data = []; $passData = PassFlow::realTimeData($dm); $returnData = ['data' => $passData]; - $connection->send(json_encode($returnData)); + $data['realTimeData'] = $returnData; + $toDayGroupsEnterNum = PassFlow::toDayGroupsEnterNum($dm); + $data['toDayGroupsEnterNum'] = $toDayGroupsEnterNum; + $connection->send(json_encode($data)); } }); };