LiveData迁移至Flow实战教程 - 第3节

StateFlow与SharedFlow对比

LiveData、StateFlow和SharedFlow都是Android组件间数据共享与状态管理的核心工具，但它们在冷/热流、初始值、粘性事件及背压处理方面存在本质差异。本章从原理层剖析三者的设计哲学，并通过参数配置、调试技巧与常见错误清单帮助你快速掌握迁移决策。

核心差异对比表

SharedFlow 配置参数详解

SharedFlow 的三个核心构造参数决定了数据分发行为：

// MutableSharedFlow 完整构造函数
val flow = MutableSharedFlow<Event>(
    replay = 0,                  // 新订阅者重放条数
    extraBufferCapacity = 0,     // 额外缓冲容量（不包含replay）
    onBufferOverflow = BufferOverflow.SUSPEND  // 缓冲溢出策略
)

• replay：控制新收集者是否收到历史事件。设为 0 可替代 LiveData 的 EventWrapper 避免粘性。
• extraBufferCapacity：在 replay 之外额外缓存事件数。常用于高频事件缓冲。
• onBufferOverflow：缓存满时行为：
  • SUSPEND（默认）：发射者挂起直到有空间。
  • DROP_OLDEST：丢弃最旧事件，保留最新。
  • DROP_LATEST：丢弃最新事件，保留旧事件。

StateFlow 与 LiveData 迁移代码示例

将 ViewModel 中的 LiveData 替换为 StateFlow：

// 迁移前：LiveData
private val _state = MutableLiveData<MyState>(MyState.INIT)
val state: LiveData<MyState> = _state

fun update() {
    _state.value = newState
}

// 迁移后：StateFlow
private val _state = MutableStateFlow(MyState.INIT)
val state: StateFlow<MyState> = _state.asStateFlow()

fun update() {
    _state.value = newState
}

调试与常见错误

常见错误 1：未提供初始值导致编译错误

StateFlow 构造时必须传入泛型类型的初始值，否则编译器报错。若状态可为 null，可使用 MutableStateFlow<MyState?>(null)。

常见错误 2：SharedFlow 复用导致粘性事件泄漏

若 SharedFlow 设置了 replay=1，新观察者会收到最后一次发射的事件。避免方法：replay = 0。

调试技巧：使用 catch 与 onCompletion 监测流生命周期

viewModel.state
    .onStart { Log.d("Flow", "Start collecting") }
    .catch { e -> Log.e("Flow", "Error: $e") }
    .onCompletion { Log.d("Flow", "Completed") }
    .flowWithLifecycle(lifecycle, Lifecycle.State.STARTED)
    .collect { state -> /* 处理状态 */ }

性能与稳定性优化建议

1. 减少无谓的重启收集：使用 distinctUntilChanged 过滤重复值，避免 UI 重复渲染。
2. 合理设置 buffer：事件密集型场景（如传感器）中，为 SharedFlow 配置 extraBufferCapacity = 10 + DROP_OLDEST，防止发射者挂起。
3. 避免在 globalScope 中发射：始终使用 viewModelScope 或自定义 CoroutineScope 管理。
4. 生命周期安全收集：在 Fragment/Activity 中使用 lifecycleScope.launch { repeatOnLifecycle(Lifecycle.State.STARTED) { flow.collect{...} } }。