Swoole을 사용하여 WebSocket 통신을 구현하는 방법

Swoole은 비동기 IO, 다중 프로세스, 다중 스레딩, 코루틴 및 기타 기능을 지원하는 고성능 PHP 코루틴 네트워크 프레임워크입니다. 그중 Swoole에서 제공하는 WebSocket 구성 요소는 실시간 양방향 통신을 구현하는 데 사용할 수 있으며 실시간 애플리케이션을 구축하는 데 이상적인 선택입니다. 이 기사에서는 Swoole을 사용하여 WebSocket 통신을 구현하는 방법을 소개하고 특정 코드 예제를 제공합니다.

1. 환경 준비

Swoole을 사용하여 WebSocket 통신을 구현하기 전에 Swoole 확장 프로그램이 설치되어 있는지 확인해야 합니다.

pecl install swoole

명령을 통해 설치하거나 공식 GitHub 저장소에서 소스 코드 빌드를 다운로드할 수 있습니다.

2. WebSocket 서버 생성

Swoole의 WebSocket 컴포넌트를 코드에 도입하고, WebSocket 서버를 생성하고, 클라이언트와의 연결을 모니터링합니다. 코드는 다음과 같습니다.

use SwooleWebSocketServer;

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

// 监听WebSocket连接事件
$server->on('open', function (Server $server, $request) {
    echo "Client {$request->fd} connected
";
});

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

위 코드는 포트 9501에서 수신 대기하는 WebSocket 서버를 생성하고 연결이 설정되면 연결된 클라이언트의 파일 설명자(fd)를 인쇄합니다.

3. WebSocket 메시지 처리

WebSocket 서버가 클라이언트와 연결을 설정하면 클라이언트는 서버에 메시지를 보낼 수 있습니다. 서버는 클라이언트의 메시지 이벤트를 수신하고 처리해야 합니다. WebSocket 메시지 처리 프로세스는 HTTP 요청 프로세스와 유사합니다. 메시지 헤더를 구문 분석하고 메시지 본문을 가져오면 메시지 내용을 얻을 수 있습니다. 코드는 다음과 같습니다.

// 监听WebSocket消息事件
$server->on('message', function (Server $server, $frame) {
    echo "Received message: {$frame->data}
";
});

위 코드는 WebSocket 메시지 이벤트를 수신하고 메시지가 수신되면 메시지 내용을 인쇄합니다.

4. WebSocket 클라이언트에 메시지 보내기

WebSocket 서버에서 클라이언트에 메시지를 보내려면 서버의 push 메서드를 사용해야 합니다. 이 메소드는 클라이언트의 파일 설명자와 전송해야 하는 메시지의 내용을 승인합니다. 코드는 다음과 같습니다.

// 监听WebSocket消息事件
$server->on('message', function (Server $server, $frame) {
    echo "Received message: {$frame->data}
";
    
    // 向客户端发送消息
    $server->push($frame->fd, 'Server received message: '.$frame->data);
});

위 코드는 WebSocket 메시지 처리 시 클라이언트에 메시지를 응답하는 코드입니다.

5. 전체 코드 예제

use SwooleWebSocketServer;

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

// 监听WebSocket连接事件
$server->on('open', function (Server $server, $request) {
    echo "Client {$request->fd} connected
";
});

// 监听WebSocket消息事件
$server->on('message', function (Server $server, $frame) {
    echo "Received message: {$frame->data}
";
    
    // 向客户端发送消息
    $server->push($frame->fd, 'Server received message: '.$frame->data);
});

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

6. WebSocket 클라이언트

WebSocket 서버 구성이 완료되면 WebSocket 클라이언트를 사용하여 서버에 메시지를 보내고 서버로부터 응답을 받아야 합니다. 다음은 WebSocket 클라이언트의 샘플 코드입니다.

// 创建WebSocket连接
const ws = new WebSocket('ws://localhost:9501');

// 监听WebSocket连接事件
ws.addEventListener('open', function (event) {
    console.log('Connected to WebSocket server');
    
    // 发送消息
    ws.send('Hello, Swoole WebSocket');
});

// 监听WebSocket消息事件
ws.addEventListener('message', function (event) {
    console.log('Received message:', event.data);
});

위 코드는 JavaScript를 사용하여 WebSocket 연결을 생성하고 연결이 설정된 후 WebSocket 서버에 메시지를 보냅니다. 서버에서 메시지를 처리하면 서버는 응답 메시지를 클라이언트에 다시 보내고 클라이언트는 메시지 이벤트를 수신하여 응답 메시지를 받을 수 있습니다.

7. 요약

본 글에서는 Swoole을 사용하여 WebSocket 통신을 구현하는 방법을 소개하고, WebSocket 서버를 생성하고, 메시지를 처리하고, 클라이언트에 메시지를 보내는 방법을 코드 예제를 통해 보여줍니다. Swoole의 WebSocket 구성요소를 사용하면 실시간 양방향 통신 애플리케이션을 쉽게 구축할 수 있습니다.

위 내용은 Swoole을 사용하여 WebSocket 통신을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!