C# WebSocket客户端方法 C#如何连接和收发WebSocket消息

3次阅读

clientwebsocket 连接关键在于状态判断、分片重组、心跳驱动和异常恢复:需检查 state、循环接收分片、手动发 ping、指数退避重连,否则弱网下会悄无声息掉线。

C# WebSocket客户端方法 C#如何连接和收发WebSocket消息

ClientWebSocket 连接 WebSocket 服务端

连接本身不难,但容易卡在状态判断和异常吞没上。关键不是“能不能连”,而是“连失败了有没有报出来”。ClientWebSocketConnectAsync异步阻塞调用,必须等它完成才能发消息;如果服务端拒绝、地址错、跨域没配好,它会直接抛 WebSocketExceptionHttpRequestException,而不是返回错误码。

  • 务必检查 clientWebSocket.State,只在 WebSocketState.ConnectingWebSocketState.Open 时才继续,别假设调用完就一定通了
  • 不要用 CancellationToken.None 做默认值——超时控制必须显式传入,否则网络卡死时整个任务挂起
  • 如果服务端需要认证头(如 JWT),得在 ConnectAsync 前用 clientWebSocket.Options.SetRequestHeader("Authorization", "xxx") 设置,连上后设无效

ReceiveAsync 必须循环读、手动拼帧

WebSocket 协议允许消息分片(fragmented message),ReceiveAsync 每次只拿一帧,result.EndOfMessage == false 就说明还有后续帧。很多人写一次 ReceiveAsync 就解析,结果中文乱码、json 解析失败、消息截断——其实只是没等完。

  • List<byte></byte> 缓存所有分片数据,直到 result.EndOfMessage == true 才转成字符串或 JSON
  • buffer 大小建议至少 1024 * 4(4KB),太小会导致频繁分片,影响吞吐;太大又浪费内存
  • 别忽略 result.MessageType:除了 Text,还可能收到 BinaryClose,不处理 Close 帧会导致连接僵死

发消息前先确认状态,发完别忘了 await

SendAsync 不是“发出去就完了”,它底层走的是 TCP 写缓冲区,如果连接已断或对方不在线,它不会立刻报错,而是在下一次发送或关闭时才暴露问题。常见现象是“以为发成功了”,实际服务端根本没收到。

  • 每次发之前加判断:if (clientWebSocket.State != WebSocketState.Open) return;,别依赖 try-catch 拦异常
  • SendAsync 返回的是 Task,必须 await,否则可能在发送中途就执行后续逻辑,甚至提前关闭 socket
  • 发文本用 Encoding.UTF8.GetBytes(...) 转字节数组,别直接传字符串——SendAsync 只接受 ArraySegment<byte></byte>

心跳和重连不能靠 Ping/Pong 自动维持

.NET 的 ClientWebSocket 确实支持 WebSocket.ReceiveAsync 自动响应 pong,但它**不自动发 ping**。很多服务端 30 秒没收到 ping 就断连,客户端却毫无察觉,表现为“突然收不到消息”,其实是连接静默断开了。

  • 得自己用 Timer 定期调用 clientWebSocket.SendAsync(..., WebSocketMessageType.Ping, ...)
  • 重连逻辑要独立于接收循环:收到 Close 帧或捕获到连接异常后,清空 buffer、重建 ClientWebSocket 实例再重试,复用旧实例大概率失败
  • 重试间隔建议指数退避(如 1s → 2s → 4s),避免瞬间打爆服务端

最麻烦的从来不是连上或发消息,而是连上之后“它到底还活着吗”——状态判断、分片重组、心跳驱动、异常恢复,这四块漏掉任何一块,都会让客户端在高并发或弱网下悄无声息地掉线。

text=ZqhQzanResources