MVP架構簡介
對于一個應用而言我們需要對它抽象出各個層面，而在MVP架構中它將UI界面和數據進行隔離，所以我們的應用也就分為三個層次。
- View: 對于View層也是視圖層，在View層中只負責對數據的展示，提供友好的界面與用戶進行交互。在Android開發(fā)中通常將Activity或者Fragment作為View層。
- Model: 對于Model層也是數據層。它區(qū)別于MVC架構中的Model，在這里不僅僅只是數據模型。在MVP架構中Model它負責對數據的存取操作，例如對數據庫的讀寫，網絡的數據的請求等。
- Presenter:這一層處理著程序各種邏輯的分發(fā)，收到View層UI上的反饋命令、定時命令、系統命令等指令后分發(fā)處理邏輯交由Model層做具體的業(yè)務操作。
前言：
相信現在采用MVP模式開發(fā)的Android項目比比皆是，從剛開始的簡單的使用MVP解耦到現在對MVP的封裝優(yōu)化，我們這些開發(fā)者的項目架構也變得更加完善了。我記著自己以前剛開始封裝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);
}
