当前位置：首页 > news >正文

Kotlin中的flow、stateflow、shareflow之间的区别和各自的功能

news 2025/10/16 9:54:18

(Flow、StateFlow、SharedFlow) 是 Kotlin 协程 Flow 家族中最核心的三种类型，常用于 MVVM 架构中实现 异步数据流、状态管理、事件分发。

1. Flow - 基础数据流(冷流)

核心特性

冷流(Cold Stream)：每次收集时重新开始执行
单订阅：每个收集者都会获得独立的数据流
可取消：跟随协程作用域的生命周期
操作符丰富：支持 map, filter, transform 等
场景：网络请求、数据库查询、搜索接口、分页加载

使用实例：

fun getUserListFlow(): Flow<List<User>> = flow {val users = api.getUserList()  // 每次 collect 都会调用emit(users)
}lifecycleScope.launch {viewModel.getUserListFlow().collect { list ->showUserList(list)}
}

2. StateFlow - 状态容器

核心特性

热流(Hot Stream)：不管有没有收集者都会存在
必须有初始值：不能为空
状态保持：保留最新值，新订阅者立即获得当前值
值去重：只有值发生变化时才通知收集者
UI状态管理：专为管理UI状态设计
类似LiveData，但支持协程 + 背压

使用实例：

private val _uiState = MutableStateFlow("初始状态")
val uiState: StateFlow<String> = _uiStatefun updateState(newState: String) {_uiState.value = newState
}lifecycleScope.launchWhenStarted {viewModel.uiState.collect { state ->textView.text = state}
}

3. SharedFlow - 事件总线

特点

也是热流，但不强制持有当前值
可配置 replay 缓存数量
常用于一次性事件：Toast、导航、弹窗、通知等
热流(Hot Stream)：独立于收集者存在
无初始值：不需要初始值
广播事件：向所有收集者发送事件
配置灵活：可配置重放数量、缓存大小等

特性

特性	说明
`replay = 0`	不缓存，收集后才会接收到事件（默认）
`replay = 1`	缓存最近一个事件（新订阅者会收到）
`extraBufferCapacity`	控制缓冲区大小，防止背压丢失
`onBufferOverflow`	配置溢出策略（DROP_OLDEST / DROP_LATEST / SUSPEND）

使用实例：

private val _eventFlow = MutableSharedFlow<String>()
val eventFlow = _eventFlow.asSharedFlow()fun sendToast(msg: String) {viewModelScope.launch {_eventFlow.emit(msg)}
}lifecycleScope.launchWhenStarted {viewModel.eventFlow.collect { msg ->Toast.makeText(context, msg, Toast.LENGTH_SHORT).show()}
}

实际项目中的组合使用

class ProductViewModel : ViewModel() {// StateFlow - 管理UI状态private val _uiState = MutableStateFlow<ProductUiState>(ProductUiState.Loading)val uiState: StateFlow<ProductUiState> = _uiState.asStateFlow()// SharedFlow - 管理一次性事件private val _events = MutableSharedFlow<ProductEvent>()val events: SharedFlow<ProductEvent> = _events.asSharedFlow()// Flow - 数据转换流val recommendations: Flow<List<Product>> = flow {val products = productRepository.getProducts()val filtered = products.filter { it.isRecommended }emit(filtered)}fun loadProduct(productId: String) {viewModelScope.launch {// 使用 Flow 进行网络请求productRepository.getProductFlow(productId).catch { e ->// 通过 SharedFlow 发送错误事件_events.emit(ProductEvent.ShowError(e.message ?: "Unknown error"))}.collect { product ->// 更新 StateFlow 状态_uiState.value = ProductUiState.Success(product)}}}
}