RxJava是使用Java实现的响应式编程库，RxJava即 Reactive Extensions Java。目前有两个版本RxJava1和RxJava2,推荐使用RxJava2,RxJava1已经停止支持了
ReactiveX即Reactive Extensions，它通过可观测的序列，实现了组合异步和事件驱动.它是一种编程方式。ReactiveX主要的实现方式是扩展 观察者模式 来达到自己的目的。ReactiveX更多介绍戳官网
RxJava学习路径与概念初始
1、 了解什么是Observer什么是Observable? 英文 或者 掘金翻译
> Observer是观察者，Observable表明是可以被观察的。行人过红绿灯，行人是Observer,红绿灯的变化是可以Observable的
> 实际项目中希望数据一发生变化就通知需要知道这个变化的对象，这可以通过观察者模式实现，数据变化观察者立马就可以对变化做出"响应"
3、 初识函数式编程 英文 或者 掘金翻译
4、 从java8中的stream到RxJava的转变 英文 或者 掘金翻译
5、 RxJava的一些API介绍 英文
> 创建Observable的基本方式，可以先了解最简单的just操作，[just的源码分析戳这里][just]
6、 了解什么是Hot Observable，什么是 Cold Observable，以及如何将Cold转换成Hot 英文
> * cold:每次订阅和其它任何订阅它的取到的数据都是一样的
> * hot:只能获取从订阅那一刻开始的数据，后续订阅的不能获取之前已经产生的数据
7、 Observer的方法介绍 英文
> onNext : 每次想通知 Observer 数据变化的时候，Observer的onNext方法就会被调用
8、 即是Observable又是Observer的对象 英文
> 相当于自己产生数据自己再消费
>
> * PublishSubject获取订阅时候的数据
> * BehaviourSubject可以获取订阅之前的1个数据
> * ReplaySubject能获取订阅前已经产生的所有数据
> * AsyncSubject只获取最后一个数据
RxJava1中部分实例的实现
User user = new User();
user.setAge(1);
Observable.just(user).subscribe(new Action1<User>() {
@Override
public void call(User user) {
LOG.info("justVerify just user age:{}", user.getAge());
}
});
产生Observable的数据
RxJava操作符
既是Observable又是Observer案例
异步与阻塞案例
RxJava2中的部分案例
Observable.just(1).subscribe(new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
LOG.info("accept:{}", integer);
}
});
产生Observable的数据 可以与 产生Observable的数据 对比下区别，大致就可以转换出过来了。
背压:如果生产太快，消费不过来该怎么办？可以反过来限制生产的速度，比如把所有生产的数据都缓存起来，消费者自己来取，比如只有有请求的时候才给数据，没有请求的数据全部扔掉