告别轮询！用C#和Fleck库5分钟搞定一个WebSocket聊天服务端

告别轮询！用C#和Fleck库5分钟搞定一个WebSocket聊天服务端

在实时通信领域，HTTP轮询曾是开发者无奈的选择——客户端不断向服务器发送请求询问"有新消息吗？"，就像每隔五分钟查看一次信箱的邮差。这种低效的方式不仅浪费带宽，还带来显著的延迟。而WebSocket技术的出现，如同在客户端和服务器之间架起了一条双向电话专线，让实时通信变得优雅高效。

对于.NET开发者而言，Fleck库将这种技术门槛降到了最低。这个轻量级的C#库封装了WebSocket协议的复杂性，只需不到50行代码就能构建出生产级实时服务。本文将带您从零开始，用咖啡还没凉的时间完成一个具备连接管理的聊天服务端，并揭示其背后的技术优势。

1. 为什么选择WebSocket？

1.1 轮询机制的先天缺陷

传统轮询方案存在三个致命伤：

• 带宽浪费：每次请求都携带完整的HTTP头信息
• 延迟不可控：最短延迟取决于轮询间隔
• 服务器压力：大量无效请求占用连接资源

# 典型HTTP轮询流量示例（每次请求约800字节头信息） GET /check_update HTTP/1.1 Host: example.com User-Agent: Mozilla/5.0 Accept: */*

1.2 WebSocket的技术优势

相比轮询，WebSocket在建立连接后：

• 单次握手：初始HTTP升级协议后保持长连接
• 极简帧结构：数据帧头部仅2-14字节
• 双向实时：服务端可主动推送消息

实际测试显示：在1000并发连接下，WebSocket的带宽消耗仅为轮询模式的1/20

2. 环境准备与Fleck入门

2.1 创建项目与安装依赖

通过Visual Studio或CLI创建控制台应用：

dotnet new console -n WebSocketDemo cd WebSocketDemo dotnet add package Fleck

2.2 基础服务端架构

Fleck的核心组件包括：

• WebSocketServer：监听指定端口的服务实例
• IWebSocketConnection：代表客户端连接的对象
• 三大事件处理器：
  • OnOpen：连接建立时触发
  • OnMessage：收到消息时触发
  • OnClose：连接关闭时触发

3. 构建完整聊天服务

3.1 连接管理实现

使用ConcurrentDictionary实现线程安全的连接池：

var connections = new ConcurrentDictionary<Guid, IWebSocketConnection>(); var server = new WebSocketServer("ws://0.0.0.0:8181"); server.Start(socket => { socket.OnOpen = () => { var clientId = Guid.NewGuid(); connections.TryAdd(clientId, socket); Console.WriteLine($"客户端 {clientId} 已连接"); }; socket.OnClose = () => { var client = connections.FirstOrDefault(x => x.Value == socket); connections.TryRemove(client.Key, out _); Console.WriteLine($"客户端 {client.Key} 已断开"); }; });

3.2 消息广播机制

扩展OnMessage处理器实现群聊功能：

socket.OnMessage = message => { var sender = connections.FirstOrDefault(x => x.Value == socket); var broadcastMsg = $"[{sender.Key}]: {message}"; foreach (var conn in connections.Values) { if(conn.IsAvailable) conn.Send(broadcastMsg); } };

4. 高级功能扩展

4.1 心跳检测实现

防止死连接占用资源：

// 在OnOpen中添加 socket.ConnectionInfo.Headers.TryGetValue("Origin", out var origin); var timer = new System.Timers.Timer(30000); timer.Elapsed += (s, e) => { if(!socket.IsAvailable) timer.Dispose(); else socket.Send("ping"); }; timer.Start();

4.2 性能优化建议

5. 实战测试技巧

5.1 使用Postman测试

新版Postman已内置WebSocket支持：

1. 新建WebSocket请求
2. 输入ws://localhost:8181
3. 连接后发送测试消息
4. 观察控制台输出

5.2 浏览器端调试

快速创建HTML测试页面：

<script> const ws = new WebSocket('ws://localhost:8181'); ws.onmessage = (e) => console.log('收到:', e.data); ws.onopen = () => ws.send('Hello from browser'); </script>

在项目开发中，我发现连接状态的维护最容易出现问题。一个实用的技巧是在OnClose事件中增加延迟判断，避免因网络抖动导致的误判。实际测试时，建议使用Wireshark抓包观察WebSocket帧的交互过程，这对理解底层协议非常有帮助。