一步一步带你认识 MVP+Retrofit+Rxjava 并封装（一）
MVP 举例（附图）
有一家早餐店，他们家卖包子、馒头、油条、粥等等这些东西，他们需要用到最重要的东西是面粉（原材料：大米），每次早餐店老板都从一家面粉店（大米店）订购，而这些大米都是面粉店老板去农民伯伯那里收购的。在这个小例子当中，农民伯伯的任务就是生产出大米，这其实就相当于 MVP 模式中的Model，大米就是实体，生产大米就是业务的逻辑；面粉店老板负责收购大米然后加工成面粉，这其实就相当于 MVP 模式中的 Presenter，负责完成农民伯伯和早餐店老板这两边的间接交易；最后早餐店老板的任务就是负责将面粉做成各种各样的早餐供大家享用，这其实就相当于 MVP 模式中的 View，负责将面粉做成各种各样的食物呈现在大家眼前。好了，相信通过这个栗子大家应该对MVP模式有一定的了解了，下面来看一张图：
代码编写（步骤）
(1)、
首先我们来看一下 Model，这部分我理解的就是数据获得的地方，换句话说就是进行网络请求的地方（或者本地数据的获取），这里我写了一个 Base类，将所有的 Model 请求数据相同的部分都放到了一起：
public class BaseModel extends BaseRetrofit {
private static final String TAG = "BaseModel";
protected CygApi mServletApi; //所有的注解接口
protected Map<String, String> mParams = new HashMap<>();
public BaseModel() {
super();
mServletApi = mRetrofit.create(CygApi.class);
}
//获取公共参数
@Override
protected Map<String, String> getCommonMap() {
Map<String, String> commonMap = new HashMap<>();
commonMap.put("user_id", String.valueOf(UserDao.getInstance().getUserId()));
commonMap.put("token", String.valueOf(UserDao.getInstance().getToken()));
return commonMap;
}
//添加一个参数
protected void addParams(String key, String value) {
if (TextUtils.isEmpty(key)) {
Log.e(TAG, "the key is null");
return;
}
mParams.put(key, value);
}
//添加多个参数
protected void addParams(Map<String, String> params) {
if (null == params) {
Log.e(TAG, "the map is null");
return;
}
mParams.putAll(params);
}
}
这里网络请求用的是 Retrofit+RxJava，这一部分我打算放到下一篇再讲，在这个 Base 类里面主要添加了公共参数和添加普通参数。来看看一个登录的
Model：
public class LoginModel extends BaseModel {
public static LoginModel getInstance() {
return getPresent(LoginModel.class);
}
public void execute(String phone, String password, Observer<User> observer) {
addParams("username", phone);
addParams("password", password);
Observable observable = mServletApi.getUserInfo(mParams).map(new HttpFunction());
toSubscribe(observable, observer);
}
}
(2)、
这里我是用的单例模式（其实我也不知道这样写单例会不会有错，用类去实例化一个对象>_<我觉得没啥问题，哈哈哈），然后execute方法就是进行网络请求了，在Presenter中调用这个方法就行了。然后我们来看一下BasePresenter：
public class BasePresenter<VIEW> {
private WeakReference<VIEW> mViews;
protected void attachView(VIEW view) {
mViews = new WeakReference<VIEW>(view);
}
protected VIEW getView() {
return isViewAttached() ? mViews.get() : null;
}
private boolean isViewAttached() {
return null != mViews && null != mViews.get();
}
protected void detachView() {
if (null != mViews) {
mViews.clear();
mViews = null;
}
}
}
在
BasePresenter里面我只是关注了View，按照MVP模式的理解，我们应该在这个里面同时关注View和Model，确实，很多 demo 都是这样干的，但是LZ前面是用的单例来写Model，所以在BasePresenter里面就暂时先关注View，还有一点需要说明的是，这里对View使用的弱引用，我们都知道View通常来说都是很大只的存在，为了防止内存泄漏，使用弱引用来及时释放内存。来看看一个登录的LoginPresenter：
public class LoginPresenter extends BasePresenter<LoginView<User>> {
public LoginPresenter(LoginView<User> loginView) {
attachView(loginView);
}
public void getUserInfo(BaseImpl baseImpl) {
LoginModel.getInstance().execute(getView().getUserName(), getView().getPassword(), new CygBaseObserver<User>(baseImpl, "正在登录") {
@Override
protected void onBaseNext(User data) {
UserInfo userInfo = new UserInfo();
userInfo.setId(data.getId());
userInfo.setUsername(getView().getUserName());
userInfo.setToken(data.getToken());
UserDao.getInstance().deleteAll(UserInfo.class);
UserDao.getInstance().insertObject(userInfo);
getView().onRequestSuccessData(data);
}
});
}
public void toMainActivity(Activity activity) {
activity.startActivity(new Intent(activity, MainActivity.class));
}
}
(3)、
在登录的 LoginPresenter 中调用 LoginModel 进行网络请求，只返回一个成功的回调，失败的回调我们在内部处理掉了，然后在回调成功之后做相应的数据操作（该回调给 View的就回调给 View，该存本地的就存本地）。然后来看看我们的 View：
public class LoginActivity extends BaseActivity<LoginPresenter> implements LoginView<User> {
@BindView(R.id.al_et_user_name)
TextInputEditText alEtUserName;
@BindView(R.id.al_et_password)
TextInputEditText alEtPassword;
@Override
protected int layoutRes() {
return R.layout.activity_login;
}
@Override
protected LoginPresenter createPresenter() {
return new LoginPresenter(this);
}
@Override
protected void initView() {
}
@Override
public String getUserName() {
return alEtUserName.getText().toString().trim();
}
@Override
public String getPassword() {
return alEtPassword.getText().toString().trim();
}
@OnClick(R.id.al_btn_login)
public void onViewClicked() {
if (TextUtils.isEmpty(getUserName())) {
alEtPassword.setError("用户名不能为空");
return;
}
if (TextUtils.isEmpty(getPassword())) {
alEtPassword.setError("密码不能为空");
return;
}
mPresenter.getUserInfo(this);
}
@Override
public void onBackPressed() {
super.onBackPressed();
moveTaskToBack(true);
}
@Override
public void onRequestSuccessData(User data) {
mPresenter.toMainActivity(this);
}
}
在
View中，就是初始化Presenter，然后各种调Presenter中的方法，这里本来是可以在Presenter中直接调用toMainActivity()方法的，为了演示成功回调之后再回调给View，这里我就多做了一步操作。好了，接下来我们来看看接口：
public interface BaseRequestContract<T> {
void onRequestSuccessData(T data);
}
这里写了一个
Base接口，由于大多时候我们只关注成功的回调数据，这里我也只写了一个成功回调的方法（如果你有其他的需求，你可以在这里加一些公共的方法），如果你有需要的话你可以在子类中写错误回调的接口，接着我们来看看登录的接口有哪些方法：
public interface LoginView<T> extends BaseRequestContract<T>{
String getUserName();
String getPassword();
}
这里我需要获得用户的输入信息，所以只简单定义了两个方法用来获取用户名和密码。到这里我们的
MVP模式就简单封装的差不多了，接下来我们来看一下最终的效果吧：
这里用eclipse+tomcat+mysql简单写了一个登录接口，这一部分LZ在之前的博客中有详细讲解，如有兴趣，请移步：
android开发怎么少的了后端（上）
android开发怎么少的了后端（中）
android开发怎么少的了后端（下）
好了，MVP 的基本封装就讲到这里，下一节我们再来讲一下 Retrofit+Rxjava 的简单封装及使用，这里先奉上代码：
MVP 主工程代码 https://github.com/Jakemesdg/MVPDemo
MVP module工程代码 https://github.com/Jakemesdg/cygmodule
可能很多人就会问了，为什么会有两份呢，这里我给大家看看我的项目工程
与之相关
关键词：code小生