WebSocket连接前必须刷新token,因握手是一次性HTTP请求且无自动重试机制;过期时需用refresh token换取新access token并更新缓存,再发起连接。
token 已过期,连接直接被拒绝PHP 本身不原生维护 WebSocket 长连接,常见做法是用 curl 或 stream_socket_client() 发起 WebSocket 握手请求(如连接 WSS 服务),并在 Sec-WebSocket-Protocol 或请求头里带 Authorization: Bearer xxx。如果此时传入的 token 已过期,服务端通常会返回 401 Unauthorized 或在 WebSocket 协议升级阶段直接关闭连接(如发送 Connection: close),客户端收不到 101 Switching Protocols 响应,握手失败。
关键点在于:WebSocket 握手是一次性 HTTP 请求,没有“自动重试 + 刷新 token”机制。你得自己在发起连接前确保 token 有效。
stream_socket_client() 返回资源后再校验 token —— 此时连接已发起,失败只能重来reactphp/websocket-client 等异步库,其 connect() 是非阻塞的,token 必须在调用前完成刷新并注入token 的实操方式不能靠前端传来的旧 token 直接连,得走后端可控的刷新流程。典型路径是:先用 refresh token 换新 access token,再用新 token 建连。
假设你的认证服务提供 /auth/refresh 接口(POST,Content-Type: application/json):
$refreshToken = $_SESSION['refresh_token'] ?? null;
if (!$refreshToken) {
throw new Exception('No refresh token available');
}
$ch = curl_init('https://api.example.com/auth/refresh');
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode(['refresh_token' => $refreshToken]));
curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/json']);
$response = curl_exec($ch);
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);
if ($httpCode !== 200) {
throw new Exception("Token refresh failed: {$httpCode}");
}
$data = json_decode($response, true);
$newToken = $data['access_token'] ?? null;
if (!$newToken) {
throw new Exception('No access_token in refresh response');
}
// 后续 WebSocket 握手请求头中使用它
$wsHeaders = [
"Authorization: Bearer {$newToken}",
"Sec-WebSocket-Version: 13",
"Sec-WebSocket-Key: " . base64_encode(random_bytes(16)),
];
access_token 和 expires_at 时间戳,避免下次又用旧 tokenWebSocket 协议本身不定义 token 续期机制。服务端通常会在 ping 响应、或每次业务消息处理前校验 token。一旦过期,常见表现是:服务端主动发 close 帧(code 4001 或自定义),或后续 send() 操作无响应、超时。
这时 PHP 客户端(如基于 sockets 或 amphp/websocket)无法“热替换 token”,唯一可靠做法是:断开重连,并在重连前刷新 token。
onClose 回调),检查 $code 是否为 4001 / 4003 等语义化过期码reconnect() 或新建 client 实例onMessage 里边收到错误响应边刷新 token 边重发消息 —— 顺序和状态容易错乱,应统一交由连接管理层处理ReactPHP 或 Amp 时 token 管理的坑异步 PHP 框架里,token 刷新是 Promise/Future 操作,容易因闭包捕获旧值、未 await 就建连而失效。
以 reactphp/websocket-client 为例,常见错误写法:
// ❌ 错误:$token 是连接前就固定的,不会随刷新更新
$client->connect("wss://api.example.com?token={$token}");
// ✅ 正确:在 connect() 的 Promise 链中动态注入新 token
$refreshedToken = yield $this->refreshToken(); // yield 等待刷新完成
yield $client->connect("wss://api.example.com", [], [
'headers' => ['Authorization' => "Bearer {$refreshedToken}"]
]);
Amp 下必须用 co() 或 await 确保刷新完成,否则 connect() 可能拿到 null 或过期值wss://…/ws?token=xxx),要注意 URL 编码,且该方式比 header 更易泄露、不推荐用于生产token 刷新不是“连上了再换”,而是“换好了再连”。所有连接发起点都必须串行经过刷新逻辑,且刷新结果要严格绑定到当次连接上下文 —— 这一点在异步、长连接、多租户场景下最容易出问题。