Flutter Dio二次封装的实现

移动开发 得得之家
这篇文章主要介绍了Flutter Dio二次封装的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

目录：

  • DioManager：Dio辅助类NWMethod：请求方法，get、post等
  • NWApi：大家都知道
  • EntityFactory：json转换辅助工厂，把json转为T
  • BaseEntity<T>：数据基类，返回的参数为 {“code”: 0, “message”: “”, “data”: {}}
  • BaseListEntity<T>：数据基类2，返回的参数为 {“code”: 0, “message”: “”, “data”: []}
  • ErrorEntity：请求报错基类，{“code”: 0, “message”: “”}

EntityFactory：


class EntityFactory {
 static T generateOBJ<T>(json) {
  if (json == null) {
   return null;
  }
//可以在这里加入任何需要并且可以转换的类型，例如下面
//  else if (T.toString() == "LoginEntity") {
//   return LoginEntity.fromJson(json) as T;
//  }
  else {
   return json as T;
  }
 }
}

BaseEntity：


class BaseEntity<T> {
 int code;
 String message;
 T data;

 BaseEntity({this.code, this.message, this.data});

 factory BaseEntity.fromJson(json) {
  return BaseEntity(
   code: json["code"],
   message: json["msg"],
   // data值需要经过工厂转换为我们传进来的类型
   data: EntityFactory.generateOBJ<T>(json["data"]),
  );
 }
}

BaseListEntity：


class BaseListEntity<T> {
 int code;
 String message;
 List<T> data;

 BaseListEntity({this.code, this.message, this.data});

 factory BaseListEntity.fromJson(json) {
  List<T> mData = List();
  if (json['data'] != null) {
   //遍历data并转换为我们传进来的类型
   (json['data'] as List).forEach((v) {
    mData.add(EntityFactory.generateOBJ<T>(v));
   });
  }

  return BaseListEntity(
   code: json["code"],
   message: json["msg"],
   data: mData,
  );
 } }

ErrorEntity：


class ErrorEntity {
 int code;
 String message;
 ErrorEntity({this.code, this.message});
}

NWApi：


class NWApi {
 static final baseApi = "https://easy-mock.bookset.io/mock/5dfae67d4946c20a50841fa7/example/";
 static final loginPath = "user/login";//接口返回：{"code": int, "message": "String", "data": {"account": "String", "password": "String"}}
 static final queryListPath = "/query/list";//接口返回：{"code": ing, "message": "String", "data": [int, int, String, int, String, int]}
 static final queryListJsonPath = "/query/listjson";//接口返回：{"code": int, "message": "String", "data": [{"account": "String", "password": "String"}， {"account": "String", "password": "String"}]}
}

NWMethod：


enum NWMethod {
 GET,
 POST,
 DELETE,
 PUT
}
//使用：NWMethodValues[NWMethod.POST]
const NWMethodValues = {
 NWMethod.GET: "get",
 NWMethod.POST: "post",
 NWMethod.DELETE: "delete",
 NWMethod.PUT: "put"
};

下面就可以进行正式的封装了：

第一步是创建Dio的单例辅助类，并初始化Dio和对Dio进行一些全局的参数设置：


import 'package:dio/dio.dart';
import 'package:flutter_app/network/NWApi.dart';
import 'package:flutter_app/utils/PrintUtil.dart';
class DioManager {
 static final DioManager _shared = DioManager._internal();
 factory DioManager() => _shared;
 Dio dio;
 DioManager._internal() {
  if (dio == null) {
   BaseOptions options = BaseOptions(
    baseUrl: NWApi.baseApi,
    contentType: Headers.jsonContentType,
    responseType: ResponseType.json,
    receiveDataWhenStatusError: false,
    connectTimeout: 30000,
    receiveTimeout: 3000,
   );
   dio = Dio(options);
  }
 }
}

第二步对请求进行封装，在我的想法中 {“code”: 0, “message”: “”, “data”: {}} 和 {“code”: 0, “message”: “”, “data”: []} 这两种数据是要分开两个请求方法的：


 // 请求，返回参数为 T
 // method：请求方法，NWMethod.POST等
 // path：请求地址
 // params：请求参数
 // success：请求成功回调
 // error：请求失败回调
 Future request<T>(NWMethod method, String path, {Map params, Function(T) success, Function(ErrorEntity) error}) async {
  try {
   Response response = await dio.request(path, queryParameters: params, options: Options(method: NWMethodValues[method]));
   if (response != null) {
    BaseEntity entity = BaseEntity<T>.fromJson(response.data);
    if (entity.code == 0) {
     success(entity.data);
    } else {
     error(ErrorEntity(code: entity.code, message: entity.message));
    }
   } else {
    error(ErrorEntity(code: -1, message: "未知错误"));
   }
  } on DioError catch(e) {
   error(createErrorEntity(e));
  }
 }

 // 请求，返回参数为 List
 // method：请求方法，NWMethod.POST等
 // path：请求地址
 // params：请求参数
 // success：请求成功回调
 // error：请求失败回调
 Future requestList<T>(NWMethod method, String path, {Map params, Function(List) success, Function(ErrorEntity) error}) async {
  try {
   Response response = await dio.request(path, queryParameters: params, options: Options(method: NWMethodValues[method]));
   if (response != null) {
    BaseListEntity entity = BaseListEntity<T>.fromJson(response.data);
    if (entity.code == 0) {
     success(entity.data);
    } else {
     error(ErrorEntity(code: entity.code, message: entity.message));
    }
   } else {
     error(ErrorEntity(code: -1, message: "未知错误"));
   }
  } on DioError catch(e) {
   error(createErrorEntity(e));
  }
 }

