讲师中心 微信公众号
AI工具推荐 视频效率加速

c# WebSocket 和高并发双向通信 C# 实现

陌墨君_2570

陌墨君_2570

发布时间:2026-01-13 11:37:44

|

436人浏览过

|

来源于php中文网

原创

生产环境必须用 Microsoft.AspNetCore.WebSockets,因其内置 HTTP 升级、连接管理、超时控制与 DI 集成;裸用 System.Net.WebSockets 需手动处理握手、生命周期等,易出错且不支持高并发。

c# websocket 和高并发双向通信 c# 实现

WebSocket 服务端用 Microsoft.AspNetCore.WebSockets 还是 System.Net.WebSockets

直接上结论:生产环境必须用 Microsoft.AspNetCore.WebSockets(即 ASP.NET Core 内置 WebSocket 中间件),而不是裸用 System.Net.WebSockets。后者只是底层协议封装,不处理 HTTP 升级、连接生命周期、并发调度、TLS 终止等关键环节——你得自己写握手、解析 Upgrade 头、管理 socket 池,极易出错且无法承载高并发。

ASP.NET Core 的 UseWebSockets 中间件已内置超时控制、缓冲区复用、连接限流(WebSocketOptions 可配 KeepAliveIntervalReceiveBufferSize),且天然集成 DI、日志、中间件管道。

  • WebSocketOptions.KeepAliveInterval = TimeSpan.FromSeconds(30):避免 NAT/防火墙静默断连
  • WebSocketOptions.ReceiveBufferSize = 4 * 1024:小包多频场景下比默认 4KB 更省内存
  • 务必在 Startup.Configure 中调用 app.UseWebSockets(options => { ... }),且位置要在 UseRouting 之后、UseEndpoints 之前

如何安全地广播消息给所有在线连接?别用静态集合存 WebSocket

WebSocket 对象不是线程安全的,且不可跨请求重用。常见错误是把 WebSocket 直接塞进 static ConcurrentDictionary<string websocket></string>,然后在另一个线程里直接 SendAsync——这会触发 InvalidOperationException: "The WebSocket is in an invalid state",因为连接可能已在其他线程关闭或正被读取。

正确做法是:为每个连接分配唯一 ID(如 GUID),用 ConcurrentDictionary<string websocketconnection></string> 存储包装类,内部封装 WebSocket + CancellationTokenSource + 状态标记,并在发送前检查 State == WebSocketState.Open

public class WebSocketConnection
{
    public WebSocket Socket { get; }
    public CancellationTokenSource CloseToken { get; } = new();
<pre class='brush:php;toolbar:false;'>public WebSocketConnection(WebSocket socket) => Socket = socket;

public async Task SendAsync(byte[] data)
{
    if (Socket.State != WebSocketState.Open) return;
    try
    {
        await Socket.SendAsync(new ArraySegment<byte>(data), 
            WebSocketMessageType.Binary, true, CloseToken.Token);
    }
    catch (OperationCanceledException) { }
    catch (WebSocketException) { /* 连接已断,后续清理 */ }
}

}

Azure Ai Projects - Microsoft Foundry SDKs
Azure Ai Projects - Microsoft Foundry SDKs

使用 Azure AI 项目 Python SDK (azure-ai-projects) 构建 AI 应用。适用于处理 Foundry 项目客户端、使用 PromptAgentDefinition 创建版本化代理、运行评估、管理连接/部署/数据集/索引,或使用 OpenAI 兼容客户端。这是高级 Foundry SDK - 如需低级代理操作,请使用 azure-ai-agents-python 技能。

下载

ReceiveAsync 阻塞模型怎么应对高并发读?必须配合 MemoryPool<byte>

每个 WebSocket 连接默认独占一个后台线程执行 ReceiveAsync 循环,若用 new byte[bufferSize] 分配缓冲区,在万级连接下会引发 GC 压力暴增和内存碎片。实测 5000 连接持续收 1KB 消息时,Gen2 GC 频率从 2 分钟一次飙升至每秒多次。

解决方案:用 MemoryPool<byte>.Shared.Rent(8192) 替代 new byte[8192],并在处理完后调用 .Return() 归还缓冲区。注意 ArraySegment<byte> 必须指向 Memory<byte>.Span,不能直接传 MemoryPool<byte>.Rent().MemoryToArray()(会触发拷贝)。

  • 缓冲区大小建议设为 2^n(如 4096、8192),匹配 MemoryPool 默认块大小
  • ReceiveAsync 返回的 WebSocketReceiveResultCount 是实际接收字节数,不是缓冲区长度
  • 必须用 while (!token.IsCancellationRequested) 包裹接收循环,否则连接断开时线程不会退出

