webSocket 및 Swoole을 사용하여 작은 대화방(코루틴) 만들기-Swoole-php.cn

머리말

예전에 간단한 비동기 채팅방을 작성하다가 생각해보니 코루틴도 해보자 해서 이 글을 하게 되었습니다. 사실 기능은 거의 다 똑같고 몇개만 빼면요. 장소는 다를 뿐이고 모두 단순한 장소입니다.
블로그 게시물 주소 :webSocket과 Swoole을 이용하여 소규모 대화방 만들기(비동기)
이번에는 추가 기능은 없지만, 하트비트가 추가되고, 프론트엔드에서 정기적으로 핑이 보내지는데, 서버가 응답하지 않습니다. 그게 전부입니다. 그게 전부입니다.

프론트 페이지 코드:

    打工人聊天室 
   聊天区域
 
 你好打工人：昵称 
 本次连接FD:

로그인 후 복사

JS 코드:

서버 정보를 수신할 때 첫 번째 연결 수신과 메시지 수신을 보낸 서버의 상태 차이가 있을 경우 msgType으로 구분할 수 있습니다. 첫 번째 연결입니다. 수신 메시지가 수신되면 FD는 페이지로 저장되며 채팅 메시지 영역에 표시되지 않습니다. 메시지 수신이 수신되면 채팅 메시지 영역에 바로 표시됩니다.

그리고 프론트엔드 통신과 백엔드 통신으로 전송되는 것들은 모두 문자열 특성이 가장 좋습니다. 저의 프론트엔드 처리 방식은 먼저 이를 객체로 결합한 후 JSON 문자열로 변환하는 것입니다.

로그인 후 복사

서버측 코드
코루틴은 모두Corun(function () {})에 있어야 합니다.

set([ 'heartbeat_idle_time' => 600, // 表示一个连接如果600秒内未向服务器发送任何数据，此连接将被强制关闭 'heartbeat_check_interval' => 60, // 表示每60秒遍历一次 ]); $server->handle('/websocket', function ($request, $ws) { $ws->upgrade(); global $wsObjects; $objectId = getObjectId($ws); $wsObjects[$objectId] = $ws; while (true) { $frame = $ws->recv(); if ($frame === '') { unset($wsObjects[$objectId]); $ws->close(); break; } else if ($frame === false) { echo 'error : ' . swoole_last_error() . "\n"; break; } else { if ($frame->data == 'close' || get_class($frame) === Swoole\WebSocket\CloseFrame::class) { unset($wsObjects[$objectId]); $ws->close(); return; } //格式化接收到json $data = json_decode($frame->data); switch ($data->msgType){ case 'open': //链接第一次 $data = json_encode([ 'fd' => $objectId, 'msgType' => 1 //代表第一次连接，前端处理fd ]); $ws->push($data); break; case 'ping': //接收到心跳 不作回复 // echo $data->msgType; break; default : // 原基础上不动，增加一些自定义 $data->msgType = 2; //代表服务器端回复 $data->time = date('Y-m-d H-i-s'); $data = json_encode($data); foreach ($wsObjects as $obj) { $obj->push($data); } } } } }); $server->start(); });

로그인 후 복사

코드가 완성된 후에는 콘솔에서 다음 PHP 파일을 실행하기만 하면 됩니다.