PHP dan WebSocket: Membina platform sembang masa nyata berprestasi tinggi

Dengan perkembangan berterusan Internet, komunikasi masa nyata telah menjadi fungsi penting untuk banyak tapak web dan aplikasi, jadi membina platform sembang masa nyata berprestasi tinggi menjadi sangat penting. Dalam pembangunan, menggunakan PHP dan WebSocket boleh memenuhi keperluan komunikasi masa nyata, dan gabungan kedua-dua teknologi ini juga boleh meningkatkan prestasi platform dengan sangat baik.

WebSocket ialah protokol komunikasi dupleks penuh yang melaluinya sambungan berpanjangan boleh diwujudkan antara penyemak imbas dan pelayan, supaya pelayan boleh menghantar mesej masa nyata secara aktif kepada pelanggan. Protokol ini dicirikan oleh kecekapan tinggi, kebolehpercayaan, dan prestasi masa nyata yang baik, jadi ia sangat sesuai untuk membina platform komunikasi masa nyata.

PHP kini merupakan salah satu bahasa pembangunan web yang paling banyak digunakan, dan terdapat banyak rangka kerja matang yang tersedia, seperti Laravel, Symfony, dsb. Gunakan PHP untuk membina platform sembang masa nyata, gunakan WebSocket sebagai protokol komunikasi, dan gunakan alatan yang disediakan oleh rangka kerja untuk melaksanakan logik perniagaan dengan pantas untuk mencapai pembangunan pesat dan prestasi tinggi.

Yang berikut akan membina contoh platform sembang web berdasarkan rangka kerja Laravel, dan menggunakan WebSocket untuk menolak mesej masa nyata. Mula-mula anda perlu memuat turun dan memasang perpustakaan Ratchet, yang merupakan perpustakaan pelayan WebSocket berdasarkan ReactPHP dan sangat mudah digunakan.

Pasang perpustakaan Ratchet:

composer require cboden/ratchet

Kemudian tentukan laluan WebSocket dalam fail routes/web.php: routes/web.php文件中定义WebSocket的路由：

use AppHttpControllersChatController;
use RatchetHttpHttpServer;
use RatchetServerIoServer;
use RatchetWebSocketWsServer;

Route::get('/chat', function () {
    $server = IoServer::factory(
        new HttpServer(
            new WsServer(
                new ChatController()
            )
        ),
        8080
    );
    $server->run();
})->name('chat');

ChatController就是WebSocket的控制器，用于处理WebSocket的连接和消息。我们在app/Http/Controllers/ChatController.php中定义：

namespace AppHttpControllers;

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class ChatController implements MessageComponentInterface
{
    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 onMessage(ConnectionInterface $from, $msg)
    {
        foreach ($this->clients as $client) {
            if ($client !== $from) {
                $client->send($msg);
            }
        }
    }

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

ChatController实现了MessageComponentInterface接口，包含了四个方法：onOpen、onMessage、onClose和onError。其中，onOpen在连接建立时触发，onMessage在接收到消息时触发，onClose在连接关闭时触发，onError在发生错误时触发。在onOpen中，将连接保存到$clients数组中；在onMessage中，将接收到的消息发送给所有其他连接；在onClose中，从$clients数组中删除关闭的连接；在onError

var conn = new WebSocket("ws://localhost:8080/chat");

conn.onmessage = function (event) {
    // 接收到聊天信息后的处理
};

function sendChatMessage(message) {
    conn.send(message);
}

ChatController ialah pengawal WebSocket, digunakan untuk memproses sambungan dan mesej WebSocket. Kami mentakrifkan dalam app/Http/Controllers/ChatController.php:

rrreee

ChatController melaksanakan antara muka MessageComponentInterface, yang mengandungi empat kaedah: onOpen, onMessage, onClose dan onError. Antaranya, onOpen dicetuskan apabila sambungan diwujudkan, onMessage dicetuskan apabila mesej diterima, onClose dicetuskan apabila sambungan ditutup , dan onError Menyala apabila ralat berlaku. Dalam onOpen, simpan sambungan ke tatasusunan $clients dalam onMessage, hantar mesej yang diterima ke semua sambungan lain dalam In ; onClose, padam sambungan tertutup daripada tatasusunan $clients dalam onError, kendalikan ralat dan tutup sambungan.

Seterusnya, gunakan JavaScript di bahagian hadapan untuk menyambung ke WebSocket, menghantar maklumat sembang ke pelayan dan menerima maklumat sembang dalam masa nyata. Kod khusus adalah seperti berikut:

rrreee

Melalui WebSocket, komunikasi dua hala masa nyata boleh dilakukan antara bahagian hadapan dan pelayan, dan fungsi sembang masa nyata yang cekap, boleh dipercayai dan direalisasikan. 🎜🎜Untuk meringkaskan, menggunakan PHP dan WebSocket untuk membina platform sembang masa nyata boleh menggunakan sepenuhnya sifat masa nyata WebSocket dan kecekapan, fleksibiliti dan rangka kerja matang dan alatan PHP untuk meningkatkan prestasi dan kecekapan pembangunan platform. Artikel ini memberikan contoh berdasarkan Laravel dan Ratchet, dengan harapan dapat membantu pembaca membina platform sembang masa nyata. 🎜

Atas ialah kandungan terperinci PHP dan WebSocket: Membina platform sembang masa nyata berprestasi tinggi. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!