1.什么是RxAndroid
RxAndroid的含义为响应式编程，Rx含义是响应式编程，其本质就是观察者模式，以观察者（Observer）和订阅者（Subscriber）为基础的异步响应方式。
　　 Observables发出一系列事件，Subscribers处理这些事件。这里的事件可以是任何你感兴趣的东西（触摸事件，异步接口调用返回的数据等）
2.RxAndroid的优势
1、异步错误处理，传统的try/catch没法处理异步计算，Rx提供了合适的错误处理机制
2、轻松使用并发，Rx的Observables和Schedulers让开发者可以摆脱底层的线程同步和各种并发问题

RxAndroid和RxJava
　　对RxJava最经典的解释就是警察抓小偷，警察需要在小偷伸手作案的时候实施抓捕。在这个例子里，警察是观察者，小偷是被观察者，警察需要时刻盯着小偷的一举一动，才能保证不会漏过任何瞬间。
　　观察者模式面向的需求是：A 对象（观察者）对 B 对象（被观察者）的某种变化高度敏感，需要在 B 变化的一瞬间做出反应。
程序的观察者模式和这种真正的『观察』略有不同，观察者不需要时刻盯着被观察者（例如 A 不需要每过 2ms 就检查一次 B 的状
态），而是采用注册(Register)或者称为订阅(Subscribe)的方式，告诉被观察者：我需要你的某某状态，你要在它变化的时候通知
我。 Android 开发中一个比较典型的例子是点击监听器OnClickListener 。对设置 OnClickListener 来说， View 是被观察者，
OnClickListener 是观察者，二者通过setOnClickListener() 方法达成订阅关系。订阅之后用户点击按钮的瞬间，Android
Framework 就会将点击事件发送给已经注册的OnClickListener 。采取这样被动的观察方式，既省去了反复检索状态的资源消耗，
也能够得到最高的反馈速度。当然，这也得益于我们可以随意定制自己程序中的观察者和被观察者，而警察叔叔明显无法要求小偷
『你在作案的时候务必通知我』。

RxJava四个基本概念：Observable（被观察者）、Observer（观察者）、subscribe(订阅）、事件。
Observable和Observer通过subscribe（）方法实现订阅关系，从而Observable可以在需要的时候发出事件来通知Observer。

RxAndroid使用和配置：
　　如果只需要使用RxAndroid，只要第一步配置就OK了。

第一步：配置gradle引用，rxjava和rxandroid是必须的。

**第二步：配置支持Java，JDK1.8

第三步：插件

第四步：在工程的gradle中添加（project的gradle）

下面使用Java代码实现观察者模式：
创建被观察者接口：

/**

• 被观察者接口
  */
  public interface Watched {

  /**

  • 添加观察者
  • @param watcher
    */
    void addWatcher(Watcher watcher);

  /**

  • 删除观察者
  • @param watcher
    */
    void removeWatcher(Watcher watcher);

  /**

  • 提醒所有的观察者
  • @param str
    */
    void notifyWatchers(String str);

}

被观察者实现类：
/**

• 被观察者实现类
  */
  public class ConcreateWatched implements Watched {

  //保存添加的观察者对象
  private List list = new ArrayList<>();

  @Override
  public void addWatcher(Watcher watcher) {
  list.add(watcher);
  }

  @Override
  public void removeWatcher(Watcher watcher) {
  list.remove(watcher);
  }

  @Override
  public void notifyWatchers(String str) {
  //此处就是，当被观察者发生变化时，通知观察者进行响应
  for (Watcher watcher : list) {
  watcher.update(str);
  }
  }
  }

创建观察者接口：
/**

• 观察者接口
  */
  public interface Watcher {

  /**

  • 接收被观察者变化的通知
  • @param str
    */
    void update(String str);
    }
    观察者实现类：

/**

• 观察者实现类
  */
  public class ConcreateWatcher implements Watcher {
  @Override
  public void update(String str) {
  System.out.println(str);
  }
  }
  测试类

/**

• 测试
  */
  public class Test {
  public static void main(String[] args) {
  Watched xiaoming = new ConcreateWatched();

   Watcher watcher = new ConcreateWatcher();Watcher watcher1 = new ConcreateWatcher();Watcher watcher2 = new ConcreateWatcher();xiaoming.addWatcher(watcher);xiaoming.addWatcher(watcher1);xiaoming.addWatcher(watcher2);xiaoming.notifyWatchers("我要投偷东西了");
  

  }
  }