Dio 并发请求限制机制的实现思路

并发控制的重要性

在现代应用开发中，网络请求管理是一个关键环节。Dio作为Flutter生态中广泛使用的HTTP客户端，其并发请求处理能力直接影响应用性能和服务器稳定性。当应用需要频繁与后端API交互时，无限制的并发请求可能导致服务器过载、触发API速率限制甚至导致请求失败。因此，实现合理的并发控制机制对于保证应用稳定性和提升用户体验至关重要。

核心实现原理

Dio本身并未内置并发限制功能，但通过其强大的拦截器机制，我们可以灵活地实现这一需求。核心思路是使用计数器锁（Counter Lock）或互斥锁（Mutex）配合拦截器来实现请求的排队管理。

技术实现要点

1. 请求计数器：维护一个全局计数器，记录当前正在进行的请求数量
2. 最大并发数：设定一个最大并发请求数的阈值
3. 请求队列：当并发数达到上限时，将新请求加入等待队列
4. 完成回调：每个请求完成后减少计数器并触发队列中等待的请求

具体实现方案

基于拦截器的实现

Dio的拦截器机制允许我们在请求发出前和响应返回后插入自定义逻辑。我们可以创建一个并发控制拦截器：

class ConcurrencyInterceptor extends Interceptor {
  final int maxConcurrentRequests;
  int _currentRequests = 0;
  final _pendingRequests = Queue<RequestOptions>();

  ConcurrencyInterceptor({this.maxConcurrentRequests = 5});

  @override
  Future onRequest(
    RequestOptions options,
    RequestInterceptorHandler handler,
  ) async {
    if (_currentRequests >= maxConcurrentRequests) {
      _pendingRequests.add(options);
      return;
    }
    
    _currentRequests++;
    handler.next(options);
  }

  @override
  Future onResponse(
    Response response,
    ResponseInterceptorHandler handler,
  ) async {
    _currentRequests--;
    _processPendingRequests();
    handler.next(response);
  }

  @override
  Future onError(
    DioError err,
    ErrorInterceptorHandler handler,
  ) async {
    _currentRequests--;
    _processPendingRequests();
    handler.next(err);
  }

  void _processPendingRequests() {
    while (_currentRequests < maxConcurrentRequests && _pendingRequests.isNotEmpty) {
      final options = _pendingRequests.removeFirst();
      dio.fetch(options).then((response) {
        options.completer?.complete(response);
      }).catchError((error) {
        options.completer?.completeError(error);
      });
      _currentRequests++;
    }
  }
}

使用信号量的替代方案

另一种更优雅的实现方式是使用Dart的Semaphore类，它专门用于控制对共享资源的访问：

import 'package:synchronized/synchronized.dart';

class SemaphoreInterceptor extends Interceptor {
  final Semaphore semaphore;

  SemaphoreInterceptor(int maxConcurrentRequests)
      : semaphore = Semaphore(maxConcurrentRequests);

  @override
  Future onRequest(
    RequestOptions options,
    RequestInterceptorHandler handler,
  ) async {
    await semaphore.acquire();
    try {
      handler.next(options);
    } catch (e) {
      semaphore.release();
      rethrow;
    }
  }

  @override
  Future onResponse(
    Response response,
    ResponseInterceptorHandler handler,
  ) async {
    semaphore.release();
    handler.next(response);
  }

  @override
  Future onError(
    DioError err,
    ErrorInterceptorHandler handler,
  ) async {
    semaphore.release();
    handler.next(err);
  }
}

实际应用建议

1. 合理设置并发数：根据服务器性能和API限制设置合适的最大并发数，通常3-5个是比较平衡的选择
2. 错误处理：确保在任何情况下（包括请求失败时）都能正确释放并发槽位
3. 优先级处理：对于关键请求，可以考虑实现优先级队列而非简单的FIFO队列
4. 超时机制：为等待队列中的请求设置合理的超时时间，避免用户长时间等待

性能考量

实现并发控制时需要注意以下几点：

1. 内存消耗：长时间运行的队列可能积累大量请求，需要监控内存使用
2. 响应延迟：队列中的请求会有额外的等待时间，需要在UI上给予适当提示
3. 线程安全：确保计数器和队列操作是线程安全的，避免竞态条件

扩展思考

这种并发控制模式不仅适用于HTTP请求，也可以应用于其他需要限制并发的场景，如：

• 文件上传/下载
• 数据库操作
• 图像处理等计算密集型任务

通过灵活运用Dio的拦截器机制，开发者可以构建出既高效又稳定的网络请求层，为应用提供可靠的网络通信保障。