RxJava其实没你想象的那么难
嘿，还记得你第一次听说RxJava这个东西是什么时候吗？
好吧，我承认，我当时即刻被RxJava那些实用却比较难上手的操作符给震惊了。
今天，重新认识一下RxJava，赶紧写篇章记录下RxJava的种种。
如今，RxJava被越来越多的安卓开发者熟知并在自己的项目当中运用。虽然在团队开发中，你不一定能够用上RxJava ,但是这并不能阻挡我们一颗热爱技术的心，不是吗？
虽然我不是老司机，但是不想成为老司机的程序猿不是好司机啊，来不及解释了，快上车！
基础
RxJava最核心的类就是Observables（被观察者，事件源）和Subscribers（订阅者），Subcribers负责处理这些事件，可以是任何你感兴趣的逻辑（触摸事件相应，接口回掉返回的Json数据等等）
于此同时，你还需要知道的是，一个Observable可以同时发出一个或者多个事件，直到事件结束或者出错。每发出一个事件，就会调用它的Subsriber的onNext()方法，最后调用Subsriber.onNext()或者Subsriber.onError()结束。
RxJava的基本实现思想看起来很像套路了观察者设计模式，但是有一点明显不同，那就是如果一个Obervable没有任何的Subscriber，那么这和Observable自己是不会发出任何事件的。
如何通过代码快速熟悉RxJava? 没错，万年不变的套路，写一个HelloWorld.
Hello World
创建一个Observable对象其实很简单，直接调用Observable.create()即可，
```
Observable myObservable = Observable.create(
new Observable.OnSubscribe() {
@Override
public void call(Subscriber sub) {
sub.onNext("Hello, world!");
sub.onCompleted();
}
}
}；
```
这里定义的Observable对象仅仅发出了一个Hello World字符串，然后就结束了，接着我们创建一个Subscriber来处理Observable对象发出的字符串。
`
Subscriber mySubscriber = new Subscriber() {
@Override
public void onNext(String s) { System.out.println(s); }
@Override
public void onCompleted() { }
@Override
public void onError(Throwable e) { }
};
`
这里subscriber仅仅就是打印observable发出的字符串。通过Subscriber函数就可以将我们定义的myObservable对象和mySubscriber对象关联起来，这样就完成了Subscriber对Observable的订阅。
`
myObservable.subscribe(mySubcriber);
`
一旦mySubscriber订阅了myObservable，myObservable就是会调用mySubscriber对象的onNext和onComplete方法，mySubscriber就会打印出Hello World
更简洁的代码
嘿，小伙伴们，看到这里，是不是觉得仅仅为了打印一个hello world 要写这么多代码太啰嗦？别着急，我这主要是为了展示RxJava背后的原理而采用这种比较啰嗦的写法，其实，RxJava提供了很对便利的函数来帮助我们减少代码。
首先来看看如何简化Obervable对象的创建过程，RxJava内置了很多简化Observable对象的函数，比如Observable就是用来创建只发出一个事件就结束的Observable对象，这样一来，创建Observable对象的代码可以简化为一行
`
Observable myObservable = Observable.just("Hello，World！");
`
接下来看看如何简化Subscriver，上面的例子中，其实，我们并不关心onComplete和OnError，我们只是需要在onNext被调用的时候做一些处理，这时候，就可以使用Action1类。
`
Action1 onNextAction = new Action1() {
@Override
public void call(String s) {
System.out.println(s);
}
};
`
subsriberf方法有一个重载版本，接受三个Action1的参数，分别对应OnNext，OnComplete，OnError函数。
`
myObservable.subscribe(onNextAction，onErrorAction，onCompleteAction);
`
这里，我们并不关心的是onError和onComplete，所以只需要第一个参数就可以。
`
myObservable.subscribe(onNextAction);
`
上面的代码，还可以这样哦
`
Observable.just("Hello，World!")
.subscribe(new Action1(){
@Override
public void call(String s){
System.out.print(s);
}
});
`
使用Java8的Lambda可以使代码更简洁
`
Observable.just("Hello,World!")
.subscribe(s -> System.out.println(s));
`
在Android开发中，强烈推荐使用retrolambda这个Gradle插件,这样你就可以在你的代码里面使用lambda了。
发张小图我们放松一下，然后我们再继续。
变换
让我们做一些有趣的事情吧！
比如我想在hello world 中加上我的签名，你可以会想要修改Observable对象。
`
Observable.just("Hello，world -kk")
.subscribe(s -> System.out.pringln(s));
`
如果你能改变Observable对象，这当然是可以的，但是如果你不能修改Observable对象呢？比如Observable对象是第三方库提供的？比如我的Observable对象被对个Subscribe订阅，但是我只想在某个订阅者做修改？
那么在Subscriber中对事件怎么修改呢？比如下面的代码:
`
Observable.just("Hello，world!")
.subscriber(s -> System.out.priintln(s + " -kk"));
`
这样的方式仍然不能让人满意，因为我希望我的Subscribers越轻量越好，因为我有可能会在mainThread中运行Subscriber。另外，根据响应式编程的概念，Subscribers更应该做的事情是”响应“，响应Observable发出的事件，而不是去修改，如果我能在某些中间步骤中对"Hello World!" 进行变换，这样是不是很酷？
操作符（Operators）
操作符就是为了解决对Observable对象的变换的问题，操作符用于在Observable和最终的Subscriber之间修改Observable发出的事件。RxJava提供了很多有用的操作符。
比如：map操作符。就是用来把一个事件转化为另外一个事件的。
`
Observable.just("Hello，world!")
.map(new Fun1(){
@Override
public String call(String s){
return s + "-kk";
}
});
.subscribe(s -> System.out.println(s));
`
使用Lambda可以简化成
`
Observable.just("Hello , world")
.map(s - > s + "kk")
.subscribe(s -> System.out.pringln(s));
`
是不是很酷？map()操作符就是变换Observable对象的，map操作符返回一个Observable对象，这样就可以实现链式调用，在一个Observable对象上对此使用map操作符，最终将最简洁的数据传递给Subscriber对象。
map操作符进阶
map操作符更有趣的一点是它不必返回Observable对象返回的类型，你可以使用map操作符返回一个发出新的数据类型的Observable对象。
比如上面的例子中，Subscriber并不关心返回的字符串，而是想要字符串的Hash值。
`
Observable.just("Hello world!")
.map(new Fun1(){
@Override
public Integer call(String s){
return s.hashCode();
}
})
.subscribe(i -> System.out.println(Integer.toString(i)));
`
很有趣吧？我们初始的Observable返回的是字符串，最终的Subscriber收到的却是Integer，当然使用Lambda可以进一步简化代码：
`
Obserbable.just("Hello world!")
.map(s -s.hashCode())
.subscribe(i -> System.out.println(Integer.toString(i)));
前面说过，Subscriber做的事情越少越好，我们在增加一个map操作符
Observable.just("Hello，world!")
.map(s -> s.hashCode())
.map(i -> Interger.toString(i))
.subscribe(s -> System.out.pringln(s));
`
总结
Observable和Subscriber可以做任何事件。Observable可以是一个数据库查询，Subscriber用来显示查询结果；Observable可以是屏幕上的点击事件，Subscriber用来响应点击事件；Observable可以使一个网络请求，Subscriber用来显示请求结果。
Observable和Subscriber是独立于变换过程的。在Observable和Subscriber中间可以增减任何数量的map。整个系统是高度可组合的，操作符是一个很简单的过程。
更多内容请关注我的个人微信公众号：前端开发技术栈
