如何使用Swoole實作WebSocket伺服器

王林

發布： 2023-06-25 09:59:08

原創

935 人瀏覽過

WebSocket已經成為現代Web應用程式中的基本元素。它提供一種全雙工的通訊方式，使得伺服器和客戶端之間可以實現即時通訊。 Swoole是一個基於PHP的高效能網路通訊框架，它可以非常方便地實作WebSocket伺服器。

本文將介紹如何使用Swoole建立WebSocket伺服器。

安裝Swoole

為了安裝Swoole，您需要使用PECL（PHP Extension Community Library）。開啟終端機並輸入以下命令：

pecl install swoole

登入後複製

一旦安裝完成，Swoole擴充功能將自動載入到PHP擴充列表中。

建立WebSocket伺服器

建立WebSocket伺服器最簡單的方式是透過使用Swoole的WebSocket伺服器類別：

$server = new SwooleWebsocketServer("127.0.0.1", 9501);

$server->on('open', function (SwooleWebsocketServer $server, $request) {
    echo "Client {$request->fd} connected
";
});

$server->on('message', function (SwooleWebsocketServer $server, $frame) {
    echo "Received message: {$frame->data}
";

    // Broadcast message to all connected clients
    foreach ($server->connections as $fd) {
        $server->push($fd, $frame->data);
    }
});

$server->on('close', function (SwooleWebsocketServer $server, $fd) {
    echo "Client {$fd} disconnected
";
});

$server->start();

登入後複製

這個範例創建了一個本地WebSocket伺服器，並將其設定為監聽埠9501。它還增加了三個回呼函數：

open - 當新的WebSocket客戶端連接到伺服器時，將被呼叫。
message - 當伺服器接收到來自客戶端的訊息時，將會被呼叫。
close - 當客戶端斷開連線時，將會被呼叫。

在open函數中，我們向控制台輸出一個簡單的訊息，提示我們已經連接了一個新的客戶端。

在message函數中，我們會向控制台輸出接收到的訊息，並向所有已連接的客戶端廣播此訊息。

在close函數中，我們會向控制台輸出一個訊息，提示已斷開連線的客戶端的fd。

最後，我們透過呼叫start方法啟動WebSocket伺服器。

測試WebSocket伺服器

為了測試WebSocket伺服器，可以使用JavaScript的WebSocket API編寫一個簡單的客戶端。這裡提供一個非常簡單的範例：

// Connect to WebSocket server
const ws = new WebSocket('ws://127.0.0.1:9501');

// Send a message to the server
ws.onopen = function() {
    ws.send('Hello, server!');
};

// Receive a message from the server
ws.onmessage = function(event) {
    console.log('Received message:', event.data);
};

登入後複製

在這個範例中，我們建立一個WebSocket對象，並連接到剛才建立的WebSocket伺服器。我們也定義了兩個回呼函數：