提取请求错误处理方法createErrorEntity：


 // 错误信息
 ErrorEntity createErrorEntity(DioError error) {
  switch (error.type) {
   case DioErrorType.CANCEL:{
    return ErrorEntity(code: -1, message: "请求取消");
   }
   break;
   case DioErrorType.CONNECT_TIMEOUT:{
    return ErrorEntity(code: -1, message: "连接超时");
   }
   break;
   case DioErrorType.SEND_TIMEOUT:{
    return ErrorEntity(code: -1, message: "请求超时");
   }
   break;
   case DioErrorType.RECEIVE_TIMEOUT:{
    return ErrorEntity(code: -1, message: "响应超时");
   }
   break;
   case DioErrorType.RESPONSE:{
    try {
     int errCode = error.response.statusCode;
     String errMsg = error.response.statusMessage;
     return ErrorEntity(code: errCode, message: errMsg);
//     switch (errCode) {
//      case 400: {
//       return ErrorEntity(code: errCode, message: "请求语法错误");
//      }
//      break;
//      case 403: {
//       return ErrorEntity(code: errCode, message: "服务器拒绝执行");
//      }
//      break;
//      case 404: {
//       return ErrorEntity(code: errCode, message: "无法连接服务器");
//      }
//      break;
//      case 405: {
//       return ErrorEntity(code: errCode, message: "请求方法被禁止");
//      }
//      break;
//      case 500: {
//       return ErrorEntity(code: errCode, message: "服务器内部错误");
//      }
//      break;
//      case 502: {
//       return ErrorEntity(code: errCode, message: "无效的请求");
//      }
//      break;
//      case 503: {
//       return ErrorEntity(code: errCode, message: "服务器挂了");
//      }
//      break;
//      case 505: {
//       return ErrorEntity(code: errCode, message: "不支持HTTP协议请求");
//      }
//      break;
//      default: {
//       return ErrorEntity(code: errCode, message: "未知错误");
//      }
//     }
    } on Exception catch(_) {
     return ErrorEntity(code: -1, message: "未知错误");
    }
   }
   break;
   default: {
    return ErrorEntity(code: -1, message: error.message);
   }
  }
 }

完整的 DioManager 类代码：


import 'package:dio/dio.dart';
import 'package:flutter_app/network/entity/BaseEntity.dart';
import 'package:flutter_app/network/entity/BaseListEntity.dart';
import 'package:flutter_app/network/entity/EntityFactory.dart';
import 'package:flutter_app/network/entity/ErrorEntity.dart';
import 'package:flutter_app/network/NWApi.dart';
import 'package:flutter_app/network/NWMethod.dart';
class DioManager {
 static final DioManager _shared = DioManager._internal();
 factory DioManager() => _shared;
 Dio dio;
 DioManager._internal() {
  if (dio == null) {
   BaseOptions options = BaseOptions(
    baseUrl: NWApi.baseApi,
    contentType: Headers.jsonContentType,
    responseType: ResponseType.json,
    receiveDataWhenStatusError: false,
    connectTimeout: 30000,
    receiveTimeout: 3000,
   );
   dio = Dio(options);
  }
 }

 // 请求，返回参数为 T
 // method：请求方法，NWMethod.POST等
 // path：请求地址
 // params：请求参数
 // success：请求成功回调
 // error：请求失败回调
 Future request<T>(NWMethod method, String path, {Map params, Function(T) success, Function(ErrorEntity) error}) async {
  try {
   Response response = await dio.request(path, queryParameters: params, options: Options(method: NWMethodValues[method]));
   if (response != null) {
    BaseEntity entity = BaseEntity<T>.fromJson(response.data);
    if (entity.code == 0) {
     success(entity.data);
    } else {
     error(ErrorEntity(code: entity.code, message: entity.message));
    }
   } else {
    error(ErrorEntity(code: -1, message: "未知错误"));
   }
  } on DioError catch(e) {
   error(createErrorEntity(e));
  }
 }

