Swoole은 단일 쿼리를 어떻게 구현한 다음 모든 사람에게 보냅니다.

내 요구 사항은 가끔씩 데이터베이스를 쿼리한 다음 모든 사람에게 푸시하는 것입니다.
코드는 다음과 유사합니다.
while(true){

<code>$sql ="select 1+1";
$count=$mysql->query($sql);
foreach($serv->connections as $fd)
{
    $serv->push($fd, $count);
}
sleep(1000);</code>

}
Swoole websocket의 on('message')을 사용하여 이 코드를 작성하면 클라이언트가 연결할 때마다 이 코드의 복사본이 열리고 실행됩니다.
모든 고객이 받을 수 있도록 코드를 실행하려면 어떻게 해야 하나요? .

답글 내용:

내 요구 사항은 가끔씩 데이터베이스를 쿼리한 다음 모든 사람에게 푸시하는 것입니다.
코드는 다음과 유사합니다.
while(true){

<code>$sql ="select 1+1";
$count=$mysql->query($sql);
foreach($serv->connections as $fd)
{
    $serv->push($fd, $count);
}
sleep(1000);</code>

}
Swoole websocket의 on('message')을 사용하여 이 코드를 작성하면 클라이언트가 연결할 때마다 이 코드의 복사본이 열리고 실행됩니다.
모든 고객이 받을 수 있도록 코드를 실행하려면 어떻게 해야 하나요? .

타이머가 있었던 것 기억나죠? 하지만 나도 이해가 안 돼요

메시지만 사용하는 경우 메시지를 두 가지 유형으로 나누어 하나는 관리자가 보내는 메시지이고 다른 하나는 관리자로부터 메시지를 받을 때마다 데이터베이스를 확인하고 확인하세요. 다른 사람에게 대량으로 보내세요.
시간이 너무 많이 걸릴 것 같다면 주요 작업을 작업에 넣어서 관리자가 메시지를 보낸 후 바로 돌아와서 다른 메시지를 처리하고, 복잡한 일은 작업에 맡기면 됩니다.