早就听到RxJava比较好用，最近才开始学也实属无奈，具体啥原因您懂的，从本文开始逐步学习RxJava，并将其改善到项目中。其实在此之前看了好多篇关于RxJava的文章，这里并不打算，介绍它的理念（其实我也不是很明白，所以不打算误导人），不过这不是重点，重点在于如何最快的使用，其实我看中它的最大亮点就是简化代码并带来代码的可读性，尤其是那些迷一般的缩进，当然本人也是用了很久的缩进。

PS：这里本文章之适合像我这样还没使用Rx的新手所以可能会罗嗦点，大神如果看了还请不要喷，随便给点建议也比喷好。

在安卓中使用RxJava需要引入几个包，查看了一下github上的配置，发现旧了好像并没有更新，网上的感觉都有点旧了，几经波折最终在其maven仓库中看到了最新的版本。当前最新为2.0.1版本

1. 引入依赖

在您的module下gradle文件中加上下面的配置

compile 'io.reactivex.rxjava2:rxjava:2.0.1'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

如此就可以愉快的使用它了。

2. 简单的说一下

在RxJava中有两种对象，一种叫做Observable(被观察者对象),另一种叫做Observer(观察者对象)，其实这就是观察者模式的增强版，被观察者其实就是你要操作数据源的管理人员，而观察者就是最终消费数据的人。由被观察者主动给观察者发送消息数据。举个生活中的例子，就是你去报社订阅周刊，这个报社就是数据源，周刊就是你要看的数据，每当有新周刊时，报社就会主动的给你发送新的周刊而不用你亲自去报社询问。当然前提是你得先交钱，而在计算机的世界中就比较单纯了。只要你订阅了 就会给你发，当然有时候也会闹一些小脾气。

3. 使用

基于上面所说的，在使用RxJava的时候，首先你得先准备好数据源然后交给被观察者。
我们以简单的字符串作为数据源开始使用，当然这里的数据可以是任意对象：
String data="I am a string to be prepared"；
我们现在把这个数据交给一个叫做Observable的人。

Observable.just(data)
        .subscribe(new Consumer<String>() {
            @Override
            public void accept(String s) throws Exception {
                Log.i(s);
            }
        });

输出结果是：I am a string to be prepared
这里，我们看到了RxJava的第一个操作符just,关于其他的操作符，在下一篇文章中介绍出来，它是Observable中的一个静态方法，它会帮你把数据交给一个被观察者并把它创建出来。有了这个被观察者我们就可以操作了，紧接着我们让被观察者去订阅了一个消费者，哦不！应该是创建一个消费者并交给被观察者。并在消费者的接收方法中操作数据。这里最终原样输出。如果你习惯使用lamdba表达式还可以更加简单点，因为Consumer是一个只有一个方法的接口
（android studio中已经可以使用lamdba了不过仅仅只是使用这样也可以让代码更加的简单了）。
最终：

String data="I am a string to be prepared";
Observable.just(data)
        .subscribe(str->Log.i(str));

到此，一条简单的不能在简单的流程就这么走完了。

下篇文章 将介绍RxJava中常用的操作符，其实Rx的使用就是在众多操作符中来回的变换直至最终成为我们想要的结果。