RxJava 出来很久了，以至于现在大红大紫。在 Android 平台中的影响更是不可言语，很多新开源项目中也纷纷引入了她。但我一直因为各种原因没有动手揭开她神秘的面纱。目前 Rx (ReactiveX) 对 Android 支持已经非常强大， 从数据库到业务逻辑异步处理，再到与 MVP 设计模式的结合都已经有相对成熟解决方案。现在正是入手的好时机。现在网络上有关于 RxJava 的文章很多，在此就不累赘她的好处和使用方法，感兴趣可以自行学习。

说明： 本人对 RxJava 的理解不是很深刻，目前只处于会用的阶段。部分观点可能会有误导
本文要解决的问题： 对 RxJava 技术体系在 Android 实际项目中具体使用的理解

RxJava 理解

下面这段代码对比与常规实现，很能说明 RxJava 的使用。(以下代码来源于：给 Android 开发者的 RxJava 详解 写的很不错，值得仔细阅读)

使用 Thread 实现：

new Thread() {
    @Override
    public void run() {
        super.run();
        for (File folder : folders) {
            File[] files = folder.listFiles();
            for (File file : files) {
                if (file.getName().endsWith(".png")) {
                    final Bitmap bitmap = getBitmapFromFile(file);
                    getActivity().runOnUiThread(new Runnable() {
                        @Override
                        public void run() {
                            imageCollectorView.addImage(bitmap);
                        }
                    });
                }
            }
        }
    }
}.start();

通过 RxJava 的使用：

Observable.from(folders)
    .flatMap(new Func1<File, Observable<File>>() {
        @Override
        public Observable<File> call(File file) {
            return Observable.from(file.listFiles());
        }
    })
    .filter(new Func1<File, Boolean>() {
        @Override
        public Boolean call(File file) {
            return file.getName().endsWith(".png");
        }
    })
    .map(new Func1<File, Bitmap>() {
        @Override
        public Bitmap call(File file) {
            return getBitmapFromFile(file);
        }
    })
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Action1<Bitmap>() {
        @Override
        public void call(Bitmap bitmap) {
            imageCollectorView.addImage(bitmap);
        }
    });

这里可以看出，使用 RxJava 能够很好的让代码逻辑变的简单。RxJava 的操作方式乍一看很像 Builder 模式，在创建类的时候先给类添加各种初始化参数，然后调用 Build 创建对象。然而 RxJava 每一步都有相应的动作（action），既都会对上一个动作返回的数据做出必要的处理，然后将变化的数据传递下去。subscribe() 方法在末尾调用，最终数据会在这里被使用。可以认为 subscribe() 被调用后，就会启动上面一连串动作（这样理解对于初学者就够）。
上面例子中用到的那些方法只要理解了，基本上 RxJava 就可以正常使用。有问题再查看官方文档。

关于rxjava的一些记录

Func1 和 Action1 的区别在于， Func1 包装的是有返回值的方法。另外,和 ActionX 一样， FuncX 也有多个，用于不同参数个数的方法。FuncX 和 ActionX的区别在 FuncX 包装的是有返回值的方法。

线程控制

Observable.just(1,2,3,4) 
.subscribeOn(Schedulers.io()) 
.observeOn(Schedulers.newThread())
.map(doSomething) // 执行在 newThread 中
.observeOn(AndroidSchedulers.mainThread) 
.subscribe(subscriber); // 执行在 UI 线程中

observeOn()指定的是 Subscriber的线程，而这个 Subscriber并不是subscribe()参数中的 Subscriber，而是 observeOn()执行时的当前 Observable所对应的 Subscriber ，即它的直接下级 Subscriber 。换句话说，observeOn()指定的是它之后的操作所在的线程

Sqlbrite

简介：A lightweight wrapper around SQLiteOpenHelper which introduces reactive stream semantics to SQL operations。个人觉得这是为了让 SQLite 能和 RxJava 结合起来才有的库
github 地址： sqlbrite

例子：

Observable<Query> users = db.createQuery("users", "SELECT * FROM users");
users.subscribe(new Action1<Query>() {
  @Override public void call(Query query) {
    Cursor cursor = query.run();
    // TODO parse data...
  }
});

因为作者的初衷并不是为了简化对 SQLite 的操作，也没有打算完全透明对 SQL 的使用。所以个人感觉不是很好用，我更乐意使用 GreenDao 。

Retrofit

一款现在很流行的网络请求地方库。使用起来很简单。

public interface GitHubService {
  @GET("users/{user}/repos")
  Call<List<Repo>> listRepos(@Path("user") String user);
}

Retrofit retrofit = new Retrofit.Builder()
    .baseUrl("https://api.github.com/")
    .build();

GitHubService service = retrofit.create(GitHubService.class);

另外关注以下几个关键字：

• @GET
• @Path

@GET("group/{id}/users")
Call<List<User>> groupList(@Path("id") int groupId);

• @Query

@GET("group/{id}/users")
Call<List<User>> groupList(@Path("id") int groupId, @Query("sort") String sort);

• @QueryMap

@GET("group/{id}/users")
Call<List<User>> groupList(@Path("id") int groupId, @QueryMap Map<String, String> options);

• @Body

更多 API 用法可以查阅官方文档 DOC ，也可搭配学习RxJava 与 Retrofit 结合的最佳实践

EventBus 与 RxJava 的选择

EventBus 官方介绍为：Android optimized event bus that simplifies communication between Activities, Fragments, Threads, Services, etc. Less code, better quality. Detail

该库的设计初衷是在 Activities, Fragments, Threads, Services 等模块间轻松的建立链接。降低两个模块之间的耦合性，通过事件进行模块间通信。同时支持异步操作。

RxJava 被设计出来的初衷也是为了解决异步任务。并且通过流式编写，让一连串任务依次执行。虽然 RxJava 是通过观察者模式订阅事件。但如果抛开被观察者和观察者的概念，通过代码流式风格的编写来理解 RxJava 设计思想，似乎也是可以的。

问题又回到了原点，EventBus 和 RxJava 该如何选择呢？个人理解 RxJava 确实能从代码的角度清晰业务逻辑。事件的处理有事件序列来控制，能很清楚展示一个事件从开始处理到结束所经历的操作，并且可以根据需要控制事件在哪个 Thread 中被处理。当项目的业务很复杂的时候，我们会选择将业务逻辑进行隔离。业务内部使用 RxJava 处理，业务之间可以通过 EventBus 来进行消息传递。这样能使业务完全解耦。

RxJava 与 MVP

MVP 可以良好的将视图层和数据层通过 Presenter 进行隔离。Google 开发者也给出了 MVP 相关的设计方案 android-architecture 可以从基本的 MVP 开始学习，然后过度到与 RxJava 集合。
大体思路是：

• 编写 Contract 接口存放 IView 接口和 Presenter 接口

public interface Contract {

    interface View extends BaseView<Presenter> {

        // 更新UI的操作接口
    }

    interface Presenter extends BasePresenter {

        // 业务相关数据操作接口
    }
}

public interface BasePresenter {

    void subscribe();

    void unsubscribe();

}

public interface BaseView<T> {

    void setPresenter(T presenter);

}

• Fragment 实现 Contract.View 接口
• Custom Presenter 实现 Contract.BasePresenter 接口
• 在 Custom Presenter 使用 RxJava 编写业务逻辑