Cloudflare 边缘 WebSocket

1. 接受升级 — const [client, server] = Object.values(new WebSocketPair()); ctx.acceptWebSocket(server) 2. 返回 client — new Response(null, { status: 101, webSocket: client }) 3. 可休眠 — 用 acceptWebSocket（非 adoptWebSocket）空闲免费 4. handler — webSocketMessage(ws, msg)、webSocketClose(ws)、webSocketError(ws) 5. 广播 — ctx.getWebSockets().forEach(ws => ws.send(data)) 6. 标记套接字 — ctx.acceptWebSocket(server, ["room:42"]) 过滤广播 7. Durable Objects — 房间范围状态，路由 WS 到 DO 实例

export default { async fetch(request: Request, env: Env): Promise<Response> { if (request.headers.get("Upgrade") !== "websocket") { return new Response("需要 WS", { status: 426 }); } const pair = new WebSocketPair(); const [client, server] = Object.values(pair); env.ctx.acceptWebSocket(server); // 可休眠 return new Response(null, { status: 101, webSocket: client }); }, async webSocketMessage(ws: WebSocket, msg: string) { // 广播给所有连接的客户端 for (const peer of this.ctx.getWebSockets()) { peer.send(`echo: ${msg}`); } }, async webSocketClose(ws: WebSocket) { console.log("客户端断开"); }, };