Swoole WebSocket

一、概述

Swoole是一款PHP語言的非同步、並行、高性能網路通信框架，其中包括對WebSocket協議的支持。WebSocket是一種在單個TCP連接上進行全雙工通信的協議，可以用於實時通信，如聊天室、實時遊戲等。

Swoole WebSocket可以讓我們輕鬆地實現一種高性能、實時的通信方式，並且支持非同步IO和多線程等高級功能。

二、與HTTP協議的區別

WebSocket協議與HTTP協議有一些重要的不同之處：

1、HTTP協議是一個請求-響應模式，客戶端發送請求，伺服器返迴響應並斷開連接。而WebSocket是一種真正的雙向通信協議，允許伺服器發送消息到客戶端，而不需要由客戶端首先發起請求。

2、HTTP協議每次請求都需要先建立連接，發送完畢立即斷開連接，下次請求需要重新建立連接。而WebSocket協議在握手時建立連接，在服務端或客戶端斷開前一直保持連接。

3、HTTP協議的數據傳輸都是通過文本格式方式傳輸，而WebSocket協議可以傳輸二進位格式的數據。

三、使用Swoole實現WebSocket通信

使用Swoole實現WebSocket通信，需要以下幾個步驟：

1. 創建WebSocket伺服器

創建一個WebSocket伺服器，需要使用Swoole提供的swoole_websocket_server類：

$server = new swoole_websocket_server('0.0.0.0', 9501);

2. 監聽WebSocket連接事件

當有WebSocket連接請求時，需要監聽onOpen事件，通知伺服器有客戶端連接：

$server->on('open', function (swoole_websocket_server $server, swoole_http_request $request) {
    echo "New client connected: {$request->fd}\n";
});

3. 監聽WebSocket消息事件

當接收到客戶端發送的WebSocket消息時，需要監聽onMessage事件，處理這個消息並發送響應消息到客戶端：

$server->on('message', function (swoole_websocket_server $server, swoole_websocket_frame $frame) {
    echo "Received message: {$frame->data}\n";
    // 處理消息並發送響應消息
    $server->push($frame->fd, "Hello, client!");
});

4. 監聽WebSocket關閉事件

當客戶端關閉WebSocket連接時，需要監聽onClose事件，通知伺服器有客戶端斷開連接：

$server->on('close', function(swoole_websocket_server $server, int $fd) {
    echo "Client disconnected: {$fd}\n";
});

5. 啟動WebSocket伺服器

最後，啟動WebSocket伺服器：

$server->start(); 

四、示例代碼

// 創建WebSocket伺服器
$server = new swoole_websocket_server('0.0.0.0', 9501);

// 監聽WebSocket連接事件
$server->on('open', function (swoole_websocket_server $server, swoole_http_request $request) {
    echo "New client connected: {$request->fd}\n";
});

// 監聽WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, swoole_websocket_frame $frame) {
    echo "Received message: {$frame->data}\n";
    // 處理消息並發送響應消息
    $server->push($frame->fd, "Hello, client!");
});

// 監聽WebSocket關閉事件
$server->on('close', function(swoole_websocket_server $server, int $fd) {
    echo "Client disconnected: {$fd}\n";
});

// 啟動WebSocket伺服器
$server->start();