Android MVP+Retrofit+RxJava实践小结

关于MVP、Retrofit、RxJava，以前已经分别作了分享，若是您尚未阅读过，能够猛戳：
一、Android MVP 实例
二、Android Retrofit 2.0使用
三、RxJava
四、RxBus

假设，您对MVP、Retrofit、RxJava已经有了一点了解，那么咱们开始本文：

Android MVP优化

一、MVP绑定Activity（Fragment）生命周期
按照以前的文章，每一个Presenter都得初始化和销毁，我新加MvpActivity(MvpFragment)，加了抽象方法protected abstract P createPresenter();这样作的目的在须要使用MVP的地方，能够继承MvpActivity(MvpFragment)，而后初始化和销毁就不用手动一个个去加了。

二、接口请求等仍是放到MVP的P中

这个图片，在当时写MVP文章时给出的，实际开发中，我发现每一个都这样写，实在是增长了很多代码，然接口请求放到P中，还有个好处，就是MVP绑定Activity（Fragment）生命周期，当onDestroy时取消RXJava注册，以免内存泄露。

代码

目录结构

如图，有个大体了解：

mvp：全部的mvp都放在这个包下
retrofit：Retrofit接口和配置文件
rxjava：RxJava一些回调设置
ui：Activity或fragment，建议按功能再细分包

核心代码

仍是就贴出核心代码吧，源码在个人github上（https://github.com/WuXiaolong/AndroidMVPSample）。

MainActivity入口，仍是演示的以前的MVP的天气的接口，接口请求方法放在Presenter。

MvpActivity

Presenter绑定Activity（Fragment）生命周期

public abstract class MvpActivity<P extends BasePresenter> extends BaseActivity {
    protected P mvpPresenter;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        mvpPresenter = createPresenter();
        super.onCreate(savedInstanceState);
    }

    protected abstract P createPresenter();

    @Override
    protected void onDestroy() {
        super.onDestroy();
        if (mvpPresenter != null) {
            mvpPresenter.detachView();
        }
    }
}

MainPresenter

apiStores.loadData方法是Retrofit作的网络请求，回调是RxJava完成的。

public class MainPresenter extends BasePresenter<MainView> {

    public MainPresenter(MainView view) {
        attachView(view);
    }
   
    public void loadData(String cityId) {
        mvpView.showLoading();
        addSubscription(apiStores.loadData(cityId),
                new SubscriberCallBack<>(new ApiCallback<MainModel>() {
                    @Override
                    public void onSuccess(MainModel model) {
                        mvpView.getDataSuccess(model);
                    }

                    @Override
                    public void onFailure(int code, String msg) {
                        mvpView.getDataFail(msg);
                    }

                    @Override
                    public void onCompleted() {
                        mvpView.hideLoading();
                    }
                }));
    }

}

apiStores.loadData

是否是很简单，关于Retrofit配置，详见源码AppClient。

public interface ApiStores {
    //baseUrl
    String API_SERVER_URL = "http://www.weather.com.cn/";

    //加载天气
    @GET("adat/sk/{cityId}.html")
    Observable<MainModel> loadData(@Path("cityId") String cityId);
}

RxJava回调方法

这里onError，写了若是网络请求用httpcode来判断。固然能够不要。

public class SubscriberCallBack<T> extends Subscriber<T> {
    private ApiCallback<T> apiCallback;

    public SubscriberCallBack(ApiCallback<T> apiCallback) {
        this.apiCallback = apiCallback;
    }

    @Override
    public void onCompleted() {
        apiCallback.onCompleted();
    }

    @Override
    public void onError(Throwable e) {
        e.printStackTrace();
        if (e instanceof HttpException) {
            HttpException httpException = (HttpException) e;
            //httpException.response().errorBody().string()
            int code = httpException.code();
            String msg = httpException.getMessage();
            if (code == 504) {
                msg = "网络不给力";
            }
            apiCallback.onFailure(code, msg);
        } else {
            apiCallback.onFailure(0, e.getMessage());
        }
        apiCallback.onCompleted();
    }

    @Override
    public void onNext(T t) {
        apiCallback.onSuccess(t);
    }
}

BasePresenter

再来看看BasePresenter，这里作了Presenter初始化和销毁(包括RXjava取消注册)，调用在MvpActivity。

public class BasePresenter<V> implements Presenter<V> {
    public V mvpView;
    public ApiStores apiStores = AppClient.retrofit().create(ApiStores.class);
    private CompositeSubscription mCompositeSubscription;

    @Override
    public void attachView(V mvpView) {
        this.mvpView = mvpView;
    }

    @Override
    public void detachView() {
        this.mvpView = null;
        onUnsubscribe();
    }

    //RXjava取消注册，以免内存泄露
    public void onUnsubscribe() {
        if (mCompositeSubscription != null && mCompositeSubscription.hasSubscriptions()) {
            mCompositeSubscription.unsubscribe();
        }
    }

    public void addSubscription(Observable observable, Subscriber subscriber) {
        if (mCompositeSubscription == null) {
            mCompositeSubscription = new CompositeSubscription();
        }
        mCompositeSubscription.add(observable
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(subscriber));
    }
}

源码地址

https://github.com/WuXiaolong/AndroidMVPSample

总结

三者结合使用，重点仍是对MVP的优化，Retrofit只贴出最简单的（后续会写Retrofit详情使用），Rxjava可能我是对它认识尚浅，实际运用最多仍是RxBus。

微信公众号

个人微信公众号：吴小龙同窗。