PHP에서 실시간 통신을 위해 WebSockets API를 사용하는 방법

WebSockets API는 웹 페이지에서 실시간 상호 작용을 위한 새로운 프로토콜입니다. 가장 큰 장점은 양방향 통신이 가능하여 서버와 클라이언트 간의 실시간 통신이 가능하다는 것입니다. PHP에서는 Ratchet 라이브러리를 사용하여 WebSocket의 기능을 구현할 수 있습니다. 이 기사에서는 PHP에서 WebSockets API를 사용하여 실시간 통신을 구현하는 방법을 자세히 소개합니다.

1. Ratchet 라이브러리 설치

WebSockets 기능 구현을 시작하기 전에 Ratchet 라이브러리를 설치해야 합니다. Ratchet 라이브러리는 WebSocket 기능을 빠르게 구현하는 데 도움이 되는 PHP로 구현된 WebSocket 서버입니다. Composer를 통해 Ratchet 라이브러리를 설치하는 것은 매우 편리합니다. 프로젝트 디렉터리에서 다음 명령만 실행하면 됩니다.

composer require cboden/ratchet

2. WebSockets 서버 생성

Ratchet 라이브러리를 설치한 후 WebSockets 서버를 생성할 수 있습니다. PHP에서는 RatchetServerIoServer에서 상속되는 클래스를 생성하여 WebSockets 서버를 구현합니다. 먼저 Ratchet 라이브러리를 소개한 다음 WebSocketServer라는 클래스를 만들고 WebSocket 서버 인스턴스를 생성해야 합니다.

use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;

class WebSocketServer {
    public function __construct() {
        $server = IoServer::factory(
            new HttpServer(
                new WsServer(
                    new Chat()
                )
            ),
            8080
        );
        $server->run();
    }
}

위 코드에서는 WebSocket 서버 인스턴스를 생성하고 이를 포트 8080에서 실행했습니다. WebSockets 서버가 실행되기 전에 서버의 비즈니스 로직을 구현하기 위해 Chat이라는 클래스를 만들어야 합니다. Chat 클래스는 클라이언트 연결, 연결 끊기, 메시지 수신과 같은 작업을 처리하는 데 사용됩니다.

3. 클라이언트 연결 및 연결 끊김 처리

다음으로 Chat 클래스에서 클라이언트 연결, 연결 끊김, 메시지 수신 등의 작업을 구현해야 합니다. 클라이언트가 연결되면 이를 기록하고 환영 메시지를 보내야 합니다. 클라이언트의 연결이 끊어지면 기록에서 이를 제거해야 합니다. 다음은 클라이언트 연결 및 연결 해제를 처리하는 코드입니다.

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class Chat implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new SplObjectStorage();
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New client connected: {$conn->resourceId}
";
        $conn->send("Welcome!
");
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "Client disconnected: {$conn->resourceId}
";
    }
}

위 코드에서는 Chat 클래스의 생성자에서 모든 클라이언트 연결을 저장하기 위해 클라이언트라는 SplObjectStorage 개체를 생성합니다. onOpen 메소드에서는 클라이언트가 연결되면 이를 클라이언트에 저장하고 클라이언트에게 환영 메시지를 보냅니다. onClose 메소드에서는 클라이언트 연결이 끊어지면 클라이언트에서 클라이언트를 제거합니다.

4. 메시지 전송 및 브로드캐스팅 처리

클라이언트 연결 및 연결 끊김의 논리적 처리가 완료된 후 메시지 수신, 메시지 보내기 및 메시지 브로드캐스팅 논리를 구현해야 합니다. Chat 클래스에서는 수신된 메시지를 처리하고 발신자와 다른 클라이언트에게 다양한 메시지를 보내기 위해 onMessage 메서드를 구현해야 합니다.

public function onMessage(ConnectionInterface $from, $msg) {
    $data = json_decode($msg);
    $numRecv = count($this->clients) - 1;
    if ($data->type === 'message') {
        foreach ($this->clients as $client) {
            if ($client !== $from) {
                // The sender is not the receiver, send to each client connected
                $client->send(json_encode([
                    'type' => 'message',
                    'user' => $data->user,
                    'message' => $data->message
                ]));
            } else {
                $from->send(json_encode([
                    'type' => 'message',
                    'user' => 'You',
                    'message' => $data->message
                ]));
            }
        }
    }
}

위 코드에서는 먼저 수신된 메시지를 구문 분석하고 메시지 유형에 따라 다른 처리를 수행합니다. 메시지 유형이 메시지인 경우 모든 클라이언트에게 메시지를 브로드캐스트해야 합니다. 보내는 사람이 받는 사람이 아닌 경우 받는 사람과 보내는 사람에게 각각 다른 메시지를 보냅니다.

마지막으로 WebSocketServer 클래스에서 Chat 클래스를 인스턴스화하고 WebSockets 서버를 시작해야 합니다.

new WebSocketServer();

위 단계를 통해 Ratchet 라이브러리를 사용하여 WebSockets 기능과의 실시간 통신을 성공적으로 구현했습니다. JavaScript를 통해 WebSocket에 연결합니다. 서버는 메시지를 보내고 받습니다. 여기서 클라이언트 측 JavaScript는 WebSockets API의 도움으로 구현될 수 있습니다. 이에 대해서는 여기서 자세히 설명하지 않습니다.

위 내용은 PHP에서 실시간 통신을 위해 WebSockets API를 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!