<?PHP
$serv = new Swoole\Server("127.0.0.1",9502, SWOOLE_BASE);
 
$serv->set(array(
    'worker_num' => 2,'task_worker_num' => 4,1)">
));
 
$serv->on('Receive',1)">function(Swoole\Server $serv,$fd,1)">$from_id,1)">$data) {
    echo "接收数据" . $data . "\n";
    $data = trim();
    $task_id = $serv->task($data,0$serv->send($task_id\n");
});
 
$serv->on('Task',1)">function (Swoole\Server $task_id,1)">echo "Tasker进程接收到数据";
    echo "#{$serv->worker_id}\tonTask: [PID={$serv->worker_pid}]: task_id=strlen($data).".".PHP_EOL$serv->finish($serv->on('Finish',1)">echo "Task#$task_id finished,1)">$data).;
});
 
$serv->on('workerStart',1)">function($worker_idglobal $argvif($worker_id >= $serv->setting['worker_num']) {
        swoole_set_process_name("PHP {$argv[0]}: task_worker");
    } else {
        swoole_set_process_name("PHP {$argv[0]}: worker");
    }
});
 
$serv->start();