一、什么是观察者模式
就是观察者告诉被观察者我需要你的某种状态，当被观察者做出动作的时候，观察者立刻做出相应反应。所以步骤就是，创建被观察者，逻辑是它要执行的动作。创建观察者，当被观察者做出动作的时候，观察者该怎么做。之后观察者要盯着观察者，这就是连接。
二、RXJAVA中的观察者和被观察者
Observable(被观察者) Observer/Subscribe(观察者)
三、创建 被观察者 和 观察者 并建立连接
//创建被观察者，运用OnSubscribe创造自己的逻辑在其中 Observable observable = Observable.create(new Observable.OnSubscribe<String>(){ @Override public void call(Subscriber<? super String> subscriber) { subscriber.onNext("123"); subscriber.onNext("321"); } }); //观察者，当被观察者做出动作了，观察者要做的事情逻辑 Observer<String> observer = new Observer<String>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onNext(String s) { //当返回数据的时候 } }; //观察者和被观察者建立连接 observable.subscribe(observer);
原文：http://www.cnblogs.com/rookiechen/p/5538356.html
