Bagaimana untuk berkomunikasi dalam masa nyata dengan protokol WebSocket melalui PHP

Cara berkomunikasi dalam masa nyata dengan protokol WebSocket melalui PHP

Dengan pembangunan aplikasi web, komunikasi masa nyata telah menjadi sangat penting dalam banyak senario, seperti sembang dalam talian, sebut harga saham, dll. Protokol WebSocket direka untuk mewujudkan sambungan komunikasi masa nyata antara pelayar web dan pelayan. Artikel ini akan memperkenalkan cara menggunakan protokol PHP dan WebSocket untuk komunikasi masa nyata dan memberikan contoh kod yang berkaitan.

1. Pengenalan kepada protokol WebSocket
Protokol WebSocket ialah protokol komunikasi dupleks penuh yang dibina pada protokol TCP. Ia boleh membolehkan pelayan menolak mesej secara aktif kepada klien dan menerima mesej daripada klien. Berbanding dengan protokol HTTP tradisional, protokol WebSocket mempunyai ciri-ciri berikut:

1. Komunikasi dua hala masa nyata: WebSocket boleh mencapai komunikasi dua hala masa nyata antara pelayan dan pelanggan, tanpa pelanggan sentiasa mengundi pelayan .
2. Overhed komunikasi yang lebih rendah: Berbanding dengan protokol HTTP, protokol WebSocket mempunyai pengepala komunikasi yang lebih kecil, yang mengurangkan overhed komunikasi.
3. Prestasi yang lebih tinggi: Oleh kerana protokol WebSocket boleh mewujudkan sambungan yang panjang, ia mengurangkan overhed jabat tangan setiap permintaan, dengan itu meningkatkan prestasi komunikasi.

2. Sambungan WebSocket PHP
PHP secara rasmi tidak memberikan sokongan langsung untuk WebSocket, tetapi anda boleh melaksanakan fungsi WebSocket dengan memasang dan menggunakan sambungan. Pada masa ini, sambungan PHP WebSocket yang lebih biasa digunakan termasuk yang berikut:

1. Ratchet: perpustakaan WebSocket PHP ringan yang menyediakan sokongan untuk pelayan dan klien WebSocket, mudah digunakan dan mempunyai fungsi yang komprehensif.
2. Swoole: Pustaka komunikasi rangkaian PHP berprestasi tinggi yang boleh melaksanakan pelayan dan klien WebSocket.
3. Workerman: Rangka kerja Socket PHP berbilang benang yang menyokong pelayan dan pelanggan WebSocket.

Disebabkan had ruang, artikel ini akan menggunakan sambungan Ratchet sebagai contoh untuk demonstrasi.

3. Pasang sambungan Ratchet
Anda boleh memasang sambungan Ratchet melalui Komposer, laksanakan arahan berikut untuk memasang:

composer require cboden/ratchet

4. Buat pelayan WebSocket
Berikut ialah pelaksanaan pelayan WebSocket yang mudah, yang boleh mengembalikan mesej yang diterima Kepada pelanggan:

<?php
use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

require 'vendor/autoload.php';

class MyWebSocketServer implements MessageComponentInterface {
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
    }

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

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
    }

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

$server = App::make('RatchetServerIoServer', [
    new AppMyWebSocketServer()
]);

$server->run();

5. Buat klien WebSocket
Berikut adalah pelaksanaan klien WebSocket mudah yang boleh berkomunikasi dengan pelayan di atas:

<?php
use RatchetClientWebSocket;
use RatchetClientConnector;
use ReactEventLoopFactory as EventLoopFactory;

require 'vendor/autoload.php';

$loop = EventLoopFactory::create();
$connector = new Connector($loop);

$connector('ws://localhost:8000')->then(function (WebSocket $conn) {
    $conn->on('message', function ($msg) use ($conn) {
        echo "Received: {$msg}
";
        $conn->close();
    });

    $conn->send('Hello, WebSocket Server!');
}, function (Exception $e) use ($loop) {
    echo "Could not connect: {$e->getMessage()}
";
    $loop->stop();
});

$loop->run();

6. Jalankan perkhidmatan WebSocket
Mulakan pelayan WebSocket melalui baris arahan:

php server.php

Kemudian laksanakan kod klien:

php client.php

Kemudian komunikasi masa nyata antara pelanggan dan pelayan boleh dicapai.

Ringkasan:
Artikel ini memperkenalkan secara ringkas cara menggunakan protokol PHP dan WebSocket untuk komunikasi masa nyata, dan menyediakan contoh kod yang berkaitan untuk sambungan Ratchet. Melalui protokol WebSocket, kami boleh melaksanakan pelayan untuk menolak mesej secara aktif kepada pelanggan dan mencapai komunikasi dua hala masa nyata. Menggunakan sambungan PHP WebSocket, kami boleh membuat pelayan dan pelanggan WebSocket dengan mudah dan mencapai komunikasi masa nyata melalui kod mudah.

Atas ialah kandungan terperinci Bagaimana untuk berkomunikasi dalam masa nyata dengan protokol WebSocket melalui PHP. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!