$worker = new Worker(); $worker->count = 100; $worker->onWorkerStart = function ($worker) { $client = Test::getServer(); // 订阅 $id = $worker->id; $client->subscribe("task-{$id}", function(...