【系统通信：RxJava】RxJava开篇

作者：郭孝星

微博：郭孝星的新浪微博

邮箱：guoxiaoxingv@163.com

博客：http://blog.csdn.net/allenwells

Github：https://github.com/guoxiaoxing

【系统通信：RxJava】章节列表

【系统通信：RxJava】RxJava开篇

Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.

一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库。

＃一 RxJava的特点

RxJava有以下特点：

零依赖

< 800KB Jar

Java 6+ & Android 2.3+

Java 8 lambda support

多语言支持(Scala, Groovy, Clojure and Kotlin)

Non-opinionated about source of concurrency (threads, pools, event loops, fibers, actors, etc)

同步或异步执行

Virtual time and schedulers for parameterized concurrency

RxJava作为一个实现异步的库，它最大的特色就是简洁，与Android传统的AsyncTask、Handler相比，即使后期异步调用逻辑越来越复杂，代码越来越多，它依然能保持简洁的特性，这对于异步操作而言，无疑是巨大的优良特性。

举个例子，我们在一段业务逻辑中，有多次内存操作、本地读取操作和网络操作，线程之间相互等待，相互配合，如果用传统的监听回调来实现，一定能把我们写的头头大了，很容易造成CallBack Hell是个令人头痛的问题。RxJava的优良之处在于它能把任何复杂的逻辑串成一条线，代码逻辑一目了然。

＃二 RxJava的实现

RxJava是基于一种扩展的观察者模式实现的。

观察者模式：A 对象（观察者）对 B 对象（被观察者）的某种变化高度敏感，需要在 B 变化的一瞬间做出反应。观察者采用注册(Register)或者称为订阅(Subscribe)的方式，告诉被观察者：我需要你的某某状态，你要在它变化的时候通知我。