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