Swoole怎么在WebSocket服务器中验证用户身份-Swoole-PHP中文网

Swoole怎么在WebSocket服务器中验证用户身份

冰火之心

发布： 2025-09-29 18:28:02

原创

187人浏览过

在Swoole WebSocket服务器中验证用户身份需在握手阶段或连接后立即进行，首选onHandshake回调解析URL中的token并校验，失败则拒绝连接；若使用复杂认证机制，可允许连接后通过onMessage接收认证消息完成验证，成功后将fd与用户ID绑定至Swoole\Table或Redis以管理会话状态，确保未认证连接不被信任。

swoole怎么在websocket服务器中验证用户身份

在Swoole的WebSocket服务器中验证用户身份，通常是在客户端刚连接时（即握手阶段）完成。由于WebSocket是长连接，无法像HTTP那样每次请求都携带Cookie或Header，因此需要在连接建立初期完成身份校验。

1. 利用WebSocket握手阶段验证

当客户端发起WebSocket连接时，会先进行HTTP握手。Swoole允许你在onHandshake回调中处理这个过程，可以读取请求头、GET参数等信息来验证身份。

常见做法：

客户端在URL中附加token：ws://your-server:9501?token=abc123
服务端在onHandshake中解析token并验证
验证失败则拒绝连接，成功则允许升级为WebSocket连接

示例代码：

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

$server->on('handshake', function($request, $response) {
    // 解析GET参数
    parse_str($request->server['query_string'], $get);
    
    if (!isset($get['token']) || !validateToken($get['token'])) {
        $response->end();
        return false;
    }

    // 手动发送WebSocket升级头
    $key = base64_encode(sha1($request->header['sec-websocket-key'] . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
    $headers = [
        'Upgrade' => 'websocket',
        'Connection' => 'Upgrade',
        'Sec-WebSocket-Accept' => $key,
        'Sec-WebSocket-Version' => '13',
    ];
    $response->header('Content-Type', 'text/plain');
    $response->header('Connection', 'Upgrade');
    $response->header('Upgrade', 'websocket');
    $response->header('Sec-WebSocket-Accept', $key);
    $response->status(101);
    $response->end();
});

function validateToken($token) {
    // 这里实现你的token验证逻辑，如查Redis或JWT解码
    return $token === 'abc123'; // 示例
}

登录后复制

2. 使用onOpen后立即发送认证消息

另一种方式是允许连接建立，但在onOpen后要求客户端立即发送一条认证消息（比如类型为"auth"的数据帧），服务端收到后再进行校验。

适合场景：

百度文心百中

百度大模型语义搜索体验中心

查看详情

使用更复杂的身份机制（如签名、加密数据）
不想把token暴露在URL中

示例流程：

$server->on('open', function($server, $req) {
    echo "连接已建立，等待认证...\n";
});

$server->on('message', function($server, $frame) {
    $data = json_decode($frame->data, true);
    
    if ($data['type'] === 'auth') {
        if (validateToken($data['token'])) {
            // 记录fd与用户关系
            $_SESSION[$frame->fd] = ['user_id' => getUserId($data['token'])];
            $server->push($frame->fd, json_encode(['type' => 'auth_success']));
        } else {
            $server->push($frame->fd, json_encode(['type' => 'auth_fail']));
            $server->disconnect($frame->fd);
        }
    }
});

登录后复制