Rxjava四要素
- 被观察者
**在Rxjava当中，
决定什么时候触发事件，
决定触发什么样的事件；**
观察者
- 决定事件触发的时候将产生什么样的行为；
- 类似于
传统观察者模式，
观察者会随着被观察者的状态变化而发生相应的操作；
订阅
- 区别于传统
观察者模式； 观察者和被观察者需要通过订阅来联系；- 通过
subscribe()方法完成这个订阅关系； - 完成订阅关系后，
- 区别于传统
即可令被观察者（Observable）在需要的时候，
发出事件来通知观察者（Observer）
事件
- 区别于传统
观察者模式；
- 区别于传统
（下面详说）
事件
- 乃
响应式编程中的核心概念； 响应式编程乃基于异步数据流概念的编程模式；
理解响应式编程
- 场景举例：
客户端从服务端获取到最新的数据时，需要通知
客户端本身相关模块进行更新（如UI变换显示等）；
这其实便是一种响应式编程——客户端根据服务端的变化做出相应；生活中的例子
- 天气冷了我们就要多穿件衣服。
天气冷了，就是一种事件；要多穿件衣服，就是基于事件做出的响应；
- 饿了要吃饭。
饿了，就是一种事件；吃饭，就是基于事件做出的响应；
代码分析
- **第一步，
（通过create()）创建被观察者(Observable)，即第一个基本要素，
其中注意OnSubscribe<String>()对象，
记住它是存储在Observable当中的；
当Observable订阅之后，
它会启动OnSubscribe<String>()对象中的回调方法call()，
同时运行call()方法体中写好的反应序列；**
//第一步：创建被观察者：create
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello");
subscriber.onNext("Imooc");
subscriber.onCompleted();
}
});.
- 其中，其实
Subscriber就是我们的观察者；
- 其中，其实
后面的Rxjava源码阅读中，
我们会发现Observer在源码中也会被转换成Subscriber来进行相应的处理，
所有才说其实Subscriber就是我们的观察者；
- 以上我们可以看到，在```create```一个```被观察者```时，我们new了一个OnSubscribe<String>()，
并在其中实现了回调方法call()，回调方法中调用了观察者的方法——
在创建被观察者时，使用了调用了观察者方法的回调方法，
这其实就是一种事件的传递；
最后将这个OnSubscribe<String>()赋给被观察者的创建方法create()；
如此便跟传统观察者模式联系起来了；
（只不过这里Rxjava给我们做好了更好的封装）
- 以上是
创建被观察者的一种方法，
事实上还有其他两种 ：
- 第二种，通过```just()```方法创建，只要把参数放到just()方法中，以逗号分隔开来即可，
而just()其实就是将参数 依次通过事件 发送出来，
这种写法其实是跟上面的两个onNext()、一个onCompleted()的写法是一样的；
- 第三种，通过```from()```方法，类似于第二种方法，只是把传给just的参数组合成一个String数组在传给from()；
这种写法其实是跟上面的两个onNext()、一个onCompleted()的写法是一样的；
- 以上三种方法其实都是等价的，其最终目的都是
创建被观察者；
//通过just方法来创建被观察者
Observable observableJust = Observable.just("hello", "Imooc");
//通过from方法来创建被观察者
String[] parameters = {"hello", "Imooc"};
Observable observableFrom = Observable.from(parameters);- 第二步，
**创建观察者Observer/Subscriber，即第二个要素，
1.在传统的观察者模式当中，观察者只有一个update()方法，
在其中根据被观察者的状态变化而做出反应/改变；**
2. **而在Rxjava中，框架给出了三个方法；****其中onCompleted()和onError()两个方法就是对传统观察者模式做出的改变/区别，
而onNext()其实就是传统观察者模式当中的update()；**
- ```onCompleted()```：当```不再有新的事件```通过```被观察者``` ```发出```的时候```回调```；
- ```onError()```： 在处理异常框架时```回调```；
- ```onNext()```：同理```传统观察者模式```当中的```update()```，即编写 当被观察者发生状态改变时，观察者的处理逻辑；
//第二步：创建观察者
Observer<Object> observer = new Observer<Object>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Object s) {
}
};
被观察者Observable是用过链式调用来执行的；为的是让后面的
操作符、线程控制等能够跟流式OPI来完善，
而不是其他方式如观察者去订阅被观察者（非链式）——
这样从意思上容易理解，但在API调用上很不方便；
- 链式调用：理解比较绕，但能跟
流式OPI来完善，API调用上非常方便；- 非链式调用：意思上容易理解，但在API调用上很不方便；
- 第三步，订阅：
**前面我们说概念的时候，都是观察者订阅被观察者的，
可是这里代码中，
“奇怪”的是“被观察者(Observable)去订阅（subscribe）观察者（Observer）”，
这里就是上面说的，
为了后面能够通过流式OPI，
使进行操作符、线程控制等操作时能够通过链式调用来完善；**
所以这里Rxjava中把订阅设计成“被观察者(Observable)去订阅（subscribe）观察者（Observer）”
public void doRxjava(){
//第三步：订阅
observable.subscribe(observer);
}- 本节完整代码如下：
**这里其实只是Rxjava的一种简单的使用，
主要是理解一下Rxjava对传统观察者设计模式的拓展和改进；
实际情况当中，其实它还包括了很多操作符，
以及Rxjava最核心的线程控制调度，
这两部分是Rxjava的核心.**
package com.example.jiajiemu.a11.rxjava;
import rx.Observable;
import rx.Observer;
import rx.Subscriber;
/**
* Created by Mjj on 2017/10/6.
*/
public class RxjavaCreateDemo {
//第一步：创建被观察者：create
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello");
subscriber.onNext("Imooc");
subscriber.onCompleted();
}
});
//通过just方法来创建被观察者
Observable observableJust = Observable.just("hello", "Imooc");
//通过from方法来创建被观察者
String[] parameters = {"hello", "Imooc"};
Observable observableFrom = Observable.from(parameters);
//第二步：创建观察者
Observer<Object> observer = new Observer<Object>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Object s) {
}
};
public void doRxjava(){
//第三步：订阅
observable.subscribe(observer);
}
}参考自 慕课网
