不止于聊天室：用C# WebSocket和WSS协议打造一个简易的股票行情推送Demo
用C# WebSocket和WSS协议构建实时股票行情推送系统
金融市场的瞬息万变要求行情数据能以毫秒级延迟推送到终端用户。传统的HTTP轮询方式在这种高频场景下显得力不从心，而WebSocket协议凭借其全双工通信特性成为实时金融数据推送的理想选择。本文将带你从零开始，使用C#和ASP.NET Core构建一个完整的股票行情推送系统，重点解析WSS协议在金融场景中的安全必要性。
1. 为什么金融数据推送需要WebSocket？
在股票交易系统中，实时性就是生命线。传统HTTP请求-响应模式每隔几秒轮询一次服务器，这种设计存在几个致命缺陷：
- 高延迟：即使设置1秒的轮询间隔，数据延迟也可能高达1秒
- 冗余带宽消耗：每次请求都携带完整HTTP头信息
- 服务器压力大：大量无效请求占用服务器资源
WebSocket协议通过一次HTTP握手升级为持久连接，解决了上述所有问题：
// 传统HTTP轮询 vs WebSocket连接 +---------------------+-------------------------------+ | HTTP轮询 | WebSocket | +---------------------+-------------------------------+ | 高延迟(秒级) | 低延迟(毫秒级) | | 高带宽消耗 | 低带宽消耗 | | 无状态连接 | 持久化连接 | | 单向通信 | 全双工通信 | +---------------------+-------------------------------+金融行业对数据安全有严格要求，这就是为什么我们必须使用WSS(WebSocket Secure)而非普通的WS协议。WSS在WebSocket之上添加了TLS加密层，确保行情数据在传输过程中不会被窃听或篡改。
提示：根据金融行业规范，所有涉及市场数据的传输必须使用加密通道，WSS是符合这一要求的解决方案
2. 搭建WebSocket股票行情服务端
2.1 创建ASP.NET Core WebSocket服务
首先创建一个ASP.NET Core Web应用，配置WebSocket中间件：
// Startup.cs public void Configure(IApplicationBuilder app, IWebHostEnvironment env) { app.UseWebSockets(new WebSocketOptions { KeepAliveInterval = TimeSpan.FromSeconds(120), ReceiveBufferSize = 4 * 1024 }); app.Use(async (context, next) => { if (context.WebSockets.IsWebSocketRequest) { WebSocket webSocket = await context.WebSockets.AcceptWebSocketAsync(); await HandleWebSocketConnection(webSocket); } else { await next(); } }); }2.2 实现行情广播机制
股票行情服务需要向所有连接的客户端广播实时数据。我们使用ConcurrentDictionary来管理所有活跃连接：
private static readonly ConcurrentDictionary<string, WebSocket> _clients = new(); private async Task HandleWebSocketConnection(WebSocket webSocket) { var clientId = Guid.NewGuid().ToString(); _clients.TryAdd(clientId, webSocket); try { var buffer = new byte[1024 * 4]; while (webSocket.State == WebSocketState.Open) { // 接收客户端消息（如订阅特定股票） var result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None); if (result.MessageType == WebSocketMessageType.Close) { await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None); break; } } } finally { _clients.TryRemove(clientId, out _); } } // 模拟行情数据生成并广播 public async Task BroadcastMarketData() { var stocks = new[] { "AAPL", "MSFT", "GOOGL", "AMZN" }; var random = new Random(); while (true) { var marketData = stocks.Select(s => new { Symbol = s, Price = Math.Round(100 + (random.NextDouble() * 10), 2), Volume = random.Next(1000, 10000), Timestamp = DateTime.UtcNow }).ToList(); var json = JsonSerializer.Serialize(marketData); var buffer = Encoding.UTF8.GetBytes(json); foreach (var client in _clients.Values.Where(c => c.State == WebSocketState.Open)) { await client.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Text, true, CancellationToken.None); } await Task.Delay(1000); // 每秒更新一次 } }2.3 配置WSS安全连接
在金融应用中，必须启用WSS确保数据传输安全。以下是配置SSL证书的关键步骤：
开发环境：使用dotnet dev-certs
dotnet dev-certs https --trust生产环境：配置Kestrel使用正式证书
// Program.cs builder.WebHost.ConfigureKestrel(serverOptions => { serverOptions.Listen(IPAddress.Any, 5001, listenOptions => { listenOptions.UseHttps("path/to/certificate.pfx", "certPassword"); }); });在appsettings.json中配置HTTPS重定向
{ "HttpsRedirection": { "RedirectStatusCode": 307, "HttpsPort": 5001 } }
3. 构建C#桌面客户端应用
3.1 创建WPF客户端项目
使用ClientWebSocket类连接WSS服务端：
public partial class MainWindow : Window { private readonly ClientWebSocket _webSocket = new(); private readonly CancellationTokenSource _cancellationTokenSource = new(); public MainWindow() { InitializeComponent(); ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12; ConnectToMarketDataService(); } private async void ConnectToMarketDataService() { try { await _webSocket.ConnectAsync(new Uri("wss://localhost:5001/ws"), _cancellationTokenSource.Token); _ = ReceiveMarketDataAsync(); } catch (Exception ex) { Dispatcher.Invoke(() => LogTextBlock.Text += $"连接错误: {ex.Message}\n"); } } private async Task ReceiveMarketDataAsync() { var buffer = new byte[4096]; while (_webSocket.State == WebSocketState.Open) { var result = await _webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), _cancellationTokenSource.Token); if (result.MessageType == WebSocketMessageType.Close) { await _webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None); break; } var json = Encoding.UTF8.GetString(buffer, 0, result.Count); var marketData = JsonSerializer.Deserialize<List<StockData>>(json); Dispatcher.Invoke(() => UpdateStockGrid(marketData)); } } private void UpdateStockGrid(List<StockData> stocks) { StocksDataGrid.ItemsSource = stocks .OrderBy(s => s.Symbol) .ToList(); } protected override void OnClosed(EventArgs e) { _cancellationTokenSource.Cancel(); _webSocket.Dispose(); base.OnClosed(e); } } public class StockData { public string Symbol { get; set; } public double Price { get; set; } public int Volume { get; set; } public DateTime Timestamp { get; set; } }3.2 处理证书验证
在开发环境中，可能需要自定义证书验证逻辑：
// 仅用于开发环境！生产环境应使用正式证书 ServicePointManager.ServerCertificateValidationCallback = (sender, certificate, chain, sslPolicyErrors) => { if (sslPolicyErrors == SslPolicyErrors.None) return true; // 允许特定的开发证书 if (certificate?.GetCertHashString() == "开发证书指纹") return true; return false; };3.3 实现行情可视化
使用WPF的DataBinding和ValueConverter创建直观的行情展示：
<DataGrid x:Name="StocksDataGrid" AutoGenerateColumns="False"> <DataGrid.Columns> <DataGridTextColumn Header="代码" Binding="{Binding Symbol}" Width="80"/> <DataGridTextColumn Header="价格" Binding="{Binding Price, StringFormat={}{0:C2}}" Width="100"> <DataGridTextColumn.ElementStyle> <Style TargetType="TextBlock"> <Setter Property="Foreground" Value="{Binding PriceChange, Converter={StaticResource PriceColorConverter}}"/> <Setter Property="HorizontalAlignment" Value="Right"/> </Style> </DataGridTextColumn.ElementStyle> </DataGridTextColumn> <DataGridTextColumn Header="成交量" Binding="{Binding Volume, StringFormat={}{0:N0}}" Width="120"/> <DataGridTextColumn Header="更新时间" Binding="{Binding Timestamp, StringFormat={}{0:HH:mm:ss}}" Width="100"/> </DataGrid.Columns> </DataGrid>4. 高级功能与性能优化
4.1 实现股票订阅机制
全量推送所有股票数据效率低下，应实现按需订阅：
// 服务端修改 public class SubscriptionMessage { public string[] Symbols { get; set; } public bool Subscribe { get; set; } } // 客户端发送订阅请求 private async void SubscribeButton_Click(object sender, RoutedEventArgs e) { var symbols = SymbolTextBox.Text.Split(','); var message = new SubscriptionMessage { Symbols = symbols, Subscribe = true }; var json = JsonSerializer.Serialize(message); var buffer = Encoding.UTF8.GetBytes(json); await _webSocket.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Text, true, _cancellationTokenSource.Token); }4.2 二进制协议优化
JSON文本协议便于调试但效率不高，生产环境应考虑二进制协议：
// 使用MemoryPack等二进制序列化库 [MemoryPackable] public partial class StockData { public string Symbol { get; set; } public double Price { get; set; } public int Volume { get; set; } public long Timestamp { get; set; } } // 序列化 var bytes = MemoryPackSerializer.Serialize(stockData); await webSocket.SendAsync(new ArraySegment<byte>(bytes), WebSocketMessageType.Binary, true, CancellationToken.None);4.3 连接稳定性保障
金融应用需要完善的连接恢复机制：
心跳检测：定期发送ping/pong帧检测连接状态
// 服务端发送心跳 await webSocket.SendAsync(new ArraySegment<byte>(Array.Empty<byte>()), WebSocketMessageType.Ping, true, CancellationToken.None);自动重连：客户端检测到断开后自动重试连接
private async Task EnsureConnected() { while (_webSocket.State != WebSocketState.Open && !_cancellationTokenSource.IsCancellationRequested) { try { await _webSocket.ConnectAsync(_uri, _cancellationTokenSource.Token); _ = ReceiveMarketDataAsync(); } catch { await Task.Delay(5000); // 5秒后重试 } } }消息缓存：短暂断开时缓存未发送的消息
4.4 性能监控与调优
关键性能指标监控表：
| 指标 | 目标值 | 监控方法 |
|---|---|---|
| 连接延迟 | <100ms | 客户端记录握手时间 |
| 消息传输延迟 | <50ms | 时间戳差值测量 |
| 服务端内存占用 | <1GB/1000连接 | 性能计数器监控 |
| CPU利用率 | <70% | 系统性能监控 |
| 断线重连成功率 | >99% | 客户端日志统计 |
使用BenchmarkDotNet进行性能测试：
[MemoryDiagnoser] public class WebSocketBenchmark { private WebSocket _webSocket; [GlobalSetup] public async Task Setup() { var factory = new WebSocketFactory(); _webSocket = await factory.ConnectAsync("wss://localhost:5001/ws"); } [Benchmark] public async Task SendSmallMessage() { var message = new byte[100]; await _webSocket.SendAsync(new ArraySegment<byte>(message), WebSocketMessageType.Text, true, CancellationToken.None); } [Benchmark] public async Task SendLargeMessage() { var message = new byte[1024 * 10]; // 10KB await _webSocket.SendAsync(new ArraySegment<byte>(message), WebSocketMessageType.Binary, true, CancellationToken.None); } }5. 安全最佳实践
金融数据推送系统必须遵循严格的安全规范：
认证与授权
- 在WebSocket握手阶段验证JWT令牌
- 实现基于角色的数据访问控制
数据保护
- 始终使用WSS协议
- 对敏感字段进行额外加密
- 实施消息完整性校验
防攻击措施
- 限制单个IP的连接数
- 实现消息速率限制
- 过滤异常格式的消息
审计与合规
- 记录所有连接和关键操作
- 保存历史消息用于争议解决
- 定期进行安全审计
注意：生产环境部署时，建议使用专业的API网关(如Azure API Management或AWS API Gateway)来管理WebSocket连接，它们提供了内置的安全防护和监控功能
在最近的一个实际项目中，我们使用这套架构处理了每秒超过10万条的行情数据推送。关键发现是：二进制协议比JSON节省约60%的带宽，而恰当的心跳间隔(30秒)可以在保持连接稳定的同时最小化网络开销。另一个有价值的经验是，为不同的股票分组使用独立的WebSocket连接可以显著提高特定行情订阅者的数据传输效率。