第8章 函数响应式编程

在《第8章 函数响应式编程》中，本页依据刘望舒《Android进阶之光》独立重构，不复制原文。版本锁定电子工业出版社2017年7月首版、492页、ISBN 9787121315305；正式结构为11章、190个章/节/小节节点。

在《第8章 函数响应式编程》中，原书处在Android 5.0至7.0、Java与Support Library时代，包含AsyncTask、Volley、otto、RxJava早期版本、ButterKnife、Dagger 2和Data Binding。课程先复现历史机制，再以AndroidX、协程/Flow、现代架构组件作迁移对照。

从可观察行为开始

Observable、Subject、操作符、Scheduler、订阅释放构成本页的分析词汇。先预测一次输入会穿过哪些对象、线程、队列、View或语言边界，再运行正常与失败样本；没有版本和原始证据的“源码原理”不能复查。

本单元主线是从Observable订阅进入Subject、八类操作符、线程控制、OkHttp与Retrofit组合、RxBus及订阅变换线程切换源码。交互管线逐项选择目录节点，反例实验切换正常、配置变化、线程竞争、所有者销毁和版本漂移，证据门要求目录、行为、线程、生命周期与迁移全部通过。

最小实现与边界

api.user(id)
    .subscribeOn(Schedulers.io())
    .map { dto -> dto.toDomain() }
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(
        { user -> view.show(user) },
        { error -> view.showError(error) }
    )

在《第8章 函数响应式编程》中，实现后用固定输入记录输出、线程名、生命周期、异常和资源释放。再构造错误输入、取消、旋转、后台切前台及低版本设备，验证便利框架没有隐藏所有权问题。

data class AndroidProbe(
    val apiLevel: Int,
    val ownerActive: Boolean,
    val callbackThread: String,
    val resultStable: Boolean
)
check(probe.ownerActive && probe.resultStable)

证据解释

第一份证据是行为基线。固定Android版本、依赖版本、构建类型、输入数据和页面生命周期，完整记录“从Observable订阅进入Subject、八类操作符、线程控制、OkHttp与Retrofit组合、RxBus及订阅变换线程切换源码”从入口到结果的顺序。除了成功输出，还要保存回调线程、对象身份、队列或订阅状态以及释放日志；否则无法判断升级后的差异来自业务代码、框架实现还是测试环境。

第二份证据是反例。针对“把长操作符链当作天然异步和安全，忽略错误终止、订阅释放、线程切换位置和上游速度”构造至少一个可重复失败：在配置变化、快速重复输入、网络超时、后台切换或所有者销毁时观察错位、重复、泄漏和迟到回调。反例必须写明预期拒绝条件；只展示正常路径会掩盖框架最重要的所有权边界。

第三份证据是源码定位。先锁定仓库标签和库版本，再从公开入口沿实际调用追踪，不跨版本拼接类名。每次跨线程、跨进程或跨Java/Native边界，都记录调用方、被调用方、数据形态、错误返回和资源归属。事件时序图、订阅释放、错误终止、背压假设、调度线程、操作符输入输出与网络取消日志应能让另一位读者在相同版本上重建同一条链。

在《第8章 函数响应式编程》中，第四份证据是迁移对照。现代API解决的问题可能相同，但取消、缓存、状态恢复、线程和错误语义未必一致。迁移时保持输入和验收不变，一次只替换一个组件；新旧结果不一致时先解释差异，再决定适配或回退，不能用“新版推荐”跳过历史行为验证。

迁移账本

原书节点: 第8章 函数响应式编程
历史基线: Android 5.0—7.0 / Java / Support Library
现代候选: 一次只替换一个API或框架
不变量: 业务结果、线程、生命周期、错误与资源释放
证据: 事件时序图、订阅释放、错误终止、背压假设、调度线程、操作符输入输出与网络取消日志
回退: 任一不变量失败即恢复历史实现

本章回顾

从一个真实输入复盘：它由谁接收、在哪个线程执行、状态和对象归谁所有、何时取消或释放、低版本与异常路径如何表现。然后用事件时序图、订阅释放、错误终止、背压假设、调度线程、操作符输入输出与网络取消日志重放；无法复现的结论退回实验阶段。

复习与独立交接

← 上一页：第7章 事件总线 · 下一页：第9章 注解与依赖注入框架 →

原版目录概念补充核对

以下条目补齐官方目录中容易被示例主线掩盖的概念。它们不重复罗列目录，而是明确每项概念的机制、适用边界和验收证据。

