kotlin中MutableStateFlow和MutableSharedFlow的区别是什么？

在 Kotlin 的协程库（kotlinx.coroutines.flow）中，MutableStateFlow 和 MutableSharedFlow 都是用于构建响应式数据流的可变（Mutable）热流（Hot Flow），但它们的设计目标和行为特性有显著区别。以下是它们的核心对比：

1. 核心区别总结

2. 详细行为对比

（1）数据存储与回放

• MutableStateFlow
  • 必须通过构造函数指定初始值：

  1val state = MutableStateFlow(initialValue = 0) // 必须提供初始值  

  • 始终保存最新一个值，新订阅者会立即获取该值：

  1state.collect { println("Collector 1: $it") } // 立即打印当前值  
  2state.value = 1  
  3state.collect { println("Collector 2: $it") } // 立即打印1  

• MutableSharedFlow
  • 无需初始值，默认不保留任何值（除非配置replay）：

  1val shared = MutableSharedFlow<Int>() // 无初始值  

  • 通过replay参数控制新订阅者接收的历史值数量：

  1val shared = MutableSharedFlow<Int>(replay = 2) // 保留最近2个值  
  2shared.tryEmit(1)  
  3shared.tryEmit(2)  
  4shared.collect { println("Collector: $it") } // 打印1, 2（历史值）  

（2）发射（Emit）行为

• MutableStateFlow
  • 通过.value直接更新值（并发安全）：

  1state.value = newValue // 等同于state.tryEmit(newValue)  

  • 去重优化：如果新值与当前值相同（equals为true），不会触发下游收集。
• MutableSharedFlow
  • 必须显式调用emit或tryEmit：

  1shared.tryEmit(event) // 非挂起函数  
  2// 或  
  3launch { shared.emit(event) } // 挂起函数，可能被暂停  

  • 无去重：即使发送相同值，也会触发下游收集。

（3）背压（Backpressure）处理

• MutableStateFlow
  • 自动处理背压：新值直接覆盖旧值，下游永远收到最新值。
• MutableSharedFlow
  • 可配置缓冲区大小和溢出策略：

  1MutableSharedFlow<Int>(  
  2    extraBufferCapacity = 10, // 缓冲区大小  
  3    onBufferOverflow = BufferOverflow.DROP_OLDEST // 溢出时丢弃旧值  
  4)  

3. 典型使用场景

MutableStateFlow

• 状态管理：维护单一可变状态，如UI状态、全局配置。

1// ViewModel中管理UI状态  
2private val _uiState = MutableStateFlow<UiState>(Loading)  
3val uiState: StateFlow<UiState> = _uiState.asStateFlow()  
4fun loadData() {  
5    _uiState.value = Loading  
6    _uiState.value = Success(data)  
7}  

MutableSharedFlow

• 事件通知：处理一次性事件（如按钮点击、错误消息）。

1// 单次事件通知（无replay）  
2private val _events = MutableSharedFlow<Event>()  
3val events = _events.asSharedFlow()  
4fun onButtonClick() {  
5    viewModelScope.launch { _events.emit(ClickEvent) }  
6}  
7// 收集端需要处理重复消费问题  
8events.collect { event ->  
9    // 每次emit都会触发  
10}  

4. 关键选择建议

• 需要维护当前状态？ → 选 StateFlow
• 需要广播事件且不关心历史值？ → 选 SharedFlow（replay = 0）
• 需要事件重放（如页面恢复时重新处理事件）？ → 选 SharedFlow（replay > 0）
• 需要高性能无阻塞发射？ → 选 SharedFlow（tryEmit非挂起）

5. 补充注意事项

• StateFlow 是 SharedFlow 的特例
  以下代码实现等价：

1val stateFlow = MutableStateFlow(initialValue)  
2// 等价于  
3val sharedFlow = MutableSharedFlow(  
4    replay = 1,  
5    onBufferOverflow = BufferOverflow.DROP_OLDEST  
6).also { it.tryEmit(initialValue) }  

• 线程安全性
  两者均可在多线程环境中安全使用（内部已实现同步机制）。
• 生命周期感知
  在Android中，通常配合Lifecycle.repeatOnLifecycle避免泄漏：

1lifecycleScope.launch {  
2    repeatOnLifecycle(Lifecycle.State.STARTED) {  
3        stateFlow.collect { updateUI(it) }  
4    }  
5}  

《kotlin中MutableStateFlow和MutableSharedFlow的区别是什么？》 是转载文章，点击查看原文。