Menggunakan Websocket proksi terbalik Nginx dalam ThinkPHP6

Dalam beberapa tahun kebelakangan ini, Websocket telah menjadi protokol komunikasi yang sangat penting dalam aplikasi Internet. ThinkPHP6, sebagai rangka kerja pembangunan PHP yang sangat baik, juga menyediakan sokongan untuk Websocket. Walau bagaimanapun, apabila menggunakan Websocket, kami biasanya melibatkan isu seperti domain silang dan pengimbangan beban Oleh itu, dalam artikel ini, kami akan memperkenalkan cara menggunakan Websocket terbalik Nginx dalam ThinkPHP6.

Pertama sekali, kita perlu menjelaskan prinsip asas dan kaedah pelaksanaan Websocket. Websocket menggunakan proses jabat tangan protokol HTTP untuk mewujudkan sambungan Selepas sambungan diwujudkan, protokol TCP digunakan untuk penghantaran data sebenar. Oleh itu, untuk penggunaan Websocket, kita perlu mempertimbangkan kedua-dua bahagian HTTP dan TCP.

Dalam aplikasi sebenar, kami biasanya menggunakan proksi terbalik Nginx untuk pengimbangan beban Websocket dan pemprosesan merentas domain. Mari perkenalkan cara menggunakan Websocket proksi terbalik Nginx dalam ThinkPHP6.

1. Konfigurasi Nginx

Kami boleh melaksanakan proksi terbalik untuk Websocket melalui fail konfigurasi Nginx. Pertama, kita perlu mengisytiharkan huluan dalam blok http:

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

Dalam konfigurasi di atas, kami mengisytiharkan huluan bernama websocket_servers, yang mengandungi dua alamat pelayan. Dengan cara ini, apabila pelanggan meminta Websocket, Nginx akan memajukan permintaan itu ke salah satu pelayan mengikut algoritma pengimbangan beban.

Seterusnya, tambahkan konfigurasi berikut dalam blok pelayan:

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;
    }
}

Konfigurasi di atas akan mendengar port 80 dan membahagikan permintaan kepada dua situasi. Apabila pelanggan meminta /ws, ia akan dimajukan ke websocket_servers yang diisytiharkan di atas;

Untuk permintaan Websocket, kami perlu menetapkan beberapa pengepala permintaan khas, seperti Naik Taraf dan Sambungan. Di sini kami menetapkan pengepala permintaan ini melalui proxy_set_header. Ambil perhatian bahawa proxy_pass di sini mestilah protokol http, bukan protokol https.

2. Konfigurasi ThinkPHP6

Dalam ThinkPHP6, kita perlu memulakan perkhidmatan Websocket melalui Pelayan Swoole. Kami boleh memulakan perkhidmatan Websocket mudah melalui kod berikut:

<?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();

Dalam kod di atas, kami mencipta pelayan WebSocket dan mendengar port 8000. Dalam acara terbuka, kami akan menerima permintaan sambungan daripada pelanggan dan menghantar mesej alu-aluan kepadanya. Dalam acara mesej, kami menerima mesej yang dihantar oleh pelanggan dan membalas dengan mesej. (Mesej balasan di sini hanyalah contoh mudah, dan perlu diubah suai mengikut keperluan sebenar dalam aplikasi sebenar.)

Perlu diingatkan di sini bahawa apabila menggunakan Websocket proksi terbalik Nginx, kita mesti menukar pelayan WebSocket Swoole Ikat pada port di bawah protokol TCP, bukan port di bawah protokol HTTP. Oleh itu, kita perlu menetapkan parameter ke-3 kepada SWOOLE_SOCK_TCP.

Kami juga boleh menggunakan mod berbilang proses Swoole untuk meningkatkan prestasi. Dalam parameter ke-4, kita boleh menetapkannya kepada SWOOLE_PROCESS dan menentukan nombor untuk mewakili bilangan proses.

Dalam aplikasi sebenar, kami mungkin perlu menggunakan beberapa pangkalan data atau fungsi cache dalam perkhidmatan Websocket, yang boleh dilaksanakan dengan mudah melalui fungsi suntikan kebergantungan ThinkPHP6.

3. Kod bahagian hadapan

Akhir sekali, mari kita lihat cara kod bahagian hadapan menggunakan 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");
};

Dalam kod di atas, kami berkomunikasi dengan pelayan melalui objek WebSocket. Apabila sambungan dibuka, peristiwa onopen dicetuskan, apabila mesej diterima, acara onmessage dicetuskan, dan apabila sambungan ditutup, acara onclose dicetuskan.

Perlu diingatkan bahawa protokol di sini mestilah ws, bukan http atau https.

4. Ringkasan

Melalui pengenalan di atas, kita dapati bahawa sangat mudah untuk menggunakan Websocket proksi terbalik Nginx dalam ThinkPHP6. Anda hanya perlu melakukan beberapa konfigurasi asas dalam Nginx dan memulakan pelayan WebSocket dalam Swoole, dan anda boleh menggunakan WebSocket untuk berkomunikasi di bahagian hadapan. Jika anda menghadapi masalah dalam aplikasi sebenar, anda boleh merujuk kepada kod di atas untuk membetulkannya.

Atas ialah kandungan terperinci Menggunakan Websocket proksi terbalik Nginx dalam ThinkPHP6. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!