为什么用了 ConcurrentDictionary 还出现连接丢失?检查 OnConnectedAsync 异常捕获

很多人把 WebSocket 接入逻辑写在 MapGet("/ws", async context => { ... }) 里,但没包裹 try/catch。一旦 AcceptWebSocketAsync() 后的初始化代码(如鉴权、DB 查询)抛异常,连接会被静默关闭,客户端收到 1006 错误,而服务端日志里只有未捕获异常堆栈,找不到对应连接 ID。

必须确保整个 WebSocket 生命周期都在 try/catch 内,且异常时主动调用 websocket.CloseAsync(WebSocketCloseStatus.InternalServerError, "...", CancellationToken.None),再清理字典中对应项。

  • 不要在 AcceptWebSocketAsync 前做耗时操作(如查 DB),否则会阻塞 HTTP 升级响应
  • 客户端重连间隔建议用指数退避(如 1s → 2s → 4s),避免雪崩式重连冲击
  • Kestrel 默认单连接最大请求体是 30MB,若需传大文件,要显式配置 options.Limits.MaxRequestBodySize = null

真正难的不是写通 WebSocket,而是让成千上万个连接在内存、GC、线程调度、网络丢包、客户端异常断连这些边界条件下稳定跑满 7×24 小时。每个 WebSocket 实例背后都是操作系统 socket、TLS 状态、.NET 线程池资源的精确配比,漏掉任意一环,压测时都会在凌晨三点给你发告警。

热门AI工具

更多
火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

AionClaw
AionClaw Hot

AionClaw是一款面向办公、创作和编程任务的AI桌面智能体。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

VibeKnow
VibeKnow Hot

一款AI视频创作工具,主要用于全球首个AI知识视频创作平台,文档、文章、网页,一键生成视频,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

相关专题

更多
什么是中间件
什么是中间件

中间件是一种软件组件,充当不兼容组件之间的桥梁,提供额外服务,例如集成异构系统、提供常用服务、提高应用程序性能,以及简化应用程序开发。想了解更多中间件的相关内容,可以阅读本专题下面的文章。

549

2024.05.11

Golang 中间件开发与微服务架构
Golang 中间件开发与微服务架构

本专题系统讲解 Golang 在微服务架构中的中间件开发,包括日志处理、限流与熔断、认证与授权、服务监控、API 网关设计等常见中间件功能的实现。通过实战项目,帮助开发者理解如何使用 Go 编写高效、可扩展的中间件组件,并在微服务环境中进行灵活部署与管理。

564

2025.12.18

ThinkPHP中间件机制与请求拦截处理实践
ThinkPHP中间件机制与请求拦截处理实践

本专题围绕 ThinkPHP 中间件体系展开,深入讲解中间件的定义、注册与执行流程。内容包括全局中间件与路由中间件的区别、请求前后处理逻辑、自定义中间件开发以及权限验证与日志处理应用。通过实际案例,帮助开发者掌握中间件在项目中的核心作用与最佳实践。

398

2026.03.31

c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

509

2023.09.22

java中null的用法
java中null的用法

在Java中,null表示一个引用类型的变量不指向任何对象。可以将null赋值给任何引用类型的变量,包括类、接口、数组、字符串等。想了解更多null的相关内容,可以阅读本专题下面的文章。

1638

2024.03.01

counta和count的区别
counta和count的区别

Count函数用于计算指定范围内数字的个数,而CountA函数用于计算指定范围内非空单元格的个数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2348

2023.11.20

while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

334

2023.09.25

登录token无效
登录token无效

登录token无效解决方法:1、检查token的有效期限,如果token已经过期,需要重新获取一个新的token;2、检查token的签名,如果签名不正确,需要重新获取一个新的token;3、检查密钥的正确性,如果密钥不正确,需要重新获取一个新的token;4、使用HTTPS协议传输token,建议使用HTTPS协议进行传输 ;5、使用双因素认证,双因素认证可以提高账户的安全性。

11866

2023.09.14

Buffalo框架数据库开发全教程
Buffalo框架数据库开发全教程

本专题围绕Buffalo框架数据库开发,讲解database.yml多环境配置、soda与fizz迁移生成回滚、模型结构体标签、增删改查与条件查询、一对多与多对多关联、数据校验、回调钩子、事务处理及原生SQL执行能力。

0

2026.09.23

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Valgrind支持平台说明
Valgrind支持平台说明

共0课时 | 0人学习

CodeIgniter框架入门视频教程
CodeIgniter框架入门视频教程

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn