ThinkPHP6에서 Nginx 역방향 프록시 웹소켓 사용하기

최근 몇 년 동안 Websocket은 인터넷 애플리케이션에서 매우 중요한 통신 프로토콜이 되었습니다. 뛰어난 PHP 개발 프레임워크인 ThinkPHP6은 Websocket에 대한 지원도 제공합니다. 하지만 Websocket을 사용할 때 크로스 도메인, 로드 밸런싱 등의 문제가 발생하는 경우가 많습니다. 따라서 이번 글에서는 ThinkPHP6에서 Nginx 리버스 프록시 Websocket을 사용하는 방법을 소개하겠습니다.

먼저 Websocket의 기본 원리와 구현 방법을 명확히 해야 합니다. Websocket은 HTTP 프로토콜의 핸드셰이크 프로세스를 사용하여 연결을 설정한 후 실제 데이터 전송에 TCP 프로토콜을 사용합니다. 따라서 Websocket을 사용하려면 HTTP 부분과 TCP 부분을 모두 고려해야 합니다.

실제 애플리케이션에서는 일반적으로 웹소켓 로드 밸런싱 및 도메인 간 처리를 위해 Nginx 역방향 프록시를 사용합니다. ThinkPHP6에서 Nginx 역방향 프록시 Websocket을 사용하는 방법을 소개하겠습니다.

1. Nginx 구성

Nginx 구성 파일을 통해 Websocket용 역방향 프록시를 구현할 수 있습니다. 먼저 http 블록에서 업스트림을 선언해야 합니다.

http {
    upstream websocket_servers {
        server 127.0.0.1:8000;
        server 127.0.0.1:8001;
    }
}

위 구성에서는 두 개의 서버 주소가 포함된 websocket_servers라는 업스트림을 선언했습니다. 이러한 방식으로 클라이언트가 Websocket을 요청하면 Nginx는 로드 밸런싱 알고리즘에 따라 서버 중 하나로 요청을 전달합니다.

다음으로 서버 블록에 다음 구성을 추가합니다.

server {
    listen 80;
    server_name example.com;

    # 处理WebSocket请求
    location /ws {
        proxy_pass http://websocket_servers;
        proxy_set_header Host $http_host;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "upgrade";
        proxy_read_timeout 86400;
    }

    # 处理其他请求
    location / {
        proxy_pass http://backend_server;
        proxy_set_header Host $http_host;
    }
}

위 구성은 포트 80을 수신하고 요청을 두 가지 상황으로 나눕니다. 클라이언트가 /ws를 요청하면 위에 선언된 websocket_servers로 전달되고, 다른 요청은 backend_server로 전달됩니다.

Websocket 요청의 경우 업그레이드 및 연결과 같은 특별한 요청 헤더를 설정해야 합니다. 여기서는 Proxy_set_header를 통해 이러한 요청 헤더를 설정합니다. 여기서 Proxy_pass는 https 프로토콜이 아닌 http 프로토콜이어야 합니다.

2. ThinkPHP6 구성

ThinkPHP6에서는 Swoole Server를 통해 Websocket 서비스를 시작해야 합니다. 다음 코드를 통해 간단한 Websocket 서비스를 시작할 수 있습니다.

<?php
use SwooleWebSocketServer;
use SwooleHttpRequest;
use SwooleWebSocketFrame;

$server = new Server("0.0.0.0", 8000, SWOOLE_PROCESS, SWOOLE_SOCK_TCP | SWOOLE_SSL);

$server->on("start", function (Server $server) {
    echo "Swoole WebSocket Server is started at http://0.0.0.0:8000
";
});

$server->on("open", function (Server $server, SwooleHttpRequest $request) {
    echo "connection open: {$request->fd}
";
    $server->push($request->fd, "hello, welcome
");
});

$server->on("message", function (Server $server, Frame $frame) {
    echo "received message: {$frame->data}
";
    $server->push($frame->fd, json_encode(["hello", "world"]));
});

$server->on("close", function (Server $server, $fd) {
    echo "connection close: {$fd}
";
});

$server->start();

위 코드에서는 WebSocket 서버를 생성하고 포트 8000을 수신했습니다. 공개 이벤트에서는 클라이언트로부터 연결 요청을 받고 환영 메시지를 보냅니다. 메시지 이벤트에서는 클라이언트가 보낸 메시지를 수신하고 메시지로 응답합니다. (여기서 응답 메시지는 단순한 예일 뿐이며 실제 애플리케이션의 실제 필요에 따라 수정되어야 합니다.)

여기서 주의해야 할 점은 Nginx 역방향 프록시 Websocket을 사용할 때 Swoole의 WebSocket 서버를 TCP 포트에 바인딩해야 한다는 것입니다. HTTP 프로토콜의 포트가 아닌 프로토콜에서. 따라서 3번째 파라미터를 SWOOLE_SOCK_TCP로 설정해야 합니다.

Swoole의 다중 프로세스 모드를 사용하여 성능을 향상시킬 수도 있습니다. 4번째 매개변수에서는 SWOOLE_PROCESS로 설정하고 프로세스 수를 나타내는 숫자를 지정할 수 있습니다.

실제 응용에서는 Websocket 서비스의 일부 데이터베이스나 캐시 기능을 사용해야 할 수도 있는데, 이는 ThinkPHP6의 종속성 주입 기능을 통해 쉽게 구현할 수 있습니다.

3. 프론트엔드 코드

마지막으로 프론트엔드 코드가 Websocket을 어떻게 사용하는지 살펴보겠습니다.

var ws_url = "ws://example.com/ws";  // 注意这里的协议必须是ws

var websocket = new WebSocket(ws_url);

websocket.onopen = function () {
    console.log("WebSocket opened");
};

websocket.onmessage = function (evt) {
    console.log("WebSocket received message:", evt.data);
};

websocket.onclose = function () {
    console.log("WebSocket closed");
};

위 코드에서는 WebSocket 객체를 통해 서버와 통신합니다. 연결이 열리면 onopen 이벤트가 발생하고, 메시지가 수신되면 onmessage 이벤트가 발생하며, 연결이 끊어지면 onclose 이벤트가 발생합니다.

여기서 프로토콜은 http나 https가 아닌 ws여야 한다는 점에 유의하세요.

4. 요약

위의 소개를 통해 ThinkPHP6에서는 Nginx 역방향 프록시 웹소켓을 사용하는 것이 매우 쉽다는 것을 알 수 있습니다. Nginx에서 몇 가지 기본 구성을 수행하고 Swoole에서 WebSocket 서버를 시작하기만 하면 WebSocket을 사용하여 프런트 엔드에서 통신할 수 있습니다. 실제 애플리케이션에서 문제가 발생하면 위의 코드를 참조하여 해결할 수 있습니다.

위 내용은 ThinkPHP6에서 Nginx 역방향 프록시 웹소켓 사용하기의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!