#hostingforum.kr
php

// server.php

use SwooleServer;



$server = new Server('127.0.0.1', 9501, SWOOLE_BASE);



$server->set([

    'worker_num' => 2,

]);



$server->on('WorkerStart', function (Server $server, $workerId) {

    echo "Worker $workerId started.
";

});



$server->on('Task', function (Server $server, $taskId, $fromWorkerId, $data) {

    echo "Task $taskId received from worker $fromWorkerId.
";

    // 비동기 작업을 처리합니다.

    sleep(2);

    $result = "Task $taskId result";

    $server->finish($result);

});



$server->on('Finish', function (Server $server, $taskId, $data) {

    echo "Task $taskId finished with result: $data
";

});



$server->on('Connect', function (Server $server, $fd, $fromId) {

    echo "Client $fd connected.
";

});



$server->on('Receive', function (Server $server, $fd, $fromId, $data) {

    echo "Client $fd received message: $data
";

    // 비동기 작업을 요청합니다.

    $server->task(["message" => $data]);

});



$server->start();

#hostingforum.kr
php

// client.php

use SwooleCoroutine;



$cli = new SwooleCoroutineClient(SWOOLE_SOCK_TCP);



$cli->connect('127.0.0.1', 9501);



$cli->send("Hello, server!");



$cli->recv();

#hostingforum.kr
php

$server->set([

    'worker_num' => 2,

    'task_worker_num' => 4,

]);

#hostingforum.kr
php

$server->set([

    'task_max_request' => 100,

]);