PHP和WebSocket: 實現即時資料傳輸的最佳實踐-php教程-PHP中文網

PHP和WebSocket: 實現即時資料傳輸的最佳實踐

WBOY

發布： 2023-12-17 21:22:02

原創

670 人瀏覽過

PHP和WebSocket: 实现实时数据传输的最佳实践

近年來，隨著網路的快速發展，即時通訊的需求也越來越強烈，而WebSocket的出現為實現即時資料傳輸提供了更優雅的解決方案。而在Web開發中，PHP語言在主流的後端語言中也佔有一席之地。那麼，如何使用PHP和WebSocket實現即時資料傳輸呢？

一、什麼是WebSocket

WebSocket是全雙工通訊協議，它透過HTTP/HTTPS協定的80或443埠進行通訊。 WebSocket在建立連線時，客戶端和伺服器端都可以向對方發送訊息，而不需要進行「請求-回應」的模式，因此具有即時性較強、雙向通訊、開銷較小等優點，適用於即時聊天、線上遊戲等需要快速互動的場景。

二、PHP中使用WebSocket

Web開發中常用的PHP框架有Laravel、CodeIgniter等。以下將以Laravel為例，介紹如何使用PHP和WebSocket實現即時資料傳輸。

安裝Ratchet

Ratchet是PHP的一個WebSocket函式庫，可用來實作WebSocket服務端。在Laravel專案中，可透過composer進行安裝，指令如下：

$ composer require cboden/ratchet

登入後複製

建立WebSocket控制器

在Laravel專案的app/Http/Controllers目錄下建立WebSocket控制器，命名為ChatController。此控制器繼承於Ratchet的MessageComponentInterface接口，並重寫其中的onOpen、onMessage、onClose、onError方法，如下所示：

<?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 ($from != $client) {
                $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();
    }
}

登入後複製

在該控制器中，$clients為客戶端連接物件的集合，onOpen方法表示有新客戶端連線時的回呼方法，onMessage方法表示接收到客戶端訊息時的回呼方法，onClose方法表示客戶端斷開連線時的回呼方法，onError方法表示連線出現錯誤時的回呼方法。

建立WebSocket服務

在Laravel專案的routes/web.php路由檔案中新增如下程式碼：

use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;
use AppHttpControllersChatController;

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

登入後複製

該程式碼表示建立了一個WebSocket服務，監聽本地8080端口，服務對應的控制器為ChatController。

客戶端程式碼

在前端頁面中，可透過JavaScript程式碼建立與WebSocket服務的連接，如下所示：

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

conn.onopen = function (e) {
    console.log("Connection established!");
};

conn.onmessage = function (e) {
    console.log("Received: " + e.data);
};

conn.onclose = function (e) {
    console.log("Connection closed!");
};

conn.onerror = function (e) {
    console.log("Error occurred: " + e.data);
};

function sendMessage() {
    var input = document.getElementById("messageInput");
    conn.send(input.value);
    input.value = "";
}

登入後複製

該程式碼表示建立了WebSocket與服務端的連接，收到服務端訊息時輸出到控制台，發送訊息時呼叫send方法發送。