MVP架构简介

对于一个应用而言我们需要对它抽象出各个层面，而在MVP架构中它将UI界面和数据进行隔离，所以我们的应用也就分为三个层次。

View: 对于View层也是视图层，在View层中只负责对数据的展示，提供友好的界面与用户进行交互。在Android开发中通常将Activity或者Fragment作为View层。
Model: 对于Model层也是数据层。它区别于MVC架构中的Model，在这里不仅仅只是数据模型。在MVP架构中Model它负责对数据的存取操作，例如对数据库的读写，网络的数据的请求等。
Presenter:这一层处理着程序各种逻辑的分发，收到View层UI上的反馈命令、定时命令、系统命令等指令后分发处理逻辑交由Model层做具体的业务操作。

前言：

相信现在采用MVP模式开发的Android项目比比皆是，从刚开始的简单的使用MVP解耦到现在对MVP的封装优化，我们这些开发者的项目架构也变得更加完善了。我记着自己以前刚开始封装MVP的时候也是遇到了不少的问题，而且我之前对M层的封装一直不是很完美，一直也想研究出一个更好的对M层封装的方法。直到前段时间一位大佬对我的MVP框架指导了一番，我改造了一下之后，个人感觉很完美。

注意：我的框架是RxJava+Retrofit +MVP，还使用了RxAndroid

废话不多说了，上代码：

这是一个基本的登录注册的M层

先放上BaseModel的代码：

public class BaseRepository {
    
    public static <T, R> void observer(LifecycleProvider provider, Observable<T> observable, Function<T, ObservableSource<R>> function, final IBaseCallBack<R> callBack) {

       observable.flatMap(function)
                .subscribeOn(Schedulers.io())
                .unsubscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .compose(provider instanceof RxAppCompatActivity ? ((RxAppCompatActivity)provider).<R>bindUntilEvent(ActivityEvent.DESTROY)
                        : ((RxFragment)provider).<R>bindUntilEvent(FragmentEvent.DESTROY_VIEW))
                .subscribe(new Observer<R>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onNext(R r) {
                        if(BuildConfig.DEBUG){
                            Logger.d("%s onNext = ", getClass().getSimpleName(), r.toString());
                        }
                        callBack.onSuccess(r);
                    }

                    @Override
                    public void onError(Throwable e) {
                        if(BuildConfig.DEBUG){
                            e.printStackTrace();
                            Logger.d("%s onError = ", getClass().getSimpleName(), e.getMessage());
                        }
                        callBack.onFail(e.getMessage());
                    }

                    @Override
                    public void onComplete() {

                    }
                });
    }
}

M层使用时的代码：

public class LoginRepository extends BaseRepository implements LoginContract.ILoginSource {

    private ApiService mApiService;
    
    public LoginRepository(){
        mApiService = WADataService.getService();
    }
    
    @Override
    public void register(LifecycleProvider provider, Map<String, String> params, final IBaseCallBack<User> callBack) {
        request(provider, mApiService.register(params), callBack);
    }

    @Override
    public void login(LifecycleProvider provider, Map<String, String> params, IBaseCallBack<User> callBack) {
        request(provider, mApiService.login(params), callBack);
    }

    private void request(LifecycleProvider provider, Observable<HttpResult<User>> observable, IBaseCallBack<User> callBack){

        observer(provider, observable,new Function<HttpResult<User>, ObservableSource<User>>() {
            @Override
            public ObservableSource<User> apply(HttpResult<User> userHttpResult) throws Exception {
                if(userHttpResult.errorCode == 0 && userHttpResult.data != null){
                    return Observable.just(userHttpResult.data);
                }

                String msg = "服务器返回数据为空";
                if(!TextUtils.isEmpty(userHttpResult.errorMsg)){
                    msg = userHttpResult.errorMsg;
                }

                return Observable.error(new NullPointerException(msg));
            }
        },callBack);
    }
}

还有M层的接口：

public interface ILoginSource{

        void register(LifecycleProvider provider, Map<String,String> params, IBaseCallBack<User> callBack);

        void login(LifecycleProvider provider,Map<String,String> params,IBaseCallBack<User> callBack);

}