Flow for Kotlin：完整指南及示例

Flow 简介：它是什么以及为什么需要它？

\n\n

Flow 是一个用于在 Kotlin 编程语言中处理响应式数据流（reactive streams）的库。它是 Kotlin 协程生态系统的一部分，提供了一种强大、类型安全且异步的方式来处理随时间生成的数据序列。

\n\n

与一次性将所有元素存储在内存中的普通集合（List、Set）不同，Flow 是一个冷流（cold stream）。这意味着数据仅在出现订阅者（collector）时才开始生成。Flow 非常适合用于：

\n

\n
• 异步数据处理：在不阻塞主线程的情况下从网络、数据库或文件系统获取数据。
\n
• 事件处理：点击、鼠标移动、UI 更新。
\n
• 响应式编程：创建数据转换链（map、filter、flatMap），并自动进行错误处理和取消。
\n
• 与协程集成：Flow 与 Kotlin 协程完全兼容，可以轻松地与其他异步操作结合使用。
\n

\n\n

为什么使用 Flow 而不是旧方法（例如 RxJava 或回调）？

\n

\n
• 简单简洁：Flow API 简洁明了，对 Kotlin 开发者来说直观易懂。
\n
• 安全性：编译器级别的类型安全。
\n
• 与协程集成：利用了结构化并发的所有优势。
\n
• 性能：轻量且高效，不会创建多余的对象。
\n

\n\n

安装 Flow

\n\n

Flow 是 kotlinx.coroutines 库的一部分。要使用它，您需要将依赖项添加到您的 build.gradle.kts（对于 Gradle）或 pom.xml（对于 Maven）文件中。

\n\n

Gradle (Kotlin DSL)

\n

dependencies {\n    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.8.1")\n    // 用于在 Android 中使用 Flow（支持 Lifecycle）\n    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-android:1.8.1")\n}

\n\n

Gradle (Groovy)

\n

dependencies {\n    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.8.1'\n    implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.8.1'\n}

\n\n

Maven

\n

\n    org.jetbrains.kotlinx\n    kotlinx-coroutines-core\n    1.8.1\n

\n\n

重要提示：请确保 Kotlin 版本与 kotlinx-coroutines 版本兼容。最新版本可以在 GitHub 上找到。

\n\n

快速入门：第一个 Flow

\n\n

让我们创建一个简单的 Flow，它延迟发射三个数字，然后订阅它。

\n\n

import kotlinx.coroutines.*\nimport kotlinx.coroutines.flow.*\n\nfun simpleFlow(): Flow<Int> = flow {\n    println("Flow 已启动")\n    for (i in 1..3) {\n        delay(100) // 模拟异步工作\n        emit(i)    // 发射值\n    }\n}\n\nfun main() = runBlocking {\n    println("主线程：${Thread.currentThread().name}")\n\n    // 订阅 Flow（收集数据）\n    simpleFlow().collect { value ->\n        println("已接收：$value")\n    }\n\n    println("Flow 已完成")\n}

\n\n

输出：

\n

主线程：main\nFlow 已启动\n已接收：1\n已接收：2\n已接收：3\nFlow 已完成

\n\n

解释