内容导读
本文使用 RxJava 的异步返回代替传统的接口回调，并结合 Java 8 函数引用的新特性，从而使整个 MVP 框架数据流更加清晰，并将层与层之间的关系由耦合变成组合。
同时使用了 RxLifeCycle 使用网络请求与 Activity / Fragment 的生命周期保持同步，避免了内存泄漏问题。
如需结合多状态布局或 Loading 对话框使用，可以使用 RxJava 的 doOnSubscribe、doOnNext、doOnError、doFinally 等操作符集成。
dependencies
本文需要导入以下依赖包：
dependencies {
implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'
implementation 'com.squareup.retrofit2:converter-gson:2.6.0'
implementation 'com.squareup.retrofit2:adapter-rxjava2:2.6.0'
implementation 'com.github.nekocode.rxlifecycle:rxlifecycle:2.0'
}
ApiService
接口服务(Service)，泛型返回值使用Gson包内的JsonObject，以最大程度地兼顾数据的易用性和灵活性。
public interface ApiService {
@GET("https://gitee.com/Haoxueren/codes/yx6t1n7j8is9vkr43cgq068/raw?blob_name=api_mvp")
Observable<JsonObject> requestServer();
}
MainModel
数据层(Model)，用于获取数据和存储数据，并不对数据进行处理(注意，请求网络时需要切换到子线程内操作，操作完成再切回主线程)。
public class MainModel {
public static Observable<JsonObject> requestServer() {
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("https://gitee.com/Haoxueren/")
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.build();
ApiService apiService = retrofit.create(ApiService.class);
return apiService.requestServer()
.subscribeOn(Schedulers.io()) // 切换到子线程执行网络请求
.observeOn(AndroidSchedulers.mainThread()); // 切换到主线程
}
}
MainPresenter
逻辑层(Presenter)，用于做一些非UI的业务逻辑处理工作，同时做为Model层与View层连接的桥梁。
public class MainPresenter {
public Observable<ResponseBean> requestServer() {
return MainModel.requestServer()
.map(this::jsonToBean); // Json映射为Bean
}
public ResponseBean jsonToBean(JsonObject jsonObject) {
Gson gson = new Gson();
return gson.fromJson(jsonObject, ResponseBean.class);
}
}
ResponseBean
public class ResponseBean {
public String code;
public String message;
public Result result;
public static class Result {
public String name;
public String age;
}
}
MainActivity
视图层(View)，负责收集数据和显示数据，并不对数据进行校验或处理。
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
MainPresenter presenter = new MainPresenter();
presenter.requestServer()
.compose(RxLifecycle.bind(this) // 与当前Activity生命周期绑定
.disposeObservableWhen(LifecycleEvent.DESTROY))
.doOnSubscribe(this::onLoading) // 请求开始，显示Loading
.filter(this::filterError) // 过滤并处理错误
.doFinally(this::endLoading) // 请求结束，关闭Loading
.subscribe(this::onSuccess, this::onFailure);
}
private boolean filterError(ResponseBean bean) {
if (bean.code.equals("200")) {
return true;
}
Toast.makeText(context, bean.message, Toast.LENGTH_SHORT).show();
return false;
}
private void onLoading(Disposable disposable) {
// show loading dialog
}
private void endLoading() {
// dismiss loading dialog
}
public void onSuccess(ResponseBean bean) {
// request success
}
public void onFailure(Throwable e) {
// request fialed
}
}
