PHP API 인터페이스: WebSocket 사용 방법

PHP는 동적 웹사이트와 웹 애플리케이션을 구축하는 데 일반적으로 사용되는 오픈 소스 서버 측 스크립팅 언어입니다. PHP API 인터페이스는 일반적으로 HTTP 프로토콜을 통해 제공되지만 최신 웹 애플리케이션의 수요가 증가함에 따라 실시간 데이터 업데이트가 더욱 중요해졌습니다. 이를 위해서는 변경 사항에 더 빠르게 응답하기 위해 양방향 통신에 WebSocket을 사용해야 합니다.

WebSocket은 HTML5의 클라이언트와 서버 간의 새로운 유형의 통신 채널입니다. 오랫동안 연결을 유지하여 실시간 양방향 데이터 전송을 제공합니다. HTTP 요청과 달리 WebSocket은 각 요청마다 TCP 소켓을 생성하는 대신 WebSocket 연결에서 TCP 소켓을 엽니다. 이는 WebSocket이 HTTP 요청보다 더 빠르고 쉽게 실시간 데이터 전송을 가능하게 한다는 것을 의미합니다.

이 기사에서는 PHP API 인터페이스를 사용하여 WebSocket과 통신하여 웹 애플리케이션의 데이터를 실시간으로 업데이트하는 방법을 소개합니다.

1. Ratchet 설치
WebSocket을 사용하려면 PHP에서 매우 인기 있는 WebSocket 라이브러리인 Ratchet을 설치해야 합니다. Github에서 Ratchet을 다운로드하여 프로젝트에 추가하거나 Composer를 사용하여 설치할 수 있습니다.

Composer를 사용하는 경우 다음 명령을 실행할 수 있습니다.

composer require cboden/ratchet

이렇게 하면 Ratchet이 자동으로 설치됩니다. 설치가 완료되면 WebSocket Server 클래스를 사용하여 WebSocket 서버를 생성할 수 있습니다.

2. WebSocket 서버 생성
Ratchet을 사용하면 클라이언트와의 실시간 통신을 위한 WebSocket 서버를 생성할 수 있습니다. 다음은 기본 WebSocket 서버 샘플 코드입니다.

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetServerIoServer;
use RatchetWebSocketWsServer;

require_once(__DIR__ . '/vendor/autoload.php');

class MyWebSocket implements MessageComponentInterface
{
    public function onOpen(ConnectionInterface $conn)
    {
        // 当有新客户端连接时执行
        echo "New connection! ({$conn->resourceId})
";
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        // 接收消息
        echo "Received message: {$msg}
";
    
        // 回复消息
        $from->send('Data received: ' . $msg);
    }

    public function onClose(ConnectionInterface $conn)
    {
        // 当客户端断开连接时执行
        echo "Connection {$conn->resourceId} has disconnected
";
    }

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        // 当出现错误时执行
        echo "An error has occurred: {$e->getMessage()}
";
    
        $conn->close();
    }
}

// 创建WebSocket服务器
$server = IoServer::factory(
    new WsServer(
        new MyWebSocket()
    ),
    8080
);

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

위 코드는 포트 8080에서 클라이언트 연결을 수락할 수 있는 WebSocket 서버를 생성합니다. 실제 비즈니스 로직은 없으며 연결, 메시지 및 연결 해제 이벤트만 인쇄합니다. 이를 시작점으로 사용하고 필요에 따라 자체 WebSocket 서버 클래스를 사용자 정의할 수 있습니다.

3. 클라이언트는 WebSocket API를 사용합니다
클라이언트 측에서는 WebSocket API를 사용하여 서버와 연결하고 메시지를 주고받을 수 있습니다. 다음은 가장 간단한 클라이언트 WebSocket 예입니다.

var connection = new WebSocket('ws://localhost:8080');

connection.onopen = function () {
    console.log('WebSocket connected');
  
    // 发送消息
    connection.send('Hello, WebSocket server!');
};

connection.onmessage = function (event) {
    console.log('Received message: ' + event.data);
};

connection.onclose = function (event) {
    console.log('WebSocket connection closed with code ' + event.code + ' and reason: ' + event.reason);
};

connection.onerror = function (error) {
    console.log('WebSocket error: ' + error.message);
};

이 코드는 방금 작성한 WebSocket 서버에 연결을 시도합니다. 연결 이벤트가 수신되면 메시지를 보냅니다. 서버로부터 메시지가 수신되면 해당 메시지를 콘솔에 기록합니다. 또한 연결 종료 및 오류 상황을 처리합니다.

4. PHP API 인터페이스를 통해 WebSocket 사용
이제 PHP API 인터페이스를 사용하여 WebSocket과 통신하는 방법을 살펴보겠습니다. 기존 API 라우터를 사용하여 WebSocket 요청을 처리할 수 있습니다. 클라이언트가 WebSocket 서버에 연결되면 Ratchet WebSocket의 ConnectionInterface 인터페이스를 사용하여 관련 정보를 검색할 수 있습니다. 또한 이 정보를 사용하여 연결을 인증하고 인증된 사용자만 WebSocket 서버에 연결할 수 있도록 할 수 있습니다.

샘플 코드는 다음과 같습니다.

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetServerIoServer;
use RatchetWebSocketWsServer;

require_once(__DIR__ . '/vendor/autoload.php');

// 自定义WebSocket服务器类
class MyWebSocket implements MessageComponentInterface
{
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn)
    {
        // 将新连接存储到$clients
        $this->clients->attach($conn);
    
        // 获取客户端地址
        $client_ip = $conn->remoteAddress;
    
        // 处理新连接（验证身份、发送欢迎消息等）
        // ...
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        // 处理收到的消息
        // ...
    }

    public function onClose(ConnectionInterface $conn)
    {
        // 从$clients中删除关闭连接
        $this->clients->detach($conn);

        // 处理关闭连接
        // ...
    }

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        // 处理WebSocket错误
        // ...
        
        // 关闭连接
        $conn->close();
    }
}

// 创建WebSocket服务器
$server = IoServer::factory(
    new WsServer(
        new MyWebSocket()
    ),
    8080
);

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

onOpen 메서드에서는 연결 확인, 클라이언트에 환영 메시지 보내기, 새 연결 기록과 같은 일부 처리를 수행할 수 있습니다. onClose 메소드에서는 목록에서 연결을 제거하고 다른 클라이언트에 오프라인 알림을 보내는 등 연결을 닫는 이벤트를 처리할 수 있습니다.

onMessage 메소드에서는 WebSocket 클라이언트가 보낸 메시지를 처리할 수 있습니다. WebSocket은 양방향 통신 채널이기 때문에 이는 서버가 클라이언트에 메시지를 보내는 것이 아니라 클라이언트도 서버에 메시지를 보낼 수 있음을 의미하며, 이는 데이터를 보내고 받는 애플리케이션의 능력을 크게 향상시킵니다.

PHP API 인터페이스를 통해 WebSocket과 통신하면 실시간으로 데이터를 업데이트할 수 있으며 이는 실시간 트랜잭션, 메시지 푸시, 게임 애플리케이션과 같은 실시간 애플리케이션에 매우 중요합니다.

위 내용은 PHP API 인터페이스: WebSocket 사용 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!