在andorid开发中越来越多的见到MVP的身影，做过web的开发的都知道web三层架构，而我们的MVP也有异曲同工之处，下面我们看下MVP的总体架构，将Model通过Prensenter完全与View隔离开来，大大减轻了View的负担
下面以简单的登录模块，来展示最基本的MVP
根据基本的OOP原则，V、P、M层都使用了接口来实现，当然也可以不用这么麻烦。
首先看View接口内,展示我们登录的结果，而LoginActivity则实现了LoginView接口，实现showLoginResult(String msg)方法，同时在onCreate方法中也对Presenter进行了初始化，在登录按钮点击时，调用Presenter的Login方法
public interface LoginView {
void showLoginResult(String msg);
}
@Override
public void showLoginResult(String msg) {
ToastUtil.shortToast(getApplicationContext(),msg);
}
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_login);
ButterKnife.inject(this);
loginPresenter = new LoginPresenterImpl(this,LoginActivity.this);
initData();
}
@OnClick(R.id.tv_login)
public void tvLogin(Button tv){
String mobile=edtAccount.getText().toString().trim();
if (!RegexTool.isMobile(mobile)){
ToastUtil.shortToast(getApplicationContext(),"请输入正确的11位手机号~~");
return;
}
String password=edtPassword.getText().toString().trim();
loginPresenter.login(mobile,password);
}
再来看我们的Presenter层接口，最简单的登录方法接口，然后看到LoginPresenterImpl接口的实现类，所以我们可以在接口实现类LoginPresenterImpl的构造方法中，进行View和Model的初始化，在这里实现了Presenter的Login方法，然后再调用Model的Login的方法，进行网络层的请求。
在Presenter层就同时持有View和Model，这样我们就可以在P层处理Model返回的数据及View根据M所做的UI改变
public interface LoginPresenter {
void login(String phone,String passWord);
}
public LoginPresenterImpl(LoginView loginView,Context context) {
this.loginView = loginView;
loginModel = new LoginModelImpl();
}
在Login方法里，我们用到了RxJava、RxAndroid编程
@Override
public void login(final String phone, final String passWord) {
subscription = loginModel.login(phone,passWord)
.observeOn(AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.io())
.subscribe(new Subscriber<LoginBean>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
if (e!=null)
loginView.showLoginResult(e.getMessage());
}
@Override
public void onNext(LoginBean loginBean) {
String message = loginBean.getMessage();
loginView.showLoginResult(message);
String status = loginBean.getStatus();
if (status!=null&&status.equals("1")){
// ToDo
}
}
});
}
对于这一段代码我们先不深究，首先看到是调用了Model的Login方法，我们看一下LoginModel及其实现类
public interface LoginModel {
Observable<LoginBean> login(String phone, String passWord);
}
public class LoginModelImpl implements LoginModel {
@Override
public Observable<LoginBean> login(final String phone, final String passWord) {
return Observable.create(new Observable.OnSubscribe<LoginBean>() {
@Override
public void call(Subscriber<? super LoginBean> subscriber) {
try {
Map<String ,String> params=new HashMap<>();
params.put(MemberController.Login.PARAMS.MOBILE,phone);
params.put(MemberController.Login.PARAMS.PASSWORD,passWord);
params.put(MemberController.Login.PARAMS.LOGINTYPE,"0");
Response response = OkHttpUtils
.post()
.url(MemberController.Login.URL)
.params(params)
.build().execute();
String result=response.body().string();
LoginBean loginBean = new Gson().fromJson(result, LoginBean.class);
subscriber.onNext(loginBean);
subscriber.onCompleted();
} catch (IOException e) {
e.printStackTrace();
subscriber.onError(new Throwable("网络连接超时"));
subscriber.onCompleted();
}
}
});
}
}
这样一次基本的Login，通过MVP的调用就完成了请求到，展示的过程。
下面我们再来看一下RxJava的简单解析。
整体来说，RxJava是一个基于观察者模式的处理异步编程的库，它让代码的异步操作变得非常简单，（当然还有很多其他方面，先不深究）。
在LoginModelImpl中，我们看到创建了一个被观察者Observable，在里面我们调用了订阅者subscriber的onNext、onComplete、onError方法。在这里以登录为例，当正常返回LoginBean的时候，我们就调用subscriber的onNext方法，将数据传给订阅者；当数据连接异常的时候，调用subscriber的onError方法，将异常传递给订阅者。
下面我们看一下Observable的观察订阅者，即LoginPresenterImpl的login方法
loginModel.login(phone,passWord)
.observeOn(AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.io())
.subscribe(new Subscriber<LoginBean>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
if (e!=null)
loginView.showLoginResult(e.getMessage());
}
@Override
public void onNext(LoginBean loginBean) {
}
可以看到在LoginModelImpl中，我们并没有开启网络请求线程， .subscribeOn(Schedulers.io())代表了Observable在子线程，而
observeOn(AndroidSchedulers.mainThread())表示在主线程订阅，可以看到通过非常简单的两句话，就完成了线程的切换。subscribe(new Subscriber<LoginBean>() {}，这里就是我们的订阅者，onNext、onComplete、onError的三个方法，就会回调之前LoginModelImpl中的被订阅者Observeable。这样就基本完成了Rxjava的简单流程。
当然，订阅记得调用subscription的解除订阅，subscription.unsubscribe();
最后，细心的观察会发现这上面的MVP有可能会产生内存泄漏，我们在订阅的时候使用了匿名内部类，而匿名内部类默认持有外部类的引用，而外部类LoginPresenterImpl又持有了LoginActivity.this，这样当我们的请求很慢，还没返回数据时，我们就退出Actiivty，则就会产生资源无法释放，导致内存泄漏。这个问题后面再解决了。
