thinkphp websocket

<?php

// 引入ThinkPHP框架和WebSocket相关的类库
use think\facade\App;
use Swoole\WebSocket\Server;

class WebSocketController
{
    protected $ws;

    public function __construct()
    {
        // 创建WebSocket服务器实例
        $this->ws = new Server("0.0.0.0", 9502);

        // 绑定事件回调函数
        $this->ws->on('open', [$this, 'onOpen']);
        $this->ws->on('message', [$this, 'onMessage']);
        $this->ws->on('close', [$this, 'onClose']);

        // 启动WebSocket服务器
        $this->ws->start();
    }

    // 当有新的客户端连接时触发
    public function onOpen($ws, $request)
    {
        echo "New connection\n";
        // 可以在这里处理新连接的逻辑，比如发送欢迎消息
        $ws->push($request->fd, "Welcome to ThinkPHP WebSocket server!");
    }

    // 当接收到客户端消息时触发
    public function onMessage($ws, $frame)
    {
        echo "Received: {$frame->data}\n";
        // 处理接收到的消息并返回响应
        $ws->push($frame->fd, "Server received: {$frame->data}");
    }

    // 当客户端断开连接时触发
    public function onClose($ws, $fd)
    {
        echo "Client {$fd} closed\n";
        // 可以在这里处理客户端断开的逻辑
    }
}

// 在ThinkPHP中启动WebSocket服务
if (!App::instance()->isCli()) {
    exit('This script can only be run in CLI mode.');
}

(new WebSocketController());

解释说明：

1. 引入必要的类库：使用think\facade\App来确保我们是在CLI模式下运行，并引入Swoole的WebSocket服务器类。
2. 创建WebSocket服务器实例：在构造函数中创建一个WebSocket服务器实例，并绑定三个主要事件：open、message和close。
3. 事件处理函数：
   • onOpen：当有新的客户端连接时触发，可以在这里发送欢迎消息。
   • onMessage：当接收到客户端消息时触发，可以处理消息并返回响应。
   • onClose：当客户端断开连接时触发，可以在这里处理断开的逻辑。
4. 启动WebSocket服务器：在构造函数的最后调用$this->ws->start()来启动WebSocket服务器。
5. CLI模式检查：确保脚本只在CLI模式下运行。

这个示例代码展示了如何在ThinkPHP框架中集成WebSocket服务器，并处理基本的连接、消息接收和断开事件。