源码

以下是一个使用ThinkPHP和Swoole实现WebSocket的简单示例：

1. 安装Swoole扩展

在终端中执行以下命令：

pecl install swoole

2. 在ThinkPHP中添加Swoole配置

在 `config.php` 文件中添加以下配置：

'swoole' => [
    'host' => '0.0.0.0',
    'port' => 9501,
    'worker_num' => 4,
    'daemonize' => false,
    'pid_file' => '/var/run/swoole.pid',
    'log_file' => '/var/log/swoole.log',
    'task_worker_num' => 4,
],

3. 创建WebSocket控制器

创建一个控制器，例如 `WebSocket.php`，并添加以下代码：

<?php

namespace app\index\controller;

use think\swoole\Server;
use swoole_websocket_server;
use swoole_websocket_frame;

class WebSocket extends Server
{
    protected $server;
    
    public function onOpen(swoole_websocket_server $server, swoole_http_request $request)
    {
        echo "WebSocket opened: {$request->fd}\n";
    }
    
    public function onMessage(swoole_websocket_server $server, swoole_websocket_frame $frame)
    {
        echo "WebSocket message: {$frame->data}\n";
        $server->push($frame->fd, "Hello, {$frame->data}!");
    }
    
    public function onClose(swoole_websocket_server $server, int $fd, int $reactorId)
    {
        echo "WebSocket closed: {$fd}\n";
    }
    
    public function onStart(swoole_websocket_server $server)
    {
        echo "WebSocket server started at http://{$this->host}:{$this->port}\n";
    }
    
    public function onShutdown(swoole_websocket_server $server)
    {
        echo "WebSocket server stopped\n";
    }
}

这个控制器继承了 `think\swoole\Server`，并实现了WebSocket服务器的事件方法 `onOpen`、`onMessage` 和 `onClose`。在 `onMessage` 方法中，我们向客户端发送一个包含客户端名称的欢迎消息。

4. 启动WebSocket服务器

在终端中执行以下命令启动WebSocket服务器：

php think swoole start -d

现在，你可以使用WebSocket客户端连接到服务器并发送消息。在控制台中，你将看到WebSocket服务器打印出每个事件的消息。

这只是一个简单的示例，你需要根据实际需求扩展该代码。