1. 简介
RxJava 是 ReactiveX 在 Java 语言中的一个实现，它提供了响应式编程的能力，允许开发者以声明式、异步的方式处理数据流和事件。RxJava 是基于观察者模式的，它扩展了观察者模式，使其能够处理异步数据流，并且支持数据流的组合和变换。
以下是 RxJava 的一些核心特点：
-
异步处理： RxJava 允许开发者编写异步代码，这意味着数据的生成和消费可以并行进行，而不是顺序执行。这样可以提高应用程序的性能和响应性。
-
基于数据流： 在 RxJava 中，数据是通过 Observable 序列来表示的，这些序列可以发射多个数据项、一个错误或者完成信号。
-
操作符： RxJava 提供了丰富的操作符，用于创建、转换、过滤和组合数据流。这些操作符使得处理复杂的数据流变得简单。
-
背压（Backpressure）： RxJava 支持背压机制，允许消费者控制数据流的速度，防止被过快的数据流淹没。
-
线程调度： RxJava 允许开发者指定数据流在特定线程上执行，这使得开发者可以轻松地在不同线程之间切换，例如在 IO 线程上执行网络请求，在主线程上更新 UI。
-
错误处理： RxJava 提供了强大的错误处理机制，使得开发者可以优雅地处理数据流中的错误。
-
可组合性： RxJava 的数据流可以被组合和重用，这意味着开发者可以构建复杂的数据处理管道，而不必每次都从头开始。
-
扩展性： RxJava 社区活跃，提供了许多扩展库，支持与各种其他库和框架的集成，例如 Retrofit、OkHttp 等。
-
类型丰富： RxJava 提供了多种类型的可观察对象，如 Observable、Flowable、Single、Maybe 和 Completable，以适应不同的用例。
-
响应式编程模型： RxJava 遵循 ReactiveX 规范，该规范定义了一套标准，使得不同的响应式编程库之间可以互操作。
RxJava 适用于需要处理大量并发数据、事件驱动的程序、UI 开发、网络请求、文件 I/O 等多种场景。
2. 关键字
-
Observable： 可观察序列，它是 RxJava 中的核心概念之一。一个 Observable 可以发射多个数据项，或者一个错误，或者什么都不发射（完成）。它允许观察者订阅它并响应数据发射。
-
Observer： 观察者，用于订阅 Observable。当 Observable 发射数据时，Observer 会接收这些数据并通过其方法（如
onNext,onError,onComplete）作出响应。 -
Subscriber： 在 RxJava 中，Subscriber 是 Observer 的一个扩展，用于处理背压（Backpressure）。它允许更细粒度的控制数据流的速度。
-
Flowable： RxJava 中的一个类，用于处理背压。它与 Observable 类似，但是支持背压策略，允许消费者控制数据流的速度。
-
Single： RxJava 中的一个类，用于表示只会发射单个数据项或者一个错误的序列。
-
Maybe： RxJava 中的一个类，用于表示可能会发射单个数据项或者什么都不发射（完成）的序列。
-
Completable： RxJava 中的一个类，用于表示不会发射任何数据项，只会完成或者发射错误的序列。
-
Schedulers： RxJava 提供的用于控制 Observable 序列执行线程的调度器。例如，
Schedulers.io()用于 IO 操作，Schedulers.computation()用于计算密集型任务。 -
Operators： RxJava 提供了一系列操作符，用于创建、转换、过滤和组合 Observable 序列。例如，
map、filter、flatMap等。 -
Disposable： 一个接口，用于取消订阅 Observable。当一个 Observable 被订阅时，会返回一个 Disposable 对象，通过调用它的
dispose方法可以取消订阅。 -
CompositeDisposable： 用于管理多个 Disposable 对象，通常用于管理多个订阅，以便在需要时一次性取消它们。
-
Subject： RxJava 中的一个类，它既是 Observable 又是 Observer。它可以作为一个桥梁，将其他 Observable 连接到它，并且它可以订阅其他 Observable。
-
ReplaySubject： 一种特殊的 Subject，它缓存 Observable 发射的所有数据，并在新的 Observer 订阅时重放这些数据。
-
BehaviorSubject： 一种特殊的 Subject，它有一个初始值，当新的 Observer 订阅时，它会立即收到这个初始值，然后收到所有后续的数据。
-
PublishSubject： 一种特殊的 Subject，它只在 Observer 订阅之后发射数据。
3. 操作符
-
create： 创建一个新的 Observable，通过提供一个
ObservableOnSubscribe接口的实现来控制数据的发射。 -
just： 创建一个 Observable，它只会发射一个或多个指定的数据项，然后完成。
-
fromIterable： 将一个可迭代的集合转换为一个 Observable，集合中的每个元素都会被发射。
-
range： 创建一个发射指定范围内整数序列的 Observable。
-
interval： 创建一个按照固定时间间隔发射整数序列的 Observable。
-
map： 将 Observable 序列中的每个数据项应用一个函数，并将返回值作为新的序列发射。
-
flatMap： 将 Observable 序列中的每个数据项转换为一个新的 Observable 序列，然后将这些序列“展平”为一个序列。
-
concatMap： 类似于 flatMap，但是确保下一个 Observable 序列只有在当前序列完成后才开始发射。
-
filter： 根据一个谓词函数过滤 Observable 序列中的数据项，只有满足条件的数据项会被发射。
-
take： 只发射 Observable 序列中的前 N 个数据项，然后完成。
-
skip： 跳过 Observable 序列中的前 N 个数据项，然后发射剩余的项。
-
takeUntil： 发射 Observable 序列中的数据项，直到另一个 Observable 序列发射了一个数据项。
-
skipUntil： 跳过 Observable 序列中的数据项，直到另一个 Observable 序列发射了一个数据项，然后发射所有剩余的项。
-
distinctUntilChanged： 忽略 Observable 序列中连续重复的数据项。
-
debounce： 在指定的时间内，如果 Observable 序列连续发射数据项，则忽略这些数据项，只发射最后一个。
-
throttleFirst： 在指定的时间窗口内，只发射 Observable 序列中的第一个数据项。
-
throttleLast： 在指定的时间窗口内，只发射 Observable 序列中的最后一个数据项。
-
observeOn： 指定 Observer 接收数据项的线程。
-
subscribeOn： 指定 Observable 发射数据项的线程。
-
doOnNext： 在 Observable 序列的每个数据项被发射时执行一个动作。
-
doOnError： 在 Observable 序列发射错误时执行一个动作。
-
doOnComplete： 在 Observable 序列完成时执行一个动作。
-
zip： 将多个 Observable 序列“压缩”为一个，这个新的 Observable 序列会发射一个包含所有原始序列最新数据项的组合。
-
merge： 将多个 Observable 序列合并为一个，合并后的序列会发射所有原始序列的数据项。
-
concat： 将多个 Observable 序列连接为一个，连接后的序列会按顺序发射所有原始序列的数据项。
-
switchIfEmpty： 如果原始 Observable 序列为空，则切换到另一个 Observable 序列。
-
defaultIfEmpty： 如果原始 Observable 序列为空，则发射一个默认值。
-
retry： 如果 Observable 序列发射了一个错误，根据指定的次数重新订阅。
-
repeat： 重复发射 Observable 序列。
-
using： 创建一个 Observable，它在订阅时获取一个资源，并在完成或错误时释放资源。
4. Demo
添加依赖
<!-- https://mvnrepository.com/artifact/io.reactivex.rxjava3/rxjava -->
<dependency><groupId>io.reactivex.rxjava3</groupId><artifactId>rxjava</artifactId><version>3.1.0</version>
</dependency>测试
package org.example;import io.reactivex.rxjava3.core.Observable;/*** Author:yang* Date:2024-10-22 9:58*/
public class Main {public static void main(String[] args) {// Create an Observable that emits "Hello, world!"Observable.just("Hello, world!").subscribe(System.out::println);}
}// 输出
Hello，World！
