PHP와 WebSocket 통합으로 실시간 채팅방 개발 실현

웹 개발 분야에서는 실시간 채팅 기능이 점점 대중화되고 있습니다. 사용자가 실시간으로 쉽게 상호 작용하고 의사소통과 이해를 높일 수 있도록 도와줍니다. 실시간 채팅을 구현하기 위해서는 WebSocket 프로토콜을 사용해야 하며, WebSocket 요청을 처리할 수 있는 프로그래밍 언어가 필요합니다. 이번 글에서는 PHP와 WebSocket 통합을 이용하여 실시간 채팅방 개발을 구현하는 방법을 소개하겠습니다.

WebSocket은 브라우저와 서버 간의 실시간 데이터 전송을 가능하게 하는 전이중 통신 프로토콜입니다. HTTP 요청과 달리 서버는 WebSocket 연결이 설정된 후 브라우저에 데이터를 푸시할 수 있습니다. 따라서 WebSocket을 통해 클라이언트와 서버 간의 양방향 데이터 통신이 가능합니다. 사용자가 채팅방에 들어오거나 나가면 메시지가 즉시 다른 온라인 사용자에게 전달될 수 있습니다. 이것이 실시간 채팅의 기본 원칙입니다.

먼저 WebSocket 요청을 처리하기 위해 서버 측에서 PHP 스크립트를 생성해야 합니다. PHP의 swoole 확장은 WebSocket 서버 개발에 도움이 될 수 있습니다. 다음으로 채팅 애플리케이션을 단계별로 구현하겠습니다.

1. swoole 확장 설치

swoole 확장을 사용하려면 먼저 설치가 필요합니다. Linux 시스템에 swoole을 설치하려면 다음 명령을 사용하십시오.

pecl install swoole

Windows 시스템에서 PHP를 사용하는 경우 swoole의 GitHub 저장소에서 관련 DLL 파일을 다운로드하고 수동으로 설치할 수 있습니다.

2. WebSocket 서버 설정

Swoole 확장을 성공적으로 설치하면 이를 사용하여 WebSocket 서버를 생성할 수 있습니다. WebSocket 서버를 생성하는 기본 코드는 다음과 같습니다.

//创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 9501);

//监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

//监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) {
    echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}
";
    $server->push($frame->fd, json_encode(["hello", "world"]));
});

//监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) {
    echo "client {$fd} closed
";
});

//启动WebSocket服务器
$server->start();

이 코드 조각에서는 WebSocket 서버를 생성하고 이벤트 핸들러 기능을 등록합니다. "open" 이벤트에서는 WebSocket 연결이 열려 있다는 메시지를 인쇄합니다. "message" 이벤트에서는 WebSocket 세션에 대한 정보를 인쇄하고 클라이언트에 메시지를 보냅니다. "close" 이벤트에서는 WebSocket 연결이 닫혔다는 메시지를 인쇄합니다.

3. 채팅방 로직 설정

이제 WebSocket 서버를 성공적으로 생성하고 이벤트 처리 기능을 설정했습니다. 다음으로 채팅방 로직 구현을 시작할 수 있습니다.

사용자가 채팅방에 들어오거나 나갈 때 모든 온라인 사용자에게 알리기 위해 메시지 방송 기능을 설정해야 합니다. 다음은 메시지 브로드캐스트 기능의 코드입니다.

//广播消息
function broadcast($server, $frame, $users) {
    $data = json_decode($frame->data, true);
    switch ($data['type']) {
        case 'enter':
            $users[$frame->fd] = $data['name'];
            $msg = $data['name'] . ' joined the room.';
            break;
        case 'leave':
            $name = $users[$frame->fd];
            unset($users[$frame->fd]);
            $msg = $name . ' left the room.';
            break;
        case 'msg':
            $name = $users[$frame->fd];
            $msg = $name . ': ' . $data['msg'];
            break;
    }
    foreach ($server->connections as $fd) {
        $server->push($fd, json_encode(['type' => 'msg', 'msg' => $msg]));
    }
}

이 코드 조각에서는 스위치 문을 사용하여 다양한 유형의 메시지를 처리합니다. 사용자가 채팅방에 참여하거나 나가면 사용자 목록을 업데이트하고 알림 메시지를 보냅니다. 사용자가 메시지를 보내면 메시지 앞에 사용자 이름을 붙여 모든 온라인 사용자에게 방송합니다.

4. 완전한 채팅방 코드

이제 필요한 모든 구성 요소가 준비되었으므로 완전한 채팅방 코드 작성을 시작할 수 있습니다. 다음은 전체 채팅방 코드입니다.

//创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 9501);

//定义用户列表
$users = [];

//广播消息
function broadcast($server, $frame, $users) {
    $data = json_decode($frame->data, true);
    switch ($data['type']) {
        case 'enter':
            $users[$frame->fd] = $data['name'];
            $msg = $data['name'] . ' joined the room.';
            break;
        case 'leave':
            $name = $users[$frame->fd];
            unset($users[$frame->fd]);
            $msg = $name . ' left the room.';
            break;
        case 'msg':
            $name = $users[$frame->fd];
            $msg = $name . ': ' . $data['msg'];
            break;
    }
    foreach ($server->connections as $fd) {
        $server->push($fd, json_encode(['type' => 'msg', 'msg' => $msg]));
    }
}

//监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

//监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) use ($users) {
    broadcast($server, $frame, $users);
});

//监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) use ($users) {
    unset($users[$fd]);
    echo "client {$fd} closed
";
});

//启动WebSocket服务器
$server->start();

이 코드 조각에서는 모든 온라인 사용자의 정보를 $users 배열에 저장합니다. 사용자가 채팅방에 참여하거나 나갈 때 이 배열을 업데이트합니다. WebSocket 메시지 이벤트에서는 Broadcast() 함수를 사용하여 메시지를 브로드캐스트합니다. WebSocket 연결 닫기 이벤트에서는 연결이 끊긴 사용자를 $users 배열에서 제거합니다.

5. 채팅방 테스트

이제 채팅방 애플리케이션이 성공적으로 생성되었습니다. Google Chrome, Firefox, Safari 등 WebSocket을 지원하는 모든 브라우저에서 테스트할 수 있습니다. 채팅방을 테스트하는 방법에 대한 단계는 다음과 같습니다.

1. PHP 명령을 사용하여 위 코드를 실행합니다.
2. 브라우저에서 index.html 파일을 엽니다.
3. 사용자 이름을 입력하고 "채팅방 입장" 버튼을 클릭합니다.
4. 에서 채팅 상자에 메시지를 입력하고 "보내기" 버튼을 클릭하세요.

모든 온라인 사용자의 채팅 상자에서 메시지 방송을 볼 수 있어야 합니다.

요약

이번 글에서는 PHP와 WebSocket 통합을 활용하여 실시간 채팅방 개발을 구현하는 방법을 소개했습니다. 우리는 swoole 확장을 사용하여 WebSocket 서버를 만들고 간단한 채팅방 애플리케이션을 작성했습니다. 이 기사를 통해 WebSocket 프로토콜을 사용하여 실시간 데이터 전송 연결을 설정하고, PHP에서 WebSocket 서버를 구현하고, 이를 사용하여 채팅방 애플리케이션을 구현하는 방법을 배울 수 있습니다.

위 내용은 PHP와 WebSocket 통합으로 실시간 채팅방 개발 실현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!