隨著移動互聯網技術的迅猛發展，用戶對即時通訊和實時交互的需求逐漸增強。而 WebSocket 協議作為 Web 實時通信的一個重要協議，其具有全雙工通信、實時推送、低延遲等特點，已經成為實時交互場景下的首選協議。因此，在 Web 開發中，我們需要掌握如何使用 WebSocket 實現實時通信。

在 PHP 中，我們可以使用 Swoole 擴展來實現 WebSocket 功能。然而，在 Swoole 部署和設置方面需要花費比較多的時間精力，對于一些對 Swoole 不熟悉的開發者來說，學習成本也比較高。

而今天，我們要介紹的是如何在 ThinkPHP6 中使用 WebSocket。

1. 安裝擴展

在使用 ThinkPHP6 中的 WebSocket 之前，我們需要安裝 topthink/thinker 擴展。

composer require topthink/thinker:dev-master

登錄后復制

topthink/thinker 是一個命令行工具，用于在 ThinkPHP6 中運行 PHP 代碼和管理異步任務。

2. 配置 WebSocket

我們需要在項目的配置文件 config/socket.php 中配置 WebSocket。

<?php
return [
    // WebSocket服務器地址，使用內網穿透時填寫內網地址
    'server' => '127.0.0.1:9501',

    // WebSocket的應用類，需要實現     hinkworkerServer 接口
    'worker_class' => 'appcontrollerWebSocket',
];

登錄后復制

我們需要指定 server 的地址以及實現 Server 接口的類 worker_class，在這里我們將實現 WebSocket 功能的控制器類命名為 WebSocket，放在 appcontroller 目錄下。

3. 實現 WebSocket

我們在 appcontroller 目錄下創建一個名為 WebSocket 的控制器，在控制器中實現 Server 接口。

<?php
namespace appcontroller;

use thinkworkerServer;

class WebSocket implements Server
{
    protected $socket = 'websocket://127.0.0.1:9501';

    public function onMessage($connection, $data)
    {
        foreach ($this->worker->connections as $conn) {
            $conn->send('user ' . $connection->id . ' said: ' . $data);
        }
    }

    public function onConnect($connection)
    {
        echo "new connection from ip " . $connection->getRemoteIp() . "
";
    }

    public function onClose($connection)
    {
        echo "connection closed: " . $connection->id . "
";
    }

    public function onWorkerStart($worker)
    {
        // 初始化
    }
}

登錄后復制

在 WebSocket 控制器類中，我們需要實現 onMessage、onConnect、onClose 和 onWorkerStart 四個方法。

onMessage: 當客戶端發送數據時，會觸發 onMessage 方法，參數 $connection 表示客戶端的連接對象，$data 表示客戶端發送的數據。onConnect: 在客戶端連接的時候會觸發 onConnect 方法，參數 $connection 表示客戶端的連接對象。onClose: 在客戶端斷開連接的時候會觸發 onClose 方法，參數 $connection 表示客戶端的連接對象。onWorkerStart: 在工作進程啟動的時候會觸發 onWorkerStart 方法，參數 $worker 表示當前工作進程的對象。