 // 请求，返回参数为 List
 // method：请求方法，NWMethod.POST等
 // path：请求地址
 // params：请求参数
 // success：请求成功回调
 // error：请求失败回调
 Future requestList<T>(NWMethod method, String path, {Map params, Function(List<T>) success, Function(ErrorEntity) error}) async {
  try {
   Response response = await dio.request(path, queryParameters: params, options: Options(method: NWMethodValues[method]));
   if (response != null) {
    BaseListEntity entity = BaseListEntity<T>.fromJson(response.data);
    if (entity.code == 0) {
     success(entity.data);
    } else {
     error(ErrorEntity(code: entity.code, message: entity.message));
    }
   } else {
    error(ErrorEntity(code: -1, message: "未知错误"));
   }
  } on DioError catch(e) {
   error(createErrorEntity(e));
  }
 }

 // 错误信息
 ErrorEntity createErrorEntity(DioError error) {
  switch (error.type) {
   case DioErrorType.CANCEL:{
    return ErrorEntity(code: -1, message: "请求取消");
   }
   break;
   case DioErrorType.CONNECT_TIMEOUT:{
    return ErrorEntity(code: -1, message: "连接超时");
   }
   break;
   case DioErrorType.SEND_TIMEOUT:{
    return ErrorEntity(code: -1, message: "请求超时");
   }
   break;
   case DioErrorType.RECEIVE_TIMEOUT:{
    return ErrorEntity(code: -1, message: "响应超时");
   }
   break;
   case DioErrorType.RESPONSE:{
    try {
     int errCode = error.response.statusCode;
     String errMsg = error.response.statusMessage;
     return ErrorEntity(code: "$errCode", message: errMsg);
//     switch (errCode) {
//      case 400: {
//       return ErrorEntity(code: errCode, message: "请求语法错误");
//      }
//      break;
//      case 403: {
//       return ErrorEntity(code: errCode, message: "服务器拒绝执行");
//      }
//      break;
//      case 404: {
//       return ErrorEntity(code: errCode, message: "无法连接服务器");
//      }
//      break;
//      case 405: {
//       return ErrorEntity(code: errCode, message: "请求方法被禁止");
//      }
//      break;
//      case 500: {
//       return ErrorEntity(code: errCode, message: "服务器内部错误");
//      }
//      break;
//      case 502: {
//       return ErrorEntity(code: errCode, message: "无效的请求");
//      }
//      break;
//      case 503: {
//       return ErrorEntity(code: errCode, message: "服务器挂了");
//      }
//      break;
//      case 505: {
//       return ErrorEntity(code: errCode, message: "不支持HTTP协议请求");
//      }
//      break;
//      default: {
//       return ErrorEntity(code: errCode, message: "未知错误");
//      }
//     }
    } on Exception catch(_) {
     return ErrorEntity(code: -1, message: "未知错误");
    }
   }
   break;
   default: {
    return ErrorEntity(code: -1, message: error.message);
   }
  }
 }
}

使用：


// 返回 LoginEntity
DioManager().request<LoginEntity>(
 NWMethod.POST,
 NWApi.loginPath,
 params: {"account": "421789838@qq.com", "password": "123456"},
 success: (data) {
   print("success data = $data"});
 }, error: (error) {
   print("error code = ${error.code}, massage = ${error.message}");
 }
);

// 返回 List
DioManager().requestList<LoginEntity>(
 NWMethod.POST,
 NWApi.queryListJsonPath,
 params: {"account": "421789838@qq.com", "password": "123456"},
 success: (data) {
   print("success data = $data"});
 }, error: (error) {
   print("error code = ${error.code}, massage = ${error.message}");
 }
);

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持得得之家。

本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除！

相关文档推荐

Flutter 日期时间DatePicker控件及国际化
这篇文章主要介绍了Flutter 日期时间DatePicker控件及国际化，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
Android Studio 下 Flutter 开发环境搭建过程
这篇文章主要介绍了Android Studio 下 Flutter 开发环境搭建/Flutter / Dart 插件安装 | Flutter SDK 安装 | 环境变量配置 | 开发环境检查,本文图文并茂给大家介绍的非常详细，需要的朋友可以参考下
Flutter应用集成极光推送的实现示例
这篇文章主要介绍了Flutter应用集成极光推送的实现示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
flutter  TextField换行自适应的实现
这篇文章主要介绍了flutter TextField换行自适应的实现,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
flutter 实现多布局列表的示例代码
这篇文章主要介绍了flutter 实现多布局列表的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
Flutter混合开发详解
这篇文章主要介绍了Flutter混合开发详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
前端开发编程语言数据库服务器系统/运维网络/安全移动开发建站教程网站运营
html vue validate adobe dreamweaver hbuilder vscode aptana editor dedecms ckeditor 编辑器 过滤 规则 织梦 图片本地化 模板 缩略图 图集 图片删除 ajax 瀑布流 无限下拉 cms 判断 sql 清除 tag 文档数 angularjs2 按钮 切换效果 vue3 thinkphp yii2 css 项目列表 li go Beego Buffalo Echo Gin Iris Revel 百度云 虚拟主机 pbootcms 伪静态 框架 排序 数据库 对象 字段 sql语句 php 字符串 分割 D3.js bootstrap 函数 svg selectAll 织梦cms 关键词 解析 采集 长度限制 日期 正则表达式