PHP 및 Swoole을 사용한 실시간 통신 구현에 대한 전체 튜토리얼

인터넷과 이동통신 기술의 급속한 발전으로 실시간 커뮤니케이션이 더욱 주목을 받고 있습니다. 실시간 통신은 사용자 간의 인스턴트 메시징, 온라인 음성 및 영상 통화, 게임 전투 및 기타 기능을 실현하여 인터넷 애플리케이션에 더 많은 가능성을 제공합니다.

이 기사에서는 PHP와 Swoole을 사용하여 실시간 통신을 구현하는 방법을 소개합니다. 간단한 WebSocket 애플리케이션부터 시작하여 점차적으로 소켓 프로그래밍의 기본 지식과 Swoole의 애플리케이션 실습을 소개합니다. 이 기사를 읽으려면 PHP 기본 및 네트워크 프로그래밍에 대한 기본 지식이 필요합니다.

1. WebSocket 기본

WebSocket은 HTTP 프로토콜을 기반으로 하는 양방향 통신 프로토콜로 "핸드셰이크"라는 프로토콜을 사용하여 양방향 통신을 가능하게 합니다. WebSocket 연결의 장점은 오버헤드가 매우 적고, 실시간 통신이 매우 좋으며, 클라이언트와 서버 간에 양방향 실시간 통신이 가능하다는 것입니다.

WebSocket을 설정하려면 다음 단계가 필요합니다.

1. 브라우저는 서버에 WebSocket 핸드셰이크 요청을 시작합니다. 요청 헤더에는 업그레이드, 연결, Sec-WebSocket-Key 등과 같은 몇 가지 주요 필드가 포함되어 있습니다.

2. 서버는 클라이언트의 WebSocket 요청을 처리하고 사양을 충족하면 응답 헤더에 Upgrade, Connection 및 Sec-WebSocket-Accept와 같은 필드가 포함된 응답 메시지를 반환합니다.

3. 클라이언트는 서버로부터 응답 메시지를 수신하고 Sec-WebSocket-Accept 필드를 확인한 후 WebSocket 핸드셰이크가 성공적으로 설정되었는지 확인합니다.

4. 양측 모두 데이터 통신을 시작할 수 있으며 텍스트, 바이너리, 핑, 퐁 및 기타 메시지를 보낼 수 있습니다.

PHP에서 WebSocket을 사용하면 Swoole에서 제공하는 WebSocket 서비스를 통해 구현할 수 있습니다. 다음은 Swoole의 기본 응용 프로그램을 소개합니다.

2. Swoole 기본

1. Swoole 설치

Swoole을 사용하기 전에 서버에 Swoole 확장 프로그램을 설치해야 합니다. 다음 명령을 통해 설치할 수 있습니다:

pecl install swoole

또는 소스 코드 설치:

$ wget https://github.com/swoole/swoole-src/archive/v4.3.3.tar.gz
$ tar zxvf v4.3.3.tar.gz
$ cd swoole-src-4.3.3
$ phpize
$ ./configure
$ make && make install --with-swoole

2. Swoole WebSocket 서비스

구현해보자 하나 포트 9501을 수신하고 클라이언트가 서버와 연결을 설정할 때 클라이언트에 안녕하세요 메시지를 보내는 간단한 WebSocket 서비스입니다.

<?php

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

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new client connected
";
    $server->push($request->fd, "hello");
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    echo "received message: {$frame->data}
";
});

$server->start();

이 코드에서는 새 WebSocket 서버를 생성하고 포트 9501에서 수신 대기합니다. 클라이언트가 서버와 연결을 설정하면 open 이벤트가 트리거되고 hello 메시지가 클라이언트로 전송됩니다. 클라이언트가 서버에 메시지를 보내면 메시지 이벤트가 트리거되고 echo를 사용하여 클라이언트가 보낸 정보를 출력할 수 있습니다.

위 코드를 시작한 후 브라우저 또는 WebSocket 클라이언트를 사용하여 서버에 연결할 수 있습니다.

let ws = new WebSocket('ws://127.0.0.1:9501');
ws.onopen = function(event) {
    console.log('WebSocket connected');
};
ws.onmessage = function(event) {
    console.log('Received:', event.data);
};
ws.send('Hello, Server');

클라이언트가 성공적으로 연결되면 콘솔에 다음 정보가 출력됩니다.

WebSocket connected
Received: hello

클라이언트가 성공적으로 수신했음을 나타냅니다. 안녕하세요 서버에서 보낸 메시지입니다.

3. 실시간 채팅 애플리케이션 구현

다음으로, 채팅방에서 여러 사용자가 실시간으로 소통할 수 있는 실시간 채팅 애플리케이션을 구현해 보겠습니다. 이를 위해서는 채팅방의 기본 기능을 구현하기 위해 위의 WebSocket 서버를 계속 확장해야 합니다.

<?php

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

$server->set([
    'worker_num' => 2,    //启动2个Worker进程
]);

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new client connected
";
    foreach($server->connections as $fd) {
        $server->push($fd, "{$request->fd} joined the room");
    }
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    foreach($server->connections as $fd) {
        if ($fd != $frame->fd) {
            $server->push($fd, "user {$frame->fd}: {$frame->data}");
        }
    }
});

$server->on('close', function ($server, $fd) {
    echo "client {$fd} closed
";
    foreach($server->connections as $fds) {
        $server->push($fds, "{$fd} quited the room");
    }
});

$server->start();

위 코드에는 열기 및 닫기 이벤트 처리를 추가했습니다. 사용자가 연결하거나 연결을 끊으면 연결된 다른 사용자에게 채팅방에 참여하거나 나가라는 메시지가 전송됩니다. 사용자가 채팅방에서 메시지를 보내면 메시지가 다른 온라인 사용자에게 브로드캐스팅됩니다.

위 코드를 시작한 후 여러 브라우저 창을 사용하여 별도로 서버에 연결하고 동일한 채팅방에 들어갈 수 있습니다. 사용자가 메시지를 보내면 다른 사용자도 실시간으로 해당 메시지를 받을 수 있습니다.

이 글에서는 기본 WebSocket 애플리케이션부터 실시간 채팅방 애플리케이션에 이르기까지 PHP와 Swoole을 사용하여 실시간 통신을 구현하는 방법을 소개합니다. Swoole은 보다 유연한 비동기 프로그래밍 방법을 제공하여 고성능, 동시성 및 대기 시간이 짧은 애플리케이션을 더 쉽게 작성할 수 있습니다.

위 내용은 PHP 및 Swoole을 사용한 실시간 통신 구현에 대한 전체 튜토리얼의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!