Products
96SEO 2026-04-22 13:20 5
Ru果你Yi经在 Android 项目里玩转了 协程，但仍对 Flow 的概念和落地细节感到模糊，那本文就是为你准备的。我们会把抽象的理论拆成一块块可操作的代码片段，再配上真实业务场景，让你在阅读后立刻Neng够在项目中落地。
简单来说Flow 就是一个Ke以发射多个值的“管道”。它具备以下几个特性：
冷流只有当有人收集（.collect {}) 时才会真正执行内部逻辑。
懒惰未被订阅前不会产生任何副作用。
响应式每一次发射douKe以被下游实时感知。
这套设计让我们Ke以把网络请求、数据库查询甚至蓝牙回调全部统一成“流”，再配合协程的调度器，轻松实现线程切换和错误捕获。
二、Zui常见的三种创建方式 1. 使用 flow{} 构建器手动 emit
fun simpleNumbers: Flow = flow {
for {
delay // 模拟耗时
emit // 把 i 推送给下游
}
}
这里的 emit 就像往水管里倒水，一点一点流向收集端。
hen多第三方 SDK只Neng通过回调告知结果，这时Ke以用 callbackFlow 把回调转换为流：
fun listenBluetooth: Flow = callbackFlow {
val cb = object : BluetoothCallback {
override fun onData { trySend }
override fun onError { close }
}
bluetooth.start
awaitClose { bluetooth.stop } // 协程取消时自动清理资源
}
Jetpack 中的 Room Yi经原生支持返回 Flow；Retrofit 只要配合 Kotlinx.coroutines 插件即可：
// Room DAO
@Dao interface UserDao {
@Query
fun getAll: Flow
}
// Retrofit Service
interface ApiService {
@GET
suspend fun getPosts: List
}
fun getPostsFlow: Flow = flow { emit) }
.flowOn Neng把上游代码迁移到指定调度器，而下游仍然保持原有线程。下面是一个典型例子：
fun fetchAndParse: Flow = flow {
val json = networkClient.getString // IO
emit) // CPU 密集
}.flowOn // 上游跑 IO
.map { it.apply { title = title.uppercase } } // 默认在 Main
.flowOn // map 在 Default 上执行
这样即使 UI 层只需要调用一次 .collect{}, 也Neng确保不出现卡顿。
协程里的异常会沿着父子层级向上传播。Ru果不捕获，整个进程可Neng崩溃。我们推荐两层防护：
局部 try/catch： 针对单个请求Zuo细粒度处理。
CoroExceptionHandler + SupervisorJob： 为整个作用域提供兜底，子协程互不影响。
val globalHandler = CoroutineExceptionHandler { _, ex ->
Log.e
}
val appScope = CoroutineScope + Dispatchers.Main + globalHandler)
// 局部捕获示例
appScope.launch {
try {
val data = repository.loadRemote
uiState.value = UiState.Success
} catch {
uiState.value = UiState.Error
}
}
Kotlin 为 Activity/Fragment 提供了两个便利属性：
LifecyleOwner.lifecycleScope
LifecyleOwner.repeatOnLifecycle
配合前文提到的 Flow，Ke以Zuo到“只在页面可见时收集”，彻底杜绝内存泄漏：
class HomeFragment : Fragment {
private val vm: HomeViewModel by viewModels
override fun onViewCreated {
viewLifecycleOwner.lifecycleScope.launch {
viewLifecycleOwner.repeatOnLifecycle {
vm.articleFlow.collect { render }
}
}
}
}
| 场景需求 | 推荐操作符 |
|---|---|
| 搜索框输入防抖 | .debounce |
| 滚动列表频繁刷新 | .throttleLatest |
| 只取Zui新值 | .flatMapLatest{} |
| 过滤空数据 | .filter{ it.isNotEmpty } |
| 去重重复请求 | .distinctUntilChanged |
| 采样间隔输出 | .sample |
下面给出一个综合示例，演示搜索框输入后防抖+去重+Zui新请求合并：
