Swoole的WebSocket如何使用？WebSocket如何通信？

Swoole\WebSocket\Server

<?php
$server = new Swoole\WebSocket\Server("0.0.0.0", 9501);

// 当WebSocket客户端与服务器建立连接并完成握手时
$server->on('open', function (Swoole\WebSocket\Server $server, $request) {
    echo "客户端 {$request->fd} 已连接。\n";
    $server->push($request->fd, "欢迎，你是第 {$request->fd} 位用户！");
});

// 当服务器收到WebSocket客户端发送的数据帧时
$server->on('message', function (Swoole\WebSocket\Server $server, $frame) {
    echo "收到客户端 {$frame->fd} 的消息: {$frame->data}\n";

    // 假设我们想把收到的消息原样发回给发送者
    $server->push($frame->fd, "服务器回应: " . $frame->data);

    // 如果是广播，可以遍历所有连接的fd并push
    // foreach ($server->connections as $fd) {
    //     if ($server->isEstablished($fd)) { // 检查连接是否仍然存在
    //         $server->push($fd, "广播消息: " . $frame->data);
    //     }
    // }
});

// 当WebSocket客户端连接关闭时
$server->on('close', function (Swoole\WebSocket\Server $server, $fd) {
    echo "客户端 {$fd} 已断开连接。\n";
});

// 启动服务器
$server->start();
?>

onOpen

onMessage

$frame->data

onClose

// 假设你的Swoole WebSocket服务器运行在localhost:9501
const ws = new WebSocket('ws://localhost:9501');

ws.onopen = function(event) {
    console.log('WebSocket连接已建立！');
    ws.send('你好，Swoole！我是客户端。');
};

ws.onmessage = function(event) {
    console.log('收到服务器消息:', event.data);
};

ws.onclose = function(event) {
    console.log('WebSocket连接已关闭。');
};

ws.onerror = function(error) {
    console.error('WebSocket发生错误:', error);
};

// 你可以随时发送消息
// ws.send('这是另一条消息。');

onOpen

$request

Cookie

Authorization

$server->on('open', function (Swoole\WebSocket\Server $server, $request) {
    // 假设客户端在连接时通过查询参数传递了token
    // ws://localhost:9501/?token=YOUR_AUTH_TOKEN
    $token = $request->get['token'] ?? ''; // 或者从 $request->header['cookie'] 中解析
    if (empty($token) || !$this->isValidToken($token)) { // 假设有个isValidToken方法验证
        echo "客户端 {$request->fd} 认证失败，关闭连接。\n";
        $server->disconnect($request->fd); // 直接断开连接
        return;
    }

    // 认证成功，将用户ID和fd关联起来，方便后续查找
    // 比如可以存在一个全局的Map或者Redis里
    $userId = $this->getUserIdFromToken($token); // 假设通过token获取用户ID
    // 假设我们有一个数组来存储fd和userId的映射
    $server->users[$request->fd] = $userId;
    $server->fdToUser[$userId] = $request->fd;

    echo "客户端 {$request->fd} (用户ID: {$userId}) 已连接。\n";
    $server->push($request->fd, "认证成功，欢迎回来！");
});

fd

fd

onMessage

$server->push()

$server->on('message', function (Swoole\WebSocket\Server $server, $frame) {
    echo "收到客户端 {$frame->fd} 的消息: {$frame->data}\n";

    // 假设是聊天消息，我们要广播给所有在线用户
    foreach ($server->connections as $fd) {
        // 确保连接仍然存在且是WebSocket连接
        if ($server->isEstablished($fd)) {
            $server->push($fd, "用户 {$frame->fd} 说: " . $frame->data);
        }
    }

    // 如果是定向广播给特定群组，你需要维护群组和fd的映射关系
    // 比如：$server->groups['room_A'] = [fd1, fd2, ...];
    // 然后遍历room_A的fd列表进行push
});

$server->connections

fd

$server->connections

onClose