RxJava中Observer与Observable关系解析

RxJava 是一个用于实现异步处理的响应式编程框架，功能类似于 Android 中的 AsyncTask 与 Handler。本文将简要讲解 RxJava 中观察者（Observer）与被观察者（Observable）之间的基本关系。通过理解这两者如何协作，你可以更高效地管理数据流和事件响应。在学习本内容前，请确保你已掌握如何在 Android Studio 中运行独立的 Java 文件，若尚不熟悉，建议先参考相关基础操作教程，以便顺利进行后续实践。

1、 先将目录模式切换为Project视图。

2、 进入app目录，找到并打开其中的build.gradle配置文件进行编辑。

3、 在build.gradle文件中加入红框内的代码，随后点击同步项目与Gradle文件即可完成配置。

4、 创建test.java文件，并输入所示的代码内容。

5、 RxJava基于扩展观察者模式，包含四个核心角色：被观察者、观察者、订阅关系和事件流处理。

6、 被观察者负责生成和发布事件，供订阅者接收处理。

7、 观察者接收事件通知并据此执行相应操作。

8、 订阅是建立被观察者与观察者之间联系的桥梁，实现事件的传递与响应。

9、 事件，即系统中发生的特定情况。

10、 例如，住院患者病情由高科技设备实时监测并传送给医生，再依据具体情况给予相应护理。

11、 住院病人作为被观察对象，医生为观察者，高科技设备实现订阅，病情变化即为触发事件。

12、 病情稳定时，医生常规护理；病情危急时，则需立即抢救。

13、 运行效果见下图。

14、 若加入红色框内内容，后续语句将被跳过不再执行。

15、 运行效果见下图。