Flutter Bloc/Cubit错误处理：最优架构与跨层错误传递实现

作为初级开发者，在Bloc框架实现中遇到错误传递问题：现有代码里NetworkService的错误被直接返回而非抛出，导致后续层无法正确捕获错误；Repository层希望返回特定对象列表，失败时不想返回null或动态类型，需要将错误完整传递到Cubit层。

核心修复思路 #

错误应通过异常机制向上传递，而非作为返回值返回；各层只负责自己的职责，错误统一由Cubit层捕获并处理。

1. 重构NetworkService：抛出异常而非返回错误 #

移除getData方法中catch块的返回逻辑，改为重新抛出异常；同时定义自定义异常类，让错误类型更明确：

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

class NetworkService {
  Future<String> getData(Uri uri) async {
    try {
      final httpResponse = await http.get(
        uri,
        headers: {
          // some headers //
        },
      );
      if (httpResponse.statusCode == 200) {
        return httpResponse.body;
      } else {
        // 抛出HTTP状态码异常
        throw HttpRequestException(
          statusCode: httpResponse.statusCode,
          message: '请求失败，状态码：${httpResponse.statusCode}',
        );
      }
    } catch (e) {
      // 非HTTP异常包装后重新抛出
      if (e is HttpRequestException) {
        rethrow;
      }
      throw NetworkException(message: e.toString());
    }
  }

  Future<List<dynamic>> fetchData() async {
    final uri = Uri.parse('some url');
    final data = await getData(uri);
    final decodedData = jsonDecode(data);
    // 校验返回格式，不符合则抛出解析异常
    if (decodedData is List) {
      return decodedData;
    } else {
      throw DataParsingException(message: '返回数据不是列表格式');
    }
  }
}

// 自定义异常类，区分不同错误类型
class HttpRequestException implements Exception {
  final int statusCode;
  final String message;

  HttpRequestException({required this.statusCode, required this.message});

  @override
  String toString() => message;
}

class NetworkException implements Exception {
  final String message;

  NetworkException({required this.message});

  @override
  String toString() => message;
}

class DataParsingException implements Exception {
  final String message;

  DataParsingException({required this.message});

  @override
  String toString() => message;
}

2. 简化Repository层：专注数据转换，异常自然传递 #

Repository只负责将原始数据转换为SomeObject列表，不处理错误，让异常自动向上传递到Cubit：

class Repository {
  final NetworkService networkService;

  // 通过构造函数注入依赖，提升可测试性
  Repository({required this.networkService});

  Future<List<SomeObject>> fetchDataList() async {
    final dataRaw = await networkService.fetchData();
    return dataRaw.map((e) => SomeObject.fromJson(e)).toList();
  }
}

3. 修复Cubit层：用async/await捕获所有异常 #

原代码中then回调的错误无法被外层try/catch捕获，改为async/await语法，确保所有异常都能被捕获并发射错误状态：

class SomeCubit extends Cubit<CubitState> {
  final Repository repository;

  SomeCubit(this.repository) : super(LoadingState()) {
    fetchDataList();
  }

  Future<void> fetchDataList() async {
    try {
      emit(LoadingState()); // 重新发射加载状态，避免重复请求时状态混乱
      final dataList = await repository.fetchDataList();
      emit(LoadedState(dataList));
    } catch (e) {
      // 可根据异常类型做差异化处理
      String errorMsg;
      if (e is HttpRequestException) {
        errorMsg = 'HTTP错误：${e.statusCode}';
      } else if (e is DataParsingException) {
        errorMsg = '数据解析失败';
      } else {
        errorMsg = '未知错误：$e';
      }
      emit(ErrorState(errorMsg));
    }
  }
}

关键要点 #

• 不要用返回值传递错误，异常是处理异步错误的标准方式
• 自定义异常类能让错误类型更清晰，方便上层做针对性处理
• async/await比then更易维护，且能让try/catch覆盖所有异步错误
• 依赖注入（如Repository的NetworkService通过构造函数传入）能提升代码的可测试性和扩展性

内容的提问来源于stack exchange，提问作者Łukasz Strzelecki