8.1 RxJava基本用法：机制、边界与证据

第8章 函数响应式编程中的8.1 RxJava基本用法由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.1.1 RxJava概述：机制、边界与证据

第8章 函数响应式编程中的8.1.1 RxJava概述由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.1.2 RxJava基本实现：机制、边界与证据

第8章 函数响应式编程中的8.1.2 RxJava基本实现由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.1.3 RxJava的不完整定义回调：机制、边界与证据

第8章 函数响应式编程中的8.1.3 RxJava的不完整定义回调由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.2 RxJava的Subject：机制、边界与证据

第8章 函数响应式编程中的8.2 RxJava的Subject由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.3 RxJava操作符入门：机制、边界与证据

第8章 函数响应式编程中的8.3 RxJava操作符入门由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.3.1 创建操作符：机制、边界与证据

第8章 函数响应式编程中的8.3.1 创建操作符由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.3.2 变换操作符：机制、边界与证据

第8章 函数响应式编程中的8.3.2 变换操作符由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.3.3 过滤操作符：机制、边界与证据

第8章 函数响应式编程中的8.3.3 过滤操作符由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.3.4 组合操作符：机制、边界与证据

第8章 函数响应式编程中的8.3.4 组合操作符由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.3.5 辅助操作符：机制、边界与证据

第8章 函数响应式编程中的8.3.5 辅助操作符由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.3.6 错误处理操作符：机制、边界与证据

第8章 函数响应式编程中的8.3.6 错误处理操作符由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.3.7 条件操作符和布尔操作符：机制、边界与证据

第8章 函数响应式编程中的8.3.7 条件操作符和布尔操作符由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.3.8 转换操作符：机制、边界与证据

第8章 函数响应式编程中的8.3.8 转换操作符由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.4 RxJava的线程控制：机制、边界与证据

第8章 函数响应式编程中的8.4 RxJava的线程控制涉及任务调度、共享状态、取消和生命周期所有权，回调成功一次不代表旋转或销毁后仍安全。记录线程、消息队列、owner 状态与资源释放，并注入取消、迟到回调或竞争复现失败路径。

8.5 RxJava的使用场景：机制、边界与证据

第8章 函数响应式编程中的8.5 RxJava的使用场景由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.5.1 RxJava结合OkHttp访问网络：机制、边界与证据

第8章 函数响应式编程中的8.5.1 RxJava结合OkHttp访问网络要明确请求身份、超时/取消、缓存键、重试幂等与响应解析边界。用可控服务端分别返回成功、慢响应、断网和错误数据，核对网络日志、缓存状态、线程切换和用户可见结果。

8.5.2 RxJava结合Retrofit访问网络：机制、边界与证据

第8章 函数响应式编程中的8.5.2 RxJava结合Retrofit访问网络要明确请求身份、超时/取消、缓存键、重试幂等与响应解析边界。用可控服务端分别返回成功、慢响应、断网和错误数据，核对网络日志、缓存状态、线程切换和用户可见结果。

8.5.3 用RxJava实现RxBus：机制、边界与证据

第8章 函数响应式编程中的8.5.3 用RxJava实现RxBus由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.6 RxJava源码解析：机制、边界与证据

第8章 函数响应式编程中的8.6 RxJava源码解析由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.6.1 RxJava的订阅过程：机制、边界与证据

第8章 函数响应式编程中的8.6.1 RxJava的订阅过程由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.6.2 RxJava的变换过程：机制、边界与证据

第8章 函数响应式编程中的8.6.2 RxJava的变换过程由订阅关系、线程调度、事件序列与终止信号共同定义。用 TestScheduler 或确定事件源复现 next/error/complete、取消和背压边界，保存订阅释放与观察线程，避免只看最终输出。

8.6.3 RxJava的线程切换过程：机制、边界与证据

第8章 函数响应式编程中的8.6.3 RxJava的线程切换过程涉及任务调度、共享状态、取消和生命周期所有权，回调成功一次不代表旋转或销毁后仍安全。记录线程、消息队列、owner 状态与资源释放，并注入取消、迟到回调或竞争复现失败路径。

8.7 本章小结：机制、边界与证据

第8章 函数响应式编程中的8.7 本章小结应固定 Android 5.0–7.0、Java 与旧 Support Library 语境，写出输入、状态、线程、生命周期和失败结果。以最小实现和单变量反例保存日志、状态快照与迁移差异。