flutter dio+rxdart

線上flutter 接口請求基本架構（線上實際項目搭建 很少講直接上代碼）

首先添加庫： pubspec.yaml 目錄下：

dio: ^2.1.2 #dio 請求框架
  rxdart: ^0.21.0 #rx框架
複製代碼

接口請求工具類：

class ApiDio {
  static ApiDio instance;
  static ApiService apiService;
  ApiDio(){
    var options = new BaseOptions(
        connectTimeout: 5000,
        receiveTimeout: 3000,
        baseUrl:TTicarConfig.baseUrl,// api 頭部例如 https://www.baidu.com
        contentType: new ContentType('application', 'x-www-form-urlencoded',
            charset: 'utf-8'));
    Dio dio = new Dio(options);
    dio.interceptors.add(AuthInterceptor());// 添加 token
    dio..interceptors.add(LogInterceptor(responseBody: true, requestBody: true)); //添加日誌
    apiService= new ApiService(dio);
  }

  static ApiService getInstance() {
    if (instance == null) {
      instance = new ApiDio();
    }
    return _getApiService();
  }
  static  ApiService _getApiService() {
    return apiService;
  }
}
/// AuthInterceptor
///
/// 添加header認證
class AuthInterceptor extends Interceptor {
  String PLATFORM = "android";//可根據代碼進行判斷
  String CLIENT = "store";
  @override
  onRequest(RequestOptions options) async{
    Map<String, String> headers = new Map();
    headers["Accept-Charset"] = "utf-8";
    headers["Connection"] = "keep-alive";
    headers["Accept"] = "*/*";
    headers["x-version"] = TTicarConfig.VERSION_NAME;//本身更改配置
    headers["x-platform"] = PLATFORM;
    headers["x-client"] = CLIENT;
    headers["x-equCode"] = TTicarConfig.equCode;//本身更改配置
    headers["Authorization"] = TTicarConfig.TOKEN;//本身更改配置

    options.headers=headers;
    return super.onRequest(options);
  }

}
複製代碼

設置請求類型（post get 可本身添加想要的類型）

class ApiService {
  ApiService(this.dio);
  Dio dio;
  //get請求結構
  Future _get(String url, {Map<String, dynamic> params}) async {
    var response = await dio.get(url, queryParameters: params);
    return response.data;
  }
  //post
  Future _post(String url, Map<String, dynamic> params) async {
    var response = await dio.post(url, data: params);
    return response.data;
  }

  Observable post(String url, Map<String, dynamic> params) =>
      Observable.fromFuture(_post(url, params)).asBroadcastStream();

  
  Observable get(String url, {Map<String, dynamic> params}) =>
      Observable.fromFuture(_get(url, params: params)).asBroadcastStream();

}
複製代碼

設置請求接口的工具類 (這不能夠精簡不須要或者經過註解的方式)

class TTicarWork {
  /*
  * 個人收藏商品列表
  * */
  Observable loadCollectGood(String pageNum, String pageSize) {
    Map<String, String> map = new Map();
    map["pageNum"] = pageNum;
    map["pageSize"] = pageSize;
    return ApiDio.getInstance().get("collection/good/list", params: map);
  }

}
複製代碼

請求接口

new TTicarWork().loadCollectGood(pageNum, "20").listen((request) {
      //接口請求成功 （request爲map） 本身設置解析數據
      
    }, onError: (e) {//請求異常等
    
    });
複製代碼

目前這個框架的缺陷 （若有更好的操做進行@我，我會逐漸修復）

1.沒有經過註解的方式進行請求數據
2.沒有自動解析數據
3.沒有對網絡進行判斷（能夠自行添加攔截器進行攔截判斷）

複製代碼