Rxjava2入门教程一

深碍√TFBOYSˉ_ 2023-07-13 13:48 25阅读 0赞

RxJava是函数响应式编程思想在java语言上的具体实现。RxJava2在这一实现下，对Rxjava1进行了全面重写，如果之前没接触过RxJava，可以直接从Rxjava2入门，而不需要了解RxJava1。  
在使用RxJava2之前，对于Android开发，需要在项目中添加以下依赖

implementation "io.reactivex.rxjava2:rxjava:2.1.3"
        implementation 'io.reactivex.rxjava2:rxandroid:2.0.1'

**函数响应式编程**是**函数式编程**和**响应式编程**这两大颠覆传统的牛逼编程范式叠加后的产物，编程界的牛逼二次方。

--------------------

**响应式编程(Reactive Programming)：**是一种面向数据流和变化传播的一种编程范式。  
响应式编程的终极思想，一切皆流（everything is stream）。如同面向对象的编程一切皆对象一样。根据唯物辩证法的思想，物质世界是普遍联系和不断运动变化的统一整体，而一切‘运动变化’这一‘客观现象’都可以通过数据流的方式进行‘抽象描述’，也可以说，物质世界是数据流的客观存在。  
在程序中一切变量，数组，集合，对象，事件都可以当做数据流来发送处理。

--------------------

**函数式编程（Functional programming）：**是一种通过函数或者函数的组合调用来处理数据，获取结果的一种编程范式。  
函数是函数式编程的核心，**纯函数**和**高阶函数**是两大重要的角色。  
纯函数具有相互独立性和对外封闭性特点，  
1、纯函数的返回结果只受函数参数的影响，如果输入参数相同不论在哪调用，何时调用，调用多少次其输出结果都是一样的。  
2、纯函数内部的数据处理不受外部环境的影响也不会影响外部环境，每一个函数内部均有一套属于自己的局部变量，只在本函数内部调用也只在本函数内部起作用，其取值由函数的初始参数决定，不受外部变量的影响，同时函数的计算结果只影响函数的返回值，不影响外部变量的值。  
高阶函数（Higher-order function）：允许将函数作为参数传入，或者将函数作为返回值返回的函数称为高阶函数。通过高阶函数可以对纯函数进行传递，组合，链接等操作来解决单一函数无法解决的复杂问题。

--------------------

**函数响应式编程(Functional Reactive Programming:FRP)：**是一种通过一系列函数的组合调用来发射，转变，监听，响应数据流的编程范式。  
在RxJava中，函数响应式编程具体表现为一个观察者（Observer）订阅一个可观察对象（Observable），通过创建可观察对象发射数据流，经过一系列操作符（Operators）加工处理和线程调度器（Scheduler）在不同线程间的转发，最后由观察者接受并做出响应的一个过程。  
在RxJava2中，提供了五对观察者模式组合来完成这一系列的过程，每一对组合依靠其可调用的一系列函数的差异，而具有各自的特点。  
这五类组合（前为可观察对象后为对应的观察者）分别是：  
**ObservableSource/Observer**  
可通过onNext方法发送单条数据或者数据序列，通过onComplete发送完成通知或通过onError发送异常通知，不支持背压策略。  
**Publisher/Subscriber**  
在ObservableSource/Observer基础上进行了改进，可通过背压策略处理背压问题，但效率没有第一组高。  
以下三组是新的响应式关系的实现，在Rxjava1中没有，可看做是ObservableSource/Observer的简化版  
**SingleSource/SingleObserver**  
不能发送数据序列或完成通知，只能通过onSuccess方法发送单条数据，或者通过onError发送异常通知  
**CompletableSource/CompletableObserve**  
不能发送任何形式的数据（单条数据或数据序列），只能通过onComplete发送完成通知或者通过onError发送异常通知  
**MaybeSource/MaybeObserver**  
可通过onSuccess发送单条数据，通过onComplete发送完成通知或者通过onError发送一条异常通知