Bagaimana untuk mencapai komunikasi masa nyata menggunakan PHP dan WebSocket

Dengan perkembangan teknologi Internet yang berterusan, komunikasi masa nyata telah menjadi bahagian yang amat diperlukan dalam kehidupan seharian. Komunikasi masa nyata yang cekap, kependaman rendah boleh dicapai menggunakan teknologi WebSockets, dan PHP, sebagai salah satu bahasa pembangunan yang paling banyak digunakan dalam bidang Internet, juga menyediakan sokongan WebSocket yang sepadan. Artikel ini akan memperkenalkan cara menggunakan PHP dan WebSocket untuk mencapai komunikasi masa nyata, dan menyediakan contoh kod khusus.

1. Apakah itu WebSocket

WebSocket ialah protokol untuk komunikasi dupleks penuh melalui satu sambungan TCP. Berbeza dengan protokol HTTP, selepas sambungan WebSocket diwujudkan, data boleh ditukar terus antara pelayan dan klien tanpa perlu berinteraksi melalui permintaan dan respons HTTP. Ini membolehkan WebSocket mencapai kependaman rendah, komunikasi masa nyata berkecekapan tinggi, dan sesuai untuk permainan dalam talian, bilik sembang dan senario lain yang memerlukan konkurensi tinggi dan interaksi masa nyata.

2. Bagaimana PHP menyokong WebSocket

PHP menyediakan beberapa perpustakaan dan rangka kerja untuk melaksanakan WebSocket, seperti Ratchet, Wrench, dll. Pustaka dan rangka kerja ini dilaksanakan berdasarkan sambungan PHP Swoole ialah rangka kerja komunikasi rangkaian berprestasi tinggi untuk PHP yang menyokong IO tak segerak, coroutine dan ciri-ciri lain Ia sesuai untuk membina pelayan web berprestasi tinggi, permainan pelayan dan aplikasi lain.

Dalam artikel ini, kami akan menggunakan perpustakaan Ratchet untuk melaksanakan WebSocket. Ratchet menyediakan pelaksanaan protokol RFC6455 WebSocket berasaskan piawai dan mempunyai ciri-ciri kemudahan penggunaan, fleksibiliti dan kebolehskalaan yang tinggi. Pada masa yang sama, Ratchet juga menyokong sub-protokol WebSockets, seperti STOMP, WAMP, dsb., dan menyediakan dokumentasi lengkap dan kod sampel untuk memudahkan pembangun bermula dengan cepat.

3. Contoh kod untuk mencapai komunikasi masa nyata

Di bawah ini kami menggunakan aplikasi bilik sembang mudah untuk menunjukkan cara menggunakan PHP dan WebSocket untuk mencapai komunikasi masa nyata.

1. Pasang Ratchet

Pasang Ratchet secara setempat atau di sebelah pelayan, anda boleh memasangnya melalui Komposer:

composer require cboden/ratchet

2. Menulis pelayan WebSocket

Buat pelayan fail PHP berikut:

Buat pelayan fail PHP:

. Kod di atas mencipta Dibuat pelayan bilik sembang ringkas, mendengar pada port 8080, menunggu sambungan pelanggan. Apabila klien menyambung, kaedah onOpen dipanggil dan objek sambungan klien disimpan ke objek ObjectStorage. Apabila pelanggan menghantar mesej, kaedah onMessage dipanggil untuk menghantar mesej kepada semua pelanggan yang disambungkan ke pelayan. Apabila klien memutuskan sambungan, kaedah onClose akan dipanggil untuk memadamkan objek sambungan klien daripada objek ObjectStorage.

3. Menulis klien WebSocket

Buat klien fail HTML.html dengan kod berikut:

<?php
require dirname(__DIR__) . '/vendor/autoload.php';

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetWebSocketMessageComponentTrait;

class Chat implements MessageComponentInterface
{
    use MessageComponentTrait;

    protected $clients;

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

    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients->attach($conn);
        echo "New connection! ({$conn->resourceId})
";
    }

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

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        echo "An error has occurred: {$e->getMessage()}
";
        $conn->close();
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        foreach ($this->clients as $client) {
            if ($from !== $client) {
                $client->send($msg);
            }
        }
    }
}

$server = new RatchetWebSocketWsServer(new Chat());
$loop = ReactEventLoopFactory::create();
$socket = new ReactSocketServer('0.0.0.0:8080', $loop);
$server = new RatchetServerIoServer($server, $socket, $loop);
echo "Server started
";
$server->run();

Kod di atas mencipta pelanggan bilik sembang ringkas, mewujudkan sambungan dengan pelayan melalui WebSocket dan mendengar mesej pelayan . Apabila pengguna memasukkan mesej dalam kotak teks dan mengklik butang hantar atau menekan kekunci enter, mesej itu dihantar ke pelayan dan dipaparkan dalam tetingkap sembang.

4. Jalankan pelayan dan klien WebSocket

Mulakan pelayan WebSocket dalam terminal:

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>Chat Room</title>
    <style>
        #messages {
            margin-bottom: 10px;
            padding: 5px;
            border: 1px solid #ddd;
            overflow-y: scroll;
            height: 200px;
        }
    </style>
</head>
<body>
    <div>
        <input type="text" id="input-message" placeholder="Write a message...">
        <button id="btn-send">Send</button>
    </div>
    <div id="messages"></div>

    <script>
        var conn = new WebSocket('ws://localhost:8080');
        var messages = document.getElementById('messages');
        var inputMessage = document.getElementById('input-message');
        var btnSend = document.getElementById('btn-send');

        conn.onopen = function(e) {
            messages.innerHTML += '<div>Connected to server</div>'
        };

        conn.onmessage = function(e) {
            messages.innerHTML += '<div>' + e.data + '</div>'
        };

        conn.onerror = function(e) {
            console.log('An error occurred: ' + e.data);
        };

        conn.onclose = function(e) {
            messages.innerHTML += '<div>Connection closed</div>'
        };

        btnSend.onclick = function() {
            if (inputMessage.value) {
                conn.send(inputMessage.value);
                inputMessage.value = '';
            }
        };

        inputMessage.addEventListener('keydown', function(e) {
            if (e.keyCode === 13 && inputMessage.value.trim()) {
                conn.send(inputMessage.value);
                inputMessage.value = '';
            }
        });
    </script>
</body>
</html>

Buka halaman klien client.html dalam pelayar web anda, masukkan mesej anda dan hantar, anda akan melihat mesej dihantar ke pelayan , dan pelanggan lain yang disambungkan ke pelayan akan menerima mesej yang sama. Dengan cara ini, kami berjaya melaksanakan komunikasi masa nyata menggunakan PHP dan WebSocket.

4. Ringkasan

Sebagai protokol komunikasi masa nyata berkependaman rendah, WebSocket menyediakan cara baharu interaksi masa nyata. Pada masa yang sama, PHP menyediakan banyak perpustakaan dan rangka kerja sokongan WebSocket, membolehkan kami membina aplikasi WebSocket yang cekap, pantas dan stabil dengan mudah. Saya harap artikel ini dapat membantu anda lebih memahami dan menggunakan teknologi WebSocket serta melaksanakan lebih banyak aplikasi komunikasi masa nyata.

Atas ialah kandungan terperinci Bagaimana untuk mencapai komunikasi masa nyata menggunakan PHP dan WebSocket. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!