FlutterDio中怎么实现二次封装-创新互联

FlutterDio中怎么实现二次封装,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。

目前创新互联公司已为超过千家的企业提供了网站建设、域名、雅安服务器托管、网站托管维护、企业网站设计、乐安网站维护等服务,公司将坚持客户导向、应用为本的策略,正道将秉承"和谐、参与、激情"的文化,与客户和合作伙伴齐心协力一起成长,共同发展。

目录:

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);   }  } }}

使用:

// 返回 LoginEntityDioManager().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}"); });// 返回 ListDioManager().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}"); });

看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联网站建设公司,的支持。

分享题目:FlutterDio中怎么实现二次封装-创新互联
链接分享:https://www.cdcxhl.com/article10/cscodo.html

成都网站建设公司_创新互联,为您提供品牌网站建设搜索引擎优化商城网站建站公司动态网站网站设计公司

广告

声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联

h5响应式网站建设