Swoole_async_read에 대한 질문

• 클린아키텍처광 15일 전 2025.03.11 01:27
• 29
  1

php

$server = new swoole_server("0.0.0.0", 9501);

$server->set([

    'worker_num' => 4,

    'max_request' => 10000,

    'max_conn' => 10000,

]);



$server->on('start', function (swoole_server $server) {

    echo "Server is started.n";

});



$server->on('connect', function (swoole_server $server, $fd, $from_id) {

    echo "Client: $fd connect.n";

});



$server->on('receive', function (swoole_server $server, $fd, $from_id, $data) {

    $server->send($fd, "Hello, client.n");

    $server->asyncRead($fd, function (swoole_server $server, $fd, $from_id, $data) {

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

    });

});



$server->on('close', function (swoole_server $server, $fd, $from_id) {

    echo "Client: $fd close.n";

});



$server->start();

목록

댓글 1

댓글목록



나우호스팅 　15일 전



swoole_async_read 함수는 비동기적으로 데이터를 읽어오기 위한 함수입니다. 이 함수는 읽어온 데이터가 없을 때 대기하는 동작을 수행하기 위해 swoole_server의 on('task') 이벤트를 사용할 수 있습니다.

on('task') 이벤트는 worker 프로세스에서 발생하며, task 큐에 데이터를 삽입할 때 호출됩니다. 이 이벤트를 사용하여 읽어온 데이터가 없을 때 대기할 수 있습니다.

다음은 예제 코드입니다.



#hostingforum.kr
php

$server = new swoole_server("0.0.0.0", 9501);

$server->set([

    'worker_num' => 4,

    'max_request' => 10000,

    'max_conn' => 10000,

]);



$server->on('start', function (swoole_server $server) {

    echo "Server is started.n";

});



$server->on('connect', function (swoole_server $server, $fd, $from_id) {

    echo "Client: $fd connect.n";

});



$server->on('receive', function (swoole_server $server, $fd, $from_id, $data) {

    $server->send($fd, "Hello, client.n");

    $server->asyncRead($fd, function (swoole_server $server, $fd, $from_id, $data) {

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

        // 읽어온 데이터가 없을 때 대기

        $server->task("wait_data", $fd);

    });

});



$server->on('task', function (swoole_server $server, $task_id, $from_id, $data) {

    // task 큐에 데이터가 삽입되었을 때 호출

    echo "Task: $task_id received data: $datan";

    // 읽어온 데이터가 없을 때 대기

    swoole_timer_after(1000, function () use ($server, $task_id) {

        $server->finish($task_id);

    }, $task_id);

});



$server->on('finish', function (swoole_server $server, $task_id, $from_id, $data) {

    // task 큐에서 데이터가 제거되었을 때 호출

    echo "Task: $task_id finished.n";

});



$server->on('close', function (swoole_server $server, $fd, $from_id) {

    echo "Client: $fd close.n";

});



$server->start();

Copy



이 예제 코드에서는 on('task') 이벤트를 사용하여 읽어온 데이터가 없을 때 대기합니다. task 큐에 데이터를 삽입할 때 호출되는 이 이벤트를 사용하여 대기할 수 있습니다.

2025-03-11 01:28

<br /> <br /> swoole_async_read 함수는 비동기적으로 데이터를 읽어오기 위한 함수입니다. 이 함수는 읽어온 데이터가 없을 때 대기하는 동작을 수행하기 위해 swoole_server의 on('task') 이벤트를 사용할 수 있습니다.<br /> <br /> on('task') 이벤트는 worker 프로세스에서 발생하며, task 큐에 데이터를 삽입할 때 호출됩니다. 이 이벤트를 사용하여 읽어온 데이터가 없을 때 대기할 수 있습니다.<br /> <br /> 다음은 예제 코드입니다.<br /> <br /> [code]#hostingforum.kr<br>php<br /> $server = new swoole_server("0.0.0.0", 9501);<br /> $server->set([<br /> 'worker_num' => 4,<br /> 'max_request' => 10000,<br /> 'max_conn' => 10000,<br /> ]);<br /> <br /> $server->on('start', function (swoole_server $server) {<br /> echo "Server is started.\n";<br /> });<br /> <br /> $server->on('connect', function (swoole_server $server, $fd, $from_id) {<br /> echo "Client: $fd connect.\n";<br /> });<br /> <br /> $server->on('receive', function (swoole_server $server, $fd, $from_id, $data) {<br /> $server->send($fd, "Hello, client.\n");<br /> $server->asyncRead($fd, function (swoole_server $server, $fd, $from_id, $data) {<br /> echo "Client: $fd received data: $data\n";<br /> // 읽어온 데이터가 없을 때 대기<br /> $server->task("wait_data", $fd);<br /> });<br /> });<br /> <br /> $server->on('task', function (swoole_server $server, $task_id, $from_id, $data) {<br /> // task 큐에 데이터가 삽입되었을 때 호출<br /> echo "Task: $task_id received data: $data\n";<br /> // 읽어온 데이터가 없을 때 대기<br /> swoole_timer_after(1000, function () use ($server, $task_id) {<br /> $server->finish($task_id);<br /> }, $task_id);<br /> });<br /> <br /> $server->on('finish', function (swoole_server $server, $task_id, $from_id, $data) {<br /> // task 큐에서 데이터가 제거되었을 때 호출<br /> echo "Task: $task_id finished.\n";<br /> });<br /> <br /> $server->on('close', function (swoole_server $server, $fd, $from_id) {<br /> echo "Client: $fd close.\n";<br /> });<br /> <br /> $server->start();<br /> [/code]<br /> <br /> 이 예제 코드에서는 on('task') 이벤트를 사용하여 읽어온 데이터가 없을 때 대기합니다. task 큐에 데이터를 삽입할 때 호출되는 이 이벤트를 사용하여 대기할 수 있습니다.