内容导读

1. 本文使用 RxJava 的异步返回代替传统的接口回调，并结合 Java 8 函数引用的新特性，从而使整个 MVP 框架数据流更加清晰，并将层与层之间的关系由耦合变成组合。

2. 同时使用了 RxLifeCycle 使用网络请求与 Activity / Fragment 的生命周期保持同步，避免了内存泄漏问题。

3. 如需结合多状态布局或 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
    }
}