Penyepaduan PHP dan WebSocket merealisasikan pembangunan ruang sembang masa nyata

Dalam bidang pembangunan web, fungsi sembang masa nyata telah menjadi semakin popular. Ia membantu pengguna berinteraksi dengan mudah dalam masa nyata dan meningkatkan komunikasi dan pemahaman. Untuk melaksanakan sembang masa nyata, kita perlu menggunakan protokol WebSocket dan memerlukan bahasa pengaturcaraan yang boleh mengendalikan permintaan WebSocket. Dalam artikel ini, kami akan memperkenalkan cara melaksanakan pembangunan bilik sembang masa nyata menggunakan penyepaduan PHP dan WebSocket.

WebSocket ialah protokol komunikasi dupleks penuh yang membolehkan penghantaran data masa nyata antara penyemak imbas dan pelayan. Tidak seperti permintaan HTTP, pelayan boleh menolak data ke penyemak imbas selepas sambungan WebSocket diwujudkan. Oleh itu, kita boleh melakukan komunikasi data dua hala antara pelanggan dan pelayan melalui WebSocket. Apabila pengguna menyertai atau keluar dari bilik sembang, mesej itu boleh segera dihantar kepada pengguna dalam talian yang lain Ini adalah prinsip asas sembang masa nyata.

Pertama, kita perlu mencipta skrip PHP pada bahagian pelayan untuk mengendalikan permintaan WebSocket. Sambungan swoole PHP boleh membantu kami membangunkan pelayan WebSocket. Seterusnya, kami akan melaksanakan aplikasi sembang kami langkah demi langkah.

1. Pasang sambungan swoole

Untuk menggunakan sambungan swoole, kita perlu memasangnya terlebih dahulu. Gunakan arahan berikut untuk memasang swoole dalam sistem Linux:

pecl install swoole

Jika anda menggunakan PHP dalam sistem Windows, anda boleh memuat turun dan memasang fail DLL yang berkaitan secara manual daripada repositori GitHub swoole.

2. Sediakan pelayan WebSocket

Setelah kami berjaya memasang sambungan swoole, kami boleh mula menggunakannya untuk mencipta pelayan WebSocket. Berikut ialah kod asas untuk mencipta pelayan WebSocket:

//创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 9501);

//监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

//监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) {
    echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}
";
    $server->push($frame->fd, json_encode(["hello", "world"]));
});

//监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) {
    echo "client {$fd} closed
";
});

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

Dalam coretan kod ini, kami mencipta pelayan WebSocket dan mendaftarkan fungsi pengendali acara. Dalam acara "terbuka" kami akan mencetak mesej bahawa sambungan WebSocket dibuka. Dalam acara "mesej", kami akan mencetak maklumat tentang sesi WebSocket dan menghantar mesej kepada pelanggan. Dalam acara "tutup" kami akan mencetak mesej bahawa sambungan WebSocket ditutup.

3. Sediakan logik bilik sembang

Kini kami telah berjaya mencipta pelayan WebSocket dan menyediakan fungsi pengendalian acara. Seterusnya, kami boleh mula melaksanakan logik bilik sembang kami.

Kami perlu menyediakan fungsi siaran mesej untuk memberitahu semua pengguna dalam talian apabila pengguna menyertai atau keluar dari bilik sembang. Berikut ialah kod fungsi penyiaran mesej:

//广播消息
function broadcast($server, $frame, $users) {
    $data = json_decode($frame->data, true);
    switch ($data['type']) {
        case 'enter':
            $users[$frame->fd] = $data['name'];
            $msg = $data['name'] . ' joined the room.';
            break;
        case 'leave':
            $name = $users[$frame->fd];
            unset($users[$frame->fd]);
            $msg = $name . ' left the room.';
            break;
        case 'msg':
            $name = $users[$frame->fd];
            $msg = $name . ': ' . $data['msg'];
            break;
    }
    foreach ($server->connections as $fd) {
        $server->push($fd, json_encode(['type' => 'msg', 'msg' => $msg]));
    }
}

Dalam coretan kod ini, kami menggunakan pernyataan suis untuk mengendalikan pelbagai jenis mesej. Apabila pengguna menyertai atau meninggalkan bilik sembang, kami mengemas kini senarai pengguna dan menghantar mesej pemberitahuan. Apabila pengguna menghantar mesej, kami akan mengawal mesej dengan nama pengguna dan menyiarkannya kepada semua pengguna dalam talian.

4. Lengkapkan kod bilik sembang

Sekarang kita sudah sediakan semua komponen yang diperlukan, kita boleh mula menulis kod bilik sembang yang lengkap. Berikut ialah kod bilik sembang yang lengkap:

//创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 9501);

//定义用户列表
$users = [];

//广播消息
function broadcast($server, $frame, $users) {
    $data = json_decode($frame->data, true);
    switch ($data['type']) {
        case 'enter':
            $users[$frame->fd] = $data['name'];
            $msg = $data['name'] . ' joined the room.';
            break;
        case 'leave':
            $name = $users[$frame->fd];
            unset($users[$frame->fd]);
            $msg = $name . ' left the room.';
            break;
        case 'msg':
            $name = $users[$frame->fd];
            $msg = $name . ': ' . $data['msg'];
            break;
    }
    foreach ($server->connections as $fd) {
        $server->push($fd, json_encode(['type' => 'msg', 'msg' => $msg]));
    }
}

//监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

//监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) use ($users) {
    broadcast($server, $frame, $users);
});

//监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) use ($users) {
    unset($users[$fd]);
    echo "client {$fd} closed
";
});

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

Dalam coretan kod ini, kami menyimpan maklumat semua pengguna dalam talian dalam tatasusunan $users. Kami akan mengemas kini tatasusunan ini apabila pengguna menyertai atau keluar dari bilik sembang. Dalam acara mesej WebSocket, kami akan menyiarkan mesej menggunakan fungsi broadcast(). Dalam acara tutup sambungan WebSocket, kami akan mengalih keluar pengguna yang terputus daripada tatasusunan $users.

5 Uji bilik sembang anda

Kini kami telah berjaya mencipta aplikasi bilik sembang kami. Kami boleh mengujinya dalam semua penyemak imbas yang menyokong WebSocket, seperti Google Chrome, Firefox dan Safari, dsb. Berikut ialah langkah-langkah bagaimana untuk menguji bilik sembang anda:

1. Jalankan kod di atas menggunakan arahan PHP
2. Buka fail index.html dalam pelayar anda
3. Masukkan nama pengguna dan klik butang "Masukkan Bilik Sembang"
4. Dalam kotak sembang Masukkan mesej anda dan klik butang "Hantar"

Anda sepatutnya dapat melihat mesej anda disiarkan dalam kotak sembang semua pengguna dalam talian.

Ringkasan

Dalam artikel ini, kami memperkenalkan cara melaksanakan pembangunan bilik sembang masa nyata menggunakan PHP dan penyepaduan WebSocket. Kami menggunakan sambungan swoole untuk mencipta pelayan WebSocket dan menulis aplikasi bilik sembang ringkas. Melalui artikel ini, anda boleh belajar cara menggunakan protokol WebSocket untuk mewujudkan sambungan penghantaran data masa nyata, melaksanakan pelayan WebSocket dalam PHP dan menggunakannya untuk melaksanakan aplikasi bilik sembang.

Atas ialah kandungan terperinci Penyepaduan PHP dan WebSocket merealisasikan pembangunan ruang sembang masa nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!