Flutter重试机制插件retryable的使用

在开发过程中，我们经常会遇到一些操作可能会失败的情况。为了提高应用程序的健壮性和用户体验，可以使用重试机制来重新尝试这些操作。在Flutter中，retryable 插件可以帮助你实现这一功能。

使用

下面是一个使用 retryable 插件的完整示例：

import 'dart:async';
import 'package:flutter/material.dart';
import 'package:retry/retry.dart';

void main() {
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: Text('Retryable Demo'),
        ),
        body: RetryableDemo(),
      ),
    );
  }
}

class RetryableDemo extends StatefulWidget {
  @override
  _RetryableDemoState createState() => _RetryableDemoState();
}

class _RetryableDemoState extends State<RetryableDemo> {
  final Cancelable cancelable = Cancelable();
  int i = -1;
  const int exceptionI = 0;
  const int expectI = 9;

  @override
  void initState() {
    super.initState();
    Timer.periodic(
      const Duration(seconds: 1),
      (timer) {
        i = Random().nextInt(10);
      },
    );
  }

  @override
  Widget build(BuildContext context) {
    return Center(
      child: ElevatedButton(
        onPressed: () async {
          try {
            final res = await retry<int>(
              () async {
                print('$i');
                if (i == exceptionI) {
                  throw Exception('exit');
                }
                if (i != expectI) {
                  throw Exception('retryable');
                }
                return i;
              },
              cancelable: cancelable,
              cancel: () async {
                // 取消定时器
                timer.cancel();
              },
              able: (i, e) async {
                // 如果异常不是 'retryable' 类型，则抛出该异常
                if (e is! Exception || e.toString().contains('retryable') == false) {
                  throw e;
                }
                // 延迟一秒后重试
                await Future.delayed(const Duration(seconds: 1));
              },
            );
            print('$res');
          } catch (e) {
            print(e.toString());
          }
        },
        child: Text('点击重试'),
      ),
    );
  }
}

在这个示例中，我们创建了一个按钮，每次点击时会触发一个包含随机数生成的操作。如果生成的随机数不等于预期值 9，则会抛出一个异常，并且该操作会被重试。如果生成的随机数等于 0，则会抛出另一个异常并停止重试。

代码解释

• 初始化定时器：

  Timer.periodic(
    const Duration(seconds: 1),
    (timer) {
      i = Random().nextInt(10);
    },
  );
  

  这段代码用于每秒生成一个新的随机数。

• 重试操作：

  final res = await retry<int>(
    () async {
      print('$i');
      if (i == exceptionI) {
        throw Exception('exit');
      }
      if (i != expectI) {
        throw Exception('retryable');
      }
      return i;
    },
    cancelable: cancelable,
    cancel: () async {
      timer.cancel();
    },
    able: (i, e) async {
      if (e is! Exception || e.toString().contains('retryable') == false) {
        throw e;
      }
      await Future.delayed(const Duration(seconds: 1));
    },
  );
  

  这段代码定义了要重试的操作，并设置了重试条件。如果抛出的是 retryable 异常，则延迟一秒后重试；否则，抛出该异常。

• 取消重试：

  cancel: () async {
    timer.cancel();
  },