终极API限流解决方案：dio请求管理完全指南-开发者社区

终极API限流解决方案：dio请求管理完全指南

【免费下载链接】dioA powerful HTTP client for Dart and Flutter, which supports global settings, Interceptors, FormData, aborting and canceling a request, files uploading and downloading, requests timeout, custom adapters, etc.项目地址: https://gitcode.com/gh_mirrors/di/dio

在现代应用开发中，API请求管理是确保应用稳定性和性能的关键环节。dio作为Dart和Flutter生态中强大的HTTP客户端，不仅支持全局设置、拦截器、FormData等基础功能，更提供了灵活的请求限流解决方案，帮助开发者轻松应对API调用频率限制问题。

为什么需要API限流？

API限流是保护后端服务、防止请求过载的重要手段。当应用需要频繁调用外部API或内部服务时，合理的限流策略可以：

避免因请求过多导致的服务端拒绝
防止应用因大量并发请求而崩溃
遵守第三方API的调用频率限制
优化网络资源使用，提升应用响应速度

dio拦截器：实现限流的核心机制

dio的拦截器（Interceptor）机制是实现请求限流的理想选择。通过拦截器，我们可以在请求发送前、响应返回后以及发生错误时插入自定义逻辑，从而实现请求的控制和管理。

拦截器的基本使用方法

在dio中添加拦截器非常简单：

import 'package:dio/dio.dart'; void main() { final dio = Dio(); // 添加日志拦截器 dio.interceptors.add(LogInterceptor()); // 添加自定义限流拦截器 dio.interceptors.add(RateLimitInterceptor()); }

dio提供了多种内置拦截器，如LogInterceptor用于日志记录，同时也支持开发者根据需求自定义拦截器。

实现dio请求限流的三种方案

1. 基于时间窗口的限流

这种方法限制在一定时间窗口内的请求数量。例如，每分钟最多发送60个请求。

class TimeWindowRateLimitInterceptor extends Interceptor { final int maxRequests; final Duration windowDuration; final List<DateTime> _requestTimes = []; TimeWindowRateLimitInterceptor({ required this.maxRequests, required this.windowDuration, }); @override void onRequest(RequestOptions options, RequestInterceptorHandler handler) { final now = DateTime.now(); // 移除窗口时间外的请求记录 _requestTimes.removeWhere((time) => now.difference(time) > windowDuration); if (_requestTimes.length < maxRequests) { _requestTimes.add(now); handler.next(options); } else { // 请求被限流，返回错误 handler.reject(DioException( requestOptions: options, message: 'Rate limit exceeded. Max $maxRequests requests per $windowDuration', )); } } }

2. 基于令牌桶算法的限流

令牌桶算法是一种更灵活的限流方式，它允许一定程度的突发请求，同时保持长期的请求速率稳定。

class TokenBucketRateLimitInterceptor extends Interceptor { final double tokensPerSecond; final int capacity; double _tokens; DateTime _lastRefillTime; TokenBucketRateLimitInterceptor({ required this.tokensPerSecond, required this.capacity, }) : _tokens = capacity.toDouble(), _lastRefillTime = DateTime.now(); @override void onRequest(RequestOptions options, RequestInterceptorHandler handler) { final now = DateTime.now(); final elapsed = now.difference(_lastRefillTime).inMicroseconds / 1e6; _lastRefillTime = now; // 计算新增的令牌数量 _tokens += elapsed * tokensPerSecond; if (_tokens > capacity) _tokens = capacity.toDouble(); if (_tokens >= 1) { _tokens -= 1; handler.next(options); } else { // 请求被限流，返回错误 handler.reject(DioException( requestOptions: options, message: 'Rate limit exceeded. Try again later.', )); } } }

3. 基于队列的请求调度

对于需要严格控制请求顺序和频率的场景，可以使用队列来调度请求，确保请求按顺序执行，避免并发过高。

class QueuedRateLimitInterceptor extends Interceptor { final int maxConcurrentRequests; final Queue<RequestInterceptorHandler> _queue = Queue(); int _activeRequests = 0; QueuedRateLimitInterceptor({required this.maxConcurrentRequests}); @override void onRequest(RequestOptions options, RequestInterceptorHandler handler) { if (_activeRequests < maxConcurrentRequests) { _activeRequests++; handler.next(options); } else { _queue.add(handler); } } @override void onResponse(Response response, ResponseInterceptorHandler handler) { _activeRequests--; _processQueue(); handler.next(response); } @override void onError(DioException err, ErrorInterceptorHandler handler) { _activeRequests--; _processQueue(); handler.next(err); } void _processQueue() { while (_queue.isNotEmpty && _activeRequests < maxConcurrentRequests) { _activeRequests++; final handler = _queue.removeFirst(); handler.next(handler.requestOptions); } } }

限流拦截器的配置与使用

使用自定义的限流拦截器非常简单，只需将其添加到dio实例中：

final dio = Dio(); // 添加时间窗口限流拦截器（每分钟最多60个请求） dio.interceptors.add(TimeWindowRateLimitInterceptor( maxRequests: 60, windowDuration: Duration(minutes: 1), )); // 或者添加令牌桶限流拦截器（每秒2个请求，最多10个令牌） dio.interceptors.add(TokenBucketRateLimitInterceptor( tokensPerSecond: 2, capacity: 10, )); // 或者添加队列限流拦截器（最多5个并发请求） dio.interceptors.add(QueuedRateLimitInterceptor( maxConcurrentRequests: 5, ));

高级技巧：动态调整限流策略

在实际应用中，可能需要根据不同的API端点或请求类型应用不同的限流策略。可以通过自定义拦截器实现这一点：

class AdvancedRateLimitInterceptor extends Interceptor { final Map<String, RateLimitStrategy> _strategies; AdvancedRateLimitInterceptor(this._strategies); @override void onRequest(RequestOptions options, RequestInterceptorHandler handler) { // 根据请求URL选择对应的限流策略 final strategy = _strategies.entries.firstWhere( (entry) => options.uri.path.contains(entry.key), orElse: () => _strategies['default']!, ).value; // 应用限流策略 if (strategy.shouldAllowRequest()) { strategy.recordRequest(); handler.next(options); } else { handler.reject(DioException( requestOptions: options, message: 'Rate limit exceeded for ${options.uri.path}', )); } } }