Dart中使用SignalR同时建立两个WebSocket连接的方法

一、先解决核心性能问题：避免重复启动连接 #

你当前每次请求都调用await connection.start()是性能损耗的关键——SignalR的连接启动需要握手、建立WebSocket通道，重复执行会大幅增加开销。正确的做法是全局维护一个（或多个）HubConnection实例，仅在连接未启动/断开时才启动。

实现代码示例（Dart）： #

// 全局初始化HubConnection，只执行一次
final HubConnection _mainHub = HubConnectionBuilder()
    .withUrl("https://your-server.com/main-hub")
    .withAutomaticReconnect() // 可选：自动重连，提升稳定性
    .build();

// 封装连接检查方法，确保连接处于活跃状态
Future<HubConnection> _getActiveConnection() async {
  if (_mainHub.state == HubConnectionState.disconnected) {
    await _mainHub.start();
  }
  return _mainHub;
}

// 改造你的请求方法，无需每次启动连接
Future<String> getTime() async {
  final activeConn = await _getActiveConnection();
  return await activeConn.invoke<String>('getTime');
}

Future<String> getUsersData() async {
  final activeConn = await _getActiveConnection();
  return await activeConn.invoke<String>('getUsersData');
}

这样所有请求都会复用同一个活跃连接，彻底消除重复启动的性能问题。

二、双连接实现：分离大文件传输与轻量请求 #

完全可以建立两个独立的SignalR连接，分别处理图片传输和轻量数据——这种设计能避免大文件传输占用通道，导致轻量请求延迟。

双连接代码示例： #

// 1. 轻量数据连接（处理时间、用户认证、用户数据）
final HubConnection _lightweightHub = HubConnectionBuilder()
    .withUrl("https://your-server.com/lightweight-hub")
    .withAutomaticReconnect()
    .build();

// 2. 图片传输连接（专门处理大尺寸图片）
final HubConnection _imageHub = HubConnectionBuilder()
    .withUrl("https://your-server.com/image-hub")
    .withAutomaticReconnect()
    // 可选：针对大文件调整配置，比如超时时间
    .build();

// 分别封装两个连接的激活方法
Future<HubConnection> _getLightweightConn() async {
  if (_lightweightHub.state == HubConnectionState.disconnected) {
    await _lightweightHub.start();
  }
  return _lightweightHub;
}

Future<HubConnection> _getImageConn() async {
  if (_imageHub.state == HubConnectionState.disconnected) {
    await _imageHub.start();
  }
  return _imageHub;
}

// 轻量请求使用轻量连接
Future<String> getTime() async {
  final conn = await _getLightweightConn();
  return await conn.invoke<String>('getTime');
}

// 图片传输使用独立连接
Future<void> uploadBatchImages(List<List<int>> imageBytesList) async {
  final conn = await _getImageConn();
  for (var bytes in imageBytesList) {
    // 异步上传每张图片，不会阻塞其他操作
    await conn.invoke<void>('UploadImage', args: [bytes]);
  }
}

注意事项： #

• 服务器端建议对应创建两个Hub类（比如LightweightHub和ImageHub），分别处理不同类型的请求，便于后续维护和性能优化。
• 针对图片传输，需要在服务器端调整SignalR的消息大小限制（比如ASP.NET Core中，在AddSignalR()配置里设置.AddHubOptions<ImageHub>(options => options.MaximumReceiveMessageSize = 10 * 1024 * 1024)，即允许10MB的消息）。

三、关于WebSocket异步的疑问 #

WebSocket本身是全双工异步通信协议，SignalR客户端的所有API（start()、invoke()等）都是异步实现的。你之前觉得“同步”是因为每次请求都重复启动连接，导致操作串行化——只要复用活跃连接，多个异步请求可以并行执行，不会互相阻塞。

额外优化建议 #

1. 图片传输前先进行压缩（比如将JPEG质量调低、转WebP格式），减少单张图片的体积，降低传输时间和带宽占用。
2. 在应用生命周期结束时（比如页面销毁、应用退出），主动调用_lightweightHub.stop()和_imageHub.stop()，释放连接资源。
3. 启用SignalR的自动重连机制（withAutomaticReconnect()），提升连接稳定性，避免因网络波动导致频繁手动重连。

内容的提问来源于stack exchange，提问作者user16357470