Flutter网络请求重试插件retry的使用

简介

retry 包提供了一种简单的方法来重试异步函数。这通常用于避免因间歇性错误（如断开的连接或暂时过载的服务器）而导致崩溃。

免责声明: 这不是Google官方支持的产品。

使用 retry

对于简单的重试逻辑与指数退避，可以使用此包提供的 retry 函数。

import 'package:retry/retry.dart';
import 'package:http/http.dart' as http;

void main() async {
  final response = await retry(
    // 执行一个GET请求
    () => http.get(Uri.parse('https://google.com')).timeout(Duration(seconds: 5)),
    // 当遇到SocketException或TimeoutException时重试
    retryIf: (e) => e is SocketException || e is TimeoutException,
  );
  print(response.body);
}

默认情况下，它会尝试8次，在第1、2、3……7次尝试后分别等待：

1. 400 ms ± 25%
2. 800 ms ± 25%
3. 1600 ms ± 25%
4. 3200 ms ± 25%
5. 6400 ms ± 25%
6. 12800 ms ± 25%
7. 25600 ms ± 25%

使用 RetryOptions

该包还提供了 RetryOptions 来定义重试次数和每次重试之间的等待时间。

import 'package:retry/retry.dart';
import 'package:http/http.dart' as http;

void main() async {
  final r = RetryOptions(maxAttempts: 8);
  final response = await r.retry(
    // 执行一个GET请求
    () => http.get(Uri.parse('https://google.com')).timeout(Duration(seconds: 5)),
    // 当遇到SocketException或TimeoutException时重试
    retryIf: (e) => e is SocketException || e is TimeoutException,
  );
  print(response.body);
}

示例代码

下面是一个完整的示例代码，演示了如何在Flutter中使用 retry 插件进行网络请求并处理异常。

import 'dart:async';
import 'dart:io';
import 'package:retry/retry.dart';
import 'package:http/http.dart' as http;

Future<void> main() async {
  try {
    // 获取状态码，并在发生特定异常时重试
    final statusCode = await retry(
      () async {
        // 执行HTTP请求并返回状态码
        final response = await http.get(Uri.parse('https://www.google.com')).timeout(Duration(seconds: 5));
        return response.statusCode;
      },
      // 在遇到SocketException或TimeoutException时重试
      retryIf: (e) => e is SocketException || e is TimeoutException,
    );

    // 根据状态码打印结果
    if (statusCode == 200) {
      print('google.com is running');
    } else {
      print('google.com is not available...');
    }
  } catch (e) {
    print('An error occurred: $e');
  }
}

这个例子展示了如何创建一个HTTP客户端，执行带超时设置的GET请求，并在遇到特定类型的异常时自动重试。通过这种方式，可以提高应用在网络不稳定情况下的鲁棒性。