本文主要是介绍RxJava入门篇 --(一) 响应式编程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
文章目录
- 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.创建被观察者 ObservableObservable<String> observable = Observable.create(new OnSubscribe<String>() {@Overridepublic void call(Subscriber<? super String> subscriber) {subscriber.onNext("Hello World!"); // 发送数据subscriber.onCompleted();// 最终调用该方法,表示结束}});// 2.创建观察者Observerrx.Observer<String> observer = new rx.Observer<String>() {@Overridepublic void onCompleted() {System.out.println("onCompleted");}@Overridepublic void onError(Throwable arg0) {System.out.println("onError");}@Overridepublic void onNext(String arg0) {System.out.println("onNext = " + arg0);}};// 3.被观察者订阅观察者observable// 建议在这修改数据.map(new Func1<String, String>() {// 第一个参数决定 call方法类型,第二个参数决定返回值类型@Overridepublic String call(String arg0) {return arg0 + "汤圆";}}).subscribe(observer);}}
这篇关于RxJava入门篇 --(一) 响应式编程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!