简介
RxJava 是一个基于 Java 的响应式编程库，用于处理异步事件流和数据流。它是由 Netflix 开发并开源，现在广泛用于 Android 和 Java 后端开发。RxJava 提供了一种用于组合和处理异步数据的丰富工具集，它的核心思想是将数据流视为一系列事件，以响应事件的方式进行处理。RxJava 提供了丰富的操作符，用于处理和转换数据流。这些操作符可以帮助你执行各种操作，包括过滤、映射、合并、变换等，以便更好地处理异步数据流。
RxJava 原理
Observable 和 Observer：RxJava 的核心是 Observable（可观察对象）和 Observer（观察者）。Observable 表示一个可观察的数据源，它可以发射数据项，而 Observer 用于订阅并监听这些数据项的变化。
操作符：RxJava 提供了各种操作符，用于对数据流进行转换、过滤、组合和其他处理。操作符可以将一个 Observable 转换成另一个 Observable，从而实现数据的转换和处理。
流式编程：RxJava 支持链式调用，可以将多个操作符和观察者方法连接在一起，以创建复杂的数据流处理逻辑。
异步和线程控制：RxJava 允许你轻松处理异步操作，使用 subscribeOn 和 observeOn 等操作符，可以指定在哪个线程上执行 Observable 和 Observer 的代码。
背压处理：RxJava 2 引入了背压处理机制，允许 Observable 控制发射的速度，以避免内存溢出和资源泄漏问题。
RxJava 在 Android 中的功能作用：
简化异步操作：RxJava 简化了异步操作，例如网络请求、数据库访问、文件读写等。你可以使用 Observable 发射异步事件，然后使用 Observer 来处理这些事件。
响应式UI：RxJava 可以在 Android UI 线程和后台线程之间建立响应式的通信，以便在 UI 上更新数据或执行操作。
处理多个观察者：RxJava 允许你轻松地将多个观察者订阅到一个 Observable，这对于多个界面元素依赖于相同数据源的情况很有用。
处理错误和异常：RxJava 提供了各种操作符，用于处理错误和异常，例如 onErrorReturn、onErrorResumeNext 等，以确保应用程序能够更健壮地处理异常情况。
组合和转换数据流：RxJava 提供了丰富的操作符，用于组合和转换数据流。例如，你可以使用 zip 将多个数据流合并，或使用 map 转换数据项的类型。
事件总线：RxJava 可以用作事件总线，允许不同组件之间进行松散耦合的通信，例如通过 RxBus 发送和接收事件。
自动管理资源：RxJava 可以帮助你管理资源，例如自动释放订阅，避免内存泄漏。
测试支持：RxJava 提供了测试支持，可以轻松地测试异步操作，确保应用程序的可靠性。
Rxjava 基本组成
1. 响应式编程： RxJava 的核心思想是响应式编程，它允许你以一种响应事件的方式来处理数据流。你可以订阅一个数据流，然后定义事件处理的方式。当数据项到达时，它们会触发事件，观察者（Observer）会监听这些事件并执行相应的操作。
2. 基本组件： RxJava 的基本组件包括以下几个部分
Observable（可观察对象）： 表示一个能够发射数据项的数据源。Observable 可以发射零个或多个数据项，以及错误或完成事件。
Observer（观察者）： 订阅 Observable 并监听发射的事件。Observer 可以处理数据项、错误和完成事件。
Flowable (背压可观察对象) ：和Observable使用和功能类似，区别是Flowable支持背压，Flowable操作符默认的缓存空间大小128。
Subscriber（订阅者）： 类似于 Observer，用于订阅 Observable。
Operator（操作符）： 用于对 Observable 发射的数据流进行变换、过滤、合并等操作。
Schedulers（调度器）： 用于控制事件的执行线程，例如在主线程或后台线程执行。
3. 操作符： RxJava 提供了大量的操作符，用于操作和转换数据流。这些操作符包括 map、filter、flatMap、zip、merge 等，允许你根据需要执行各种操作。
4. 异步和并发： RxJava 简化了异步编程，允许你轻松地处理多线程和并发操作。你可以使用 subscribeOn 和 observeOn 操作符来指定代码的执行线程，以避免阻塞主线程。
5. 错误处理： RxJava 提供了多种方式来处理错误，包括 onError、onErrorReturn、onErrorResumeNext 等，以确保应用程序能够更健壮地处理异常情况。
6. 背压处理： RxJava 2 引入了背压处理机制，用于处理生产者和消费者之间的速率不匹配问题。背压机制允许 Observable 控制数据的发射速率，以避免内存溢出和资源泄漏。
7. 在 Android 中的应用： RxJava 在 Android 开发中广泛应用于处理异步操作，例如网络请求、数据库访问、UI事件响应等。它简化了异步编程，提高了代码的可读性和可维护性，同时提供了更好的性能和响应性。
8. 流式编程： RxJava 支持链式调用，可以将多个操作符和观察者方法连接在一起，以创建复杂的数据流处理逻辑。这使得代码更具表达力和可读性。
Rxjava使用
RxJava 的基本用法： \
创建一个 Observable，它会发射整数数据。\
创建一个观察者 Observer，用于订阅这个 Observable。
使用 subscribe 方法将观察者订阅到 Observable 上，观察者会监听 Observable 发射的数据项和事件。
//创建一个 `Observable`，它会发射整数数据。
val observable = Observable.create(ObservableOnSubscribe
for (i in 1..10) {
it.onNext(i)
}
it.onComplete()
})
var num: Int;
var dd : Disposable? = null
//创建一个观察者 `Observer`，用于订阅这个 `Observable`
val observer = object:Observer
override fun onSubscribe(d: Disposable) {//当调用订阅时调用此方法
dd = d
}
override fun onNext(t: Int) {//上游发送数据时调用此方法 即当 Observable 发射数据项时调用
num = t
if (num == 5){
dd!!.dispose()
}
Log.d(TAG,"接受上游数据：$t")
}
override fun onError(e: Throwable) {// 当出现错误时调用
}
override fun onComplete() {// 当 Observable 完成时调用
}
}
//使用subscribe方法将观察者订阅到 Observable上，观察者会监听Observable发射的数据项和事件。
observable.subscribe(observer)
也可以使用方法：直接使用函数式编程，把创建后的被观察者通过订阅方法（订阅操作符）把创建观察者作为订阅方法的参数；伪代码：
Observable.create(ObservableOnSubscribe
//上游发送数据
it.onNext(1)
it.onNext(3)
it.onNext(5)
it.onComplete()
})
.subscribe(object :Observer
override fun onSubscribe(d: Disposable) {
}
override fun onNext(t: Int) {
//下游接受数据
Log.i(TAG,"接受到上游数据：$t")
}
override fun onError(e: Throwable) {
}
override fun onComplete(