Retrofit+MVP框架封装记录篇

当下最流行的网络请求组合，retrofit2+okhttp+rxjava+mvp

Retrofit+MVP框架封装记录篇

这里是封装记录篇

首先分模块，比如登录

Retrofit+MVP框架封装记录篇

先来说封装后的使用

package com.fragmentapp.login.presenter;

import android.util.Log;

import com.fragmentapp.base.BasePresenter;

import com.fragmentapp.http.BaseObserver;

import com.fragmentapp.http.BaseResponses;

import com.fragmentapp.login.bean.LoginDataBean;

import com.fragmentapp.login.imple.ILoginModel;

import com.fragmentapp.login.imple.ILoginView;

import com.fragmentapp.login.model.LoginModel;

/**

 * Created by liuzhen on 2017/11/3.

 */

public class LoginPresenter extends BasePresenter {

    private ILoginView view;

    private ILoginModel model;

    public LoginPresenter(ILoginView view){

        this.view = view;

        model = new LoginModel();

    }

    public void login(String username,String pwd){

        model.login(observer,username,pwd);

    }

    BaseObserver<BaseResponses<LoginDataBean>> observer = new BaseObserver<BaseResponses<LoginDataBean>>(){

        @Override

        public void onNextResponse(BaseResponses<LoginDataBean> loginDataBean) {

            Log.e("token",loginDataBean.getData().getHCACCESSTOKEN()+"");

            view.success(loginDataBean.getData());

        }

        @Override

        public void onErrorResponse(BaseResponses<LoginDataBean> loginDataBean) {

            view.error();

        }

        @Override

        public void onNetWorkError(String val) {

            view.error();

        }

    };

}

Presenter

通过p层的接口来交互，model去访问网络请求，然后返回结果回调返回到view层去刷新

这里自定义了一个base的obsever类，避免多次的传递接口

Retrofit+MVP框架封装记录篇

model则负责调用网络请求了

package com.fragmentapp.login.model;

import com.fragmentapp.http.BaseObserver;

import com.fragmentapp.http.BaseResponses;

import com.fragmentapp.http.RetrofitHelper;

import com.fragmentapp.login.bean.LoginDataBean;

import com.fragmentapp.login.imple.ILoginModel;

import java.util.HashMap;

import java.util.Map;

import io.reactivex.android.schedulers.AndroidSchedulers;

import io.reactivex.schedulers.Schedulers;

/**

 * Created by liuzhen on 2017/11/7.

 */

public class LoginModel implements ILoginModel {

    @Override

    public void login(final BaseObserver<BaseResponses<LoginDataBean>> observer,String username,String pwd) {

        Map<String, String> map = new HashMap<>();

        map.put("account[username]", username);

        map.put("account[password]", pwd);

        RetrofitHelper.getInstance().getService()

                .login(map)

                .subscribeOn(Schedulers.io())

                .observeOn(AndroidSchedulers.mainThread())

                .subscribe(observer);

    }

}

view层的回调也只有两个接口，可以根据自己的需求添加

package com.fragmentapp.login.imple;

import com.fragmentapp.login.bean.LoginDataBean;

/**

 * Created by liuzhen on 2017/11/6.

 */

public interface ILoginView {

    void success(LoginDataBean dataBean);

    void error();

}

Retrofit+MVP框架封装记录篇

访问网络后直接在activity里处理回调的结果刷新界面等

这里的retrofit的访问url是用的添加头部tag来达到动态访问替换baseurl的目的

Retrofit+MVP框架封装记录篇

然后接口参数采用map的方式添加，个人感觉一个个分开来跟烦，每次都得改service类

Retrofit+MVP框架封装记录篇

然后observable套用了一层类型，这里主要是后台数据格式吭，可以去掉

package com.fragmentapp.http;

/**

 * Created by liuzhen on 2017/11/3.

 */

public class BaseResponses<T> {

    private String info;

    private int status;

    private T data;

    public String getInfo() {

        return info;

    }

    public void setInfo(String info) {

        this.info = info;

    }

    public int getStatus() {

        return status;

    }

    public void setStatus(int status) {

        this.status = status;

    }

    public T getData() {

        return data;

    }

    public void setData(T data) {

        this.data = data;

    }

}

然后是base的observer类，在里面根据自己的业务去回调自定义的接口，这样就不用每次重载这么多的方法了

package com.fragmentapp.http;

import android.os.Looper;

import android.util.Log;

import io.reactivex.Observer;

import io.reactivex.disposables.Disposable;

/**

 * Created by liuzhen on 2017/11/3.

 */

public abstract class BaseObserver<T extends BaseResponses> implements Observer<T> {

    String TAG = getClass().getSimpleName();

    @Override

    public void onSubscribe(Disposable d) {

        Log.e(TAG, "onSubscribe");

    }

    @Override

    public void onNext(T t) {

        Log.e(TAG, "onNext"+t);

        if (t.getStatus() == 200) {

            onNextResponse(t);

        } else {

            Log.e(TAG, "ErrorStatus:" + t.getStatus() + "ErrorInfo" + t.getInfo());

            onErrorResponse(t);

        }

    }

    @Override

    public void onError(Throwable e) {

        Log.e(TAG, "onError" + e.toString());

        onNetWorkError("onError 网络超时，请重新尝试--"+e.getMessage());

        if (Looper.myLooper() == null) {

            Looper.prepare();

            Log.e(TAG,"onError 网络超时，请重新尝试");

            Looper.loop();

        }

    }

    @Override

    public void onComplete() {

        Log.e(TAG, "onComplete");

    }

    /**返回成功*/

    public abstract void onNextResponse(T t);

    /**接口失败信息*/

    public abstract void onErrorResponse(T t);

    /**网络错误*/

    public abstract void onNetWorkError(String val);

}