嗯绽昼，這篇博客應(yīng)該有個(gè)副標(biāo)題：Retrofit + RxJava + RxLifecycle + MVP
在上一篇文章中，我們對(duì)Retrofit進(jìn)行了封裝须蜗，But硅确，這種封裝是不支持MVP模式的，今天就以Retrofit和RxJava為基礎(chǔ)唠粥，談?wù)勎宜斫獾腗VP疏魏。
《Android Retrofit + RxJava使用詳解》
《Android 探討一下Retrofit封裝的最佳姿勢(shì)》
1.MVP VS MVC
首先來兩張圖感受一下：
兩種模式的分層處理中，思想大致相同晤愧，Model提供數(shù)據(jù)大莫，Presenter/Controller負(fù)責(zé)邏輯處理，View負(fù)責(zé)UI顯示官份，但是在各層之間的調(diào)用方面卻有很大的區(qū)別：
在MVP模式中只厘，View是不能直接使用Model的，他們之前的通信需要借助Presenter來完成舅巷，而View與Presenter之間的通信則需要通過接口來完成羔味，這樣就將視圖層與邏輯層進(jìn)行了分離，也就是解耦钠右。
在MVC模式中赋元，View是可以直接使用Model的，這樣在View中也會(huì)存在邏輯處理飒房，視圖層與邏輯層耦合在一起搁凸，一旦需求發(fā)生變動(dòng)，代碼修改起來是很困難的狠毯。
2.MVP實(shí)踐
首先看下項(xiàng)目結(jié)構(gòu)：
做一些準(zhǔn)備工作
定義一個(gè)請(qǐng)求參數(shù)接口护糖，還是以上一篇文章中用到的接口為例：
public interface RetrofitService {
/**
* 獲取快遞信息
* Rx方式
*
* @param type 快遞類型
* @param postid 快遞單號(hào)
* @return Observable<ExpressInfo>
*/
@GET(Constant.UrlOrigin.get_express_info)
Observable<ExpressInfo> getExpressInfoRx(@Query("type") String type, @Query("postid") String postid);
}
定義Retrofit幫助類嫡良，用于Retrofit與RetrofitService的初始化：
public class RetrofitHelper {
private static RetrofitHelper retrofitHelper;
private RetrofitService retrofitService;
public static RetrofitHelper getInstance() {
return retrofitHelper == null ? retrofitHelper = new RetrofitHelper() : retrofitHelper;
}
private RetrofitHelper() {
// 初始化Retrofit
Retrofit retrofit = new Retrofit.Builder()
.baseUrl(Constant.SERVER_URL)
.addConverterFactory(GsonConverterFactory.create()) // json解析
.addCallAdapterFactory(RxJava2CallAdapterFactory.create()) // 支持RxJava
.build();
retrofitService = retrofit.create(RetrofitService.class);
}
public RetrofitService getRetrofitService() {
return retrofitService;
}
}
Model層
public class DataManager {
private static DataManager dataManager;
private RetrofitService retrofitService;
public static DataManager getInstance() {
return dataManager == null ? dataManager = new DataManager() : dataManager;
}
private DataManager() {
retrofitService = RetrofitHelper.getInstance().getRetrofitService();
}
/**
* 獲取快遞信息
*
* @param type 快遞類型
* @param postid 快遞單號(hào)
* @return Observable<ExpressInfo>
*/
public Observable<ExpressInfo> getExpressInfo(String type, String postid) {
return retrofitService.getExpressInfoRx(type, postid);
}
}
使用了單例模式，在構(gòu)造方法中獲取RetrofitService實(shí)例羡蛾，定義getExpressInfo方法痴怨，返回泛型為ExpressInfo的被觀察者對(duì)象，稍后在Presenter中會(huì)用到捐迫。
其實(shí)在寫這個(gè)類之前也想了好久施戴，Model層是用一個(gè)類來寫赞哗，還是根據(jù)業(yè)務(wù)區(qū)分來寫辆雾，后來發(fā)現(xiàn)大部分的數(shù)據(jù)處理都可以在這一個(gè)類中完成度迂，索性就只寫在一個(gè)類里，大家在使用的過程中坛梁，可以根據(jù)具體的需求來選擇划咐。
View層
首先定義Presenter與View之間進(jìn)行通信的接口尖殃，在基類中定義一些通用的方法划煮，子類中加入更新UI的方法：
public interface BaseView {
/**
* 顯示Loading
*/
void showProgressDialog();
/**
* 隱藏Loading
*/
void hideProgressDialog();
/**
* 顯示錯(cuò)誤信息
*
* @param msg 錯(cuò)誤信息
*/
void showError(String msg);
}
public interface ExpressView extends BaseView {
/**
* 更新UI
*
* @param expressInfo 快遞信息
*/
void updateView(ExpressInfo expressInfo);
}
Activity實(shí)現(xiàn)ExpressView接口，在接口的回調(diào)方法中進(jìn)行UI的更新：
public class MainActivity extends BaseActivity implements ExpressView {
@BindView(R.id.tv_post_info)
TextView tvPostInfo;
private ProgressDialog progressDialog;
private ExpressPresenter expressPresenter;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
ButterKnife.bind(this);
expressPresenter = new ExpressPresenter(this, this);
progressDialog = new ProgressDialog(this);
progressDialog.setMessage("正在獲取快遞信息...");
}
@OnClick(R.id.btn_get_post_info)
public void onViewClicked() {
expressPresenter.getExpressInfo("yuantong", "11111111111");
}
@Override
public void updateView(ExpressInfo expressInfo) {
tvPostInfo.setText(expressInfo.toString());
}
@Override
public void showProgressDialog() {
progressDialog.show();
}
@Override
public void hideProgressDialog() {
progressDialog.hide();
}
@Override
public void showError(String msg) {
Toast.makeText(this, msg, Toast.LENGTH_SHORT).show();
}
}
由于使用了RxJava蟹略，而RxJava有可能會(huì)引起內(nèi)存泄漏挖炬，所以使用RxLifecycle框架來管理RxJava意敛，在BaseActivity中繼承RxAppCompatActivity：
如果你對(duì)RxLifecycle還不太了解，可以看下這篇文章《Android 使用RxLifecycle解決RxJava內(nèi)存泄漏》钓猬。
public class BaseActivity extends RxAppCompatActivity {
}
Presenter層
首先看下BasePresenter：
public class BasePresenter {
private LifecycleProvider<ActivityEvent> provider;
public BasePresenter(LifecycleProvider<ActivityEvent> provider) {
this.provider = provider;
}
public LifecycleProvider<ActivityEvent> getProvider() {
return provider;
}
}
由于使用了RxLifecycle框架來管理RxJava敞曹，而RxLifecycle與RxJava的綁定是在Presenter中進(jìn)行的澳迫，所以就需要在構(gòu)造Presenter時(shí)傳入LifecycleProvider<ActivityEvent>接口的實(shí)例剧劝。上文提到MainActivity最終繼承了RxAppCompatActivity担平，在RxAppCompatActivity內(nèi)部又實(shí)現(xiàn)了LifecycleProvider<ActivityEvent>接口，所以在構(gòu)造Presenter時(shí)直接傳入this就可以了面褐。
public class ExpressPresenter extends BasePresenter {
private ExpressView expressView;
private DataManager dataManager;
public ExpressPresenter(ExpressView expressView, LifecycleProvider<ActivityEvent> provider) {
super(provider);
this.expressView = expressView;
dataManager = DataManager.getInstance();
}
/**
* 獲取快遞信息
*
* @param type 快遞類型
* @param postid 快遞單號(hào)
*/
public void getExpressInfo(String type, String postid) {
expressView.showProgressDialog();
dataManager.getExpressInfo(type, postid)
.subscribeOn(Schedulers.io()) // 在子線程中進(jìn)行Http訪問
.observeOn(AndroidSchedulers.mainThread()) // UI線程處理返回接口
.compose(getProvider().<ExpressInfo>bindUntilEvent(ActivityEvent.DESTROY)) // onDestroy取消訂閱
.subscribe(new DefaultObserver<ExpressInfo>() { // 訂閱
@Override
public void onNext(@NonNull ExpressInfo expressInfo) {
expressView.updateView(expressInfo);
}
@Override
public void onError(@NonNull Throwable e) {
expressView.showError(e.getMessage());
expressView.hideProgressDialog();
}
@Override
public void onComplete() {
expressView.hideProgressDialog();
}
});
}
}
在構(gòu)造方法中傳入ExpressView與LifecycleProvider<ActivityEvent>接口的實(shí)例，定義getExpressInfo方法闻蛀，在其中調(diào)用DataManager類的同名方法（根據(jù)實(shí)際需求命名），返回被觀察者對(duì)象觉痛，然后進(jìn)行訂閱薪棒，在onNext、onError棵介、onComplete中分別回調(diào)ExpressView接口中對(duì)應(yīng)的方法邮辽。
看下這行代碼compose(getProvider().<ExpressInfo>bindUntilEvent(ActivityEvent.DESTROY))，表示在Activity銷毀的時(shí)候取消訂閱岩睁，避免內(nèi)存泄漏锐极。
OK灵再，到這里MVP模式就講完了！
3.寫在最后
源碼已托管到GitHub上栋猖，歡迎Fork蒲拉，覺得還不錯(cuò)就Start一下吧痴腌！
歡迎同學(xué)們吐槽評(píng)論士聪，如果你覺得本篇博客對(duì)你有用，那么就留個(gè)言或者點(diǎn)下喜歡吧(＾－＾)
