文章目录
- 1. 什么是 `Rx`
- 2.`Rx` 模式 --- 观察者模式
- 3.`Rx` 优点 --- 简洁
- 4.什么是 `RxJava`？
- 5.学习 `RxJava`
- 6. `RxJava` 的 `HelloWord`
刚开始学习，不是很明白很多话的道理，学习一门新技术，要经历what，how，why三个步骤。
- what 这个
RxJava 能做什么？提供什么样的 API - how 采用什么样的方式实现，主要有哪些模块。
- 每个模块有什么方法，怎么实现的
- 结构，或者说架构怎么搭建的
- 为什么
Rx 会火，它这样封装后意图？（简洁？逻辑简单？）
带着这些疑问开始 RxJava 学习之路吧
1. 什么是 Rx
-
ReactiveX 是Reactive Extensions 的缩写。 -
Rx 是一个编程模型，目标是提供一致的编程接口，帮助开发者更方便的处理异步任务流。
目前 Rx 支持大部分流行的编程语言，eg：Java、C#、PHP…
- Rx 是一个函数库，让开发者可以利用可观察序列和 LINQ 风格查询操作符来编写异步和基于事件的程序。
- 可以这样定义：Rx = Observables + LINQ + Schedulers
-
ReactiveX 不仅仅是编程接口，更是一种编程思想的突破。Rx 还影响了其它程序、框架以及编程语言。
RxJava 在 GitHub 主页上的自我介绍是:
- A library for composing asynchronous and event-based programs using observable sequences for the Java VM
- 一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库。
其实， RxJava 的本质可以压缩为 异步 这一个词。说到根上，它就是一个实现异步操作的库，而别的定语都是基于这之上的。
这就是 RxJava ，概括得非常精准。
2.Rx 模式 — 观察者模式
- 创建：
Rx 可以方便的创建事件流和数据流 - 组合：
Rx 可以使用查询式的操作符 组合和变换数据流 - 监听：
Rx 可以订阅任何可以观察的数据流并执行操作
3.Rx 优点 — 简洁
- 函数式风格：
Rx 可以方便的创建事件流和数据流 - 简化代码：
Rx 的操作符可以将复杂的逻辑简化为很少的几行代码 - 异步错误处理机制：传统的
try/catch 没办法处理异步计算，Rx 提供了合适的错误处理机制； - 轻松使用并发：
Rx 的Observable 和Schedulers 让开发者可以避免底层线程同步和各种并发问题。
换句话说，『同样是做异步，为什么人们用它，而不用现成的 AsyncTask / Handler / XXX / … ？』
一个词：简洁。
异步操作很关键的一点是程序的简洁性，因为在调度过程比较复杂的情况下，异步代码经常会既难写也难被读懂。 Android 创造的 AsyncTask 和 Handler ，其实都是为了让异步代码更加简洁。RxJava 的优势也是简洁，但它的简洁的与众不同之处在于，随着程序逻辑变得越来越复杂，它依然能够保持简洁。
4.什么是 RxJava？
RxJava 是 ReactiveX 在 JVM 上的一个实现，也就是说 RxJava 就是一种用 Java 语言实现的响应式编程，来创建基于事件的异步程序。
提升开发效率，降低维护成本一直是开发团队永恒不变的宗旨，近一年来国内越来越多的技术团队提到和使用RxJava。RxJava 能帮我们简化代码逻辑，提升代码可读性，这对于提升开发效率，降低维护成本很有帮助。
5.学习 RxJava
响应式编程的主要组成部分是 observable，operator 和 subscriber，一般响应式编程的信息流如下所示：
Observable -> Operator1 -> Operator2 -> Operator3 -> Subscriber
Observable 产生数据，中间通过几个 Operator, 也就是几个操作符（操作符是用来转换数据的），最终数据发送给 Subscriber
也就是说， observable 是事件的产生者， subscriber 是事件的最终消费者
因为 subscrible 通常在主线程执行，因此要求设计上代码尽可能简单，只对事情做出响应（不对事件或者数据进行修改），而修改事件的工作全部交由 operator 执行
6. RxJava 的 HelloWord
官网：http://reactivex.io/
Github: https://github.com/ReactiveX/RxJava
PS：jar包下载地址
package com.lizi.rxjava;
import rx.Observable;
import rx.Observable.OnSubscribe;
import rx.Observer;
import rx.Subscriber;
import rx.functions.Func1;
public class RxJavaPattern {
public static void main(String[] args) {
testObservable();
}
@SuppressWarnings("deprecation")
private static void testObservable() {
// 1.创建被观察者 Observable
Observable<String> observable = Observable.create(new OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello World！"); // 发送数据
subscriber.onCompleted();// 最终调用该方法，表示结束
}
});
// 2.创建观察者Observer
rx.Observer<String> observer = new rx.Observer<String>() {
@Override
public void onCompleted() {
System.out.println("onCompleted");
}
@Override
public void onError(Throwable arg0) {
System.out.println("onError");
}
@Override
public void onNext(String arg0) {
System.out.println("onNext = " + arg0);
}
};
// 3.被观察者订阅观察者
observable
// 建议在这修改数据
.map(new Func1<String, String>() {
// 第一个参数决定 call方法类型，第二个参数决定返回值类型
@Override
public String call(String arg0) {
return arg0 + "汤圆";
}
}).subscribe(observer);
}
}
