kotlin 02flow-sharedFlow 完整教程

一 sharedFlow是什么

SharedFlow 是 Kotlin 协程中 Flow 的一种 热流（Hot Flow），用于在多个订阅者之间 共享事件或数据流。它适合处理 一次性事件（如导航、弹窗、Toast、刷新通知等），而不是持续状态。

✅ SharedFlow 是什么？

SharedFlow 是 Flow 的一种扩展，具备以下特点：

它本质上是一个“事件广播器”。

✅ 常见使用场景

📍 1. 一次性 UI 事件

• Toast 弹窗
• SnackBar 提示
• 导航跳转
• 关闭页面
• 对话框展示/取消

这些事件都是“一次性的”，不需要保存状态，也不该重复触发，因此适合 SharedFlow。

sealed class UiEvent {
    data class ShowToast(val message: String) : UiEvent()
    object NavigateToHome : UiEvent()
}

// ViewModel 中
private val _uiEvent = MutableSharedFlow<UiEvent>()
val uiEvent = _uiEvent.asSharedFlow()

fun loginSuccess() {
    viewModelScope.launch {
        _uiEvent.emit(UiEvent.NavigateToHome)
    }
}

// Fragment 中
lifecycleScope.launchWhenStarted {
    viewModel.uiEvent.collect { event ->
        when (event) {
            is UiEvent.ShowToast -> showToast(event.message)
            is UiEvent.NavigateToHome -> navigate()
        }
    }
}

📍 2. 流式通知

• 通知其他模块刷新数据
• 数据拉取完成通知页面更新
• ViewModel 向 UI 发信号

📍 3. 替代 LiveData<Event> 解决重复消费问题

传统用 LiveData<Event<T>> 或 SingleLiveEvent 处理一次性事件，代码复杂、不优雅，而 SharedFlow 是官方推荐的替代方案。

✅ 在公司项目中，SharedFlow 的典型用法

示例：登录成功后跳转 + 弹出 Toast

// ViewModel
val eventFlow = MutableSharedFlow<UiEvent>()

suspend fun login(username: String, pwd: String) {
    if (doLogin(username, pwd)) {
        eventFlow.emit(UiEvent.ShowToast("登录成功"))
        eventFlow.emit(UiEvent.NavigateHome)
    }
}

✅ 与其他 Flow 类型的对比

✅ 总结一句话：

SharedFlow = Kotlin 中处理一次性事件的推荐工具，适合在 ViewModel → UI 层传递 Toast、导航、弹窗等短暂行为，比 LiveData 更现代、可控。

二 sharedFlow如何处理背压的？

✅ 1. SharedFlow 是如何处理被压的（Backpressure）？

SharedFlow 是 热流（hot stream），意味着数据会立即发出，而不会像 Flow 那样等待订阅者 collect。这也就意味着：

• 如果发射得太快（比如连续多次 emit）
• 而订阅者还没来得及 collect
• 数据就可能被丢弃，或缓存起来等待

这就需要一个“缓存策略”来决定怎么处理这些“来不及处理”的数据 —— 这就是 SharedFlow 的 buffer 和 溢出策略（onBufferOverflow）。

✅ 2. replay = 2, extraBufferCapacity = 5 的含义

val sharedFlow = MutableSharedFlow<Int>(
    replay = 2,
    extraBufferCapacity = 5
)

这两者分别控制了两块缓存区域：

💡 总缓冲区大小 = replay + extraBufferCapacity

即上面的配置，总共可以缓冲 最多 7 条数据。

这意味着在没有 collect 的情况下，可以最多 emit 7 条数据不会失败或丢失。

✅ 3. onBufferOverflow = DROP_OLDEST / DROP_LATEST / SUSPEND 是什么？

这是控制当 缓冲区已满时，继续 emit 会怎么处理的策略。

支持的策略：

示例说明：

val flow = MutableSharedFlow<Int>(
    replay = 1,
    extraBufferCapacity = 2,
    onBufferOverflow = BufferOverflow.DROP_OLDEST
)

此时总 buffer 是 3 条：

• 如果连续 emit 第 1、2、3 条 → 都能进 buffer。
• 如果 emit 第 4 条时还没人 collect → buffer 满了。
• DROP_OLDEST 策略：会把 第 1 条值移除，保留 2、3、4。

🔄 emit() 和 tryEmit() 的区别：

• emit() 是 挂起函数，可能会 suspend（如果 buffer 满且策略是 SUSPEND）。
• tryEmit() 是 非挂起，返回 true/false 表示是否成功发射。

✅ 总结一句话：