Swoole Advanced: サーバーの CPU 使用率を最適化する方法

$http = new swoole_http_server("0.0.0.0", 9501);

// 设置异步工作进程数
$http->set([
    'worker_num' => 4,
    'task_worker_num' => 2,
    'dispatch_mode' => 2,
]);

$http->on('Request', function (swoole_http_request $request, swoole_http_response $response) use ($http) {
    $response_server = "<h1>Hello World!</h1>";
    $http->task($response_server);
    $response->end($response_server);
});

$http->on('Task', function (swoole_http_server $server, $task_id, $from_id, $data) use ($http) {
    // 处理完任务后，将任务结果发送给Worker进程
    $http->finish($data);
});

$http->on('Finish', function (swoole_http_server $server, $task_id, $data) {
    echo "Task {$task_id} has finished, data={$data}
";
});

$http->start();

$http = new swoole_http_server("0.0.0.0", 9501);

// 设置多进程工作模式
$http->set([
    'worker_num' => 4,
    'task_worker_num' => 2,
    'dispatch_mode' => 2,
]);

$http->on('WorkerStart', function (swoole_http_server $serv, $worker_id) {
    // 每个Worker进程单独创建MySQL连接
    if ($worker_id >= $serv->setting['worker_num']) {
        $db = new mysqli("127.0.0.1", "root", "password", "test");
        if ($db->connect_errno)
            die("mysql connect error: ". $db->connect_error);
        $GLOBALS['db'] = $db;
    }
});

$http->on('Request', function (swoole_http_request $request, swoole_http_response $response) use ($http) {
    $response_server = "<h1>Hello World!</h1>";
    $http->task($response_server);
    $response->end($response_server);
});

$http->on('Task', function (swoole_http_server $server, $task_id, $from_id, $data) use ($http) {   
    $db = $GLOBALS['db'];
    $result = $db->query("SELECT COUNT(*) FROM users");
    $http->finish($result->fetch_assoc());
});

$http->on('Finish', function (swoole_http_server $server, $task_id, $data) {
    echo "Task {$task_id} has finished, data=".json_encode($data)."
";
});

$http->start();