如果你正在涉足 Android 开发领域，那么你肯定遇到过如何处理表示层数据的这个老生常谈的问题。长期以来，LiveData 一直占据主导地位，但随着 Kotlin 协程的出现，更强大、更灵活的工具应运而生。我们说的就是StateFlow 和 SharedFlow，它们本质上是响应式、高效地管理数据流的自然演进。
事实上，虽然它们乍看之下似乎是相似的概念，但各自有着不同的用途。例如，让屏幕记住新闻推送的上次显示位置，与发送一个仅供查看一次的 Toast 通知是截然不同的。为了避免混淆，我们来详细了解一下这些热点流的工作原理，以及为什么在现代项目中应该考虑放弃 LiveData。
流动的概念：冷流还是热流？
要理解 StateFlow 和 SharedFlow，首先需要掌握冷流和热流的区别。标准流程是冷流，就像一份食谱：在有人决定执行它（调用 `collect`）之前，什么都不会发生。问题在于，如果你有三个订阅者，生产者的代码就会执行三次，这会消耗大量电量或导致冗余的 API 请求。
这就是热流发挥作用的地方。StateFlow 和 SharedFlow 都采用了策略性热流机制，这意味着无论是否有人在监听，生产者都会保持活跃状态。这使得多个收集器可以共享同一个数据源，避免应用程序重复执行相同的工作——这对保持系统流畅性至关重要。
StateFlow：LiveData 的理想替代方案
StateFlow 本质上是一个状态容器。它的主要特点是始终维护一个当前值，该值可以通过 `.value` 属性同步查询。它是管理用户界面状态的理想工具，例如屏幕是否正在加载或个人资料数据是否已成功更新。
与 LiveData 不同，StateFlow 的构造函数需要一个初始值，从而避免了启动时状态为空的不确定性。此外，它还实现了数据合并和去重功能：如果连续两次发出相同的值，流程会直接忽略它。这对于防止在数据实际上没有变化时不必要地刷新 UI 非常有效。
要在 ViewModel 中实现这一点，最佳方法是使用私有的MutableStateFlow 回退属性，并将其公开为不可变的 StateFlow。这样可以确保只有 ViewModel 才能修改状态，遵循单向数据流，并防止视图操作数据。
SharedFlow：用于唯一操作的事件总线
如果 StateFlow 用于“状态”，那么 SharedFlow 用于“事件”。假设你想显示一个错误对话框或导航到另一个屏幕。如果使用 StateFlow，旋转设备会导致新的收集器接收到上次的值，事件会再次触发——这是一个严重的 bug。SharedFlow 解决了这个问题，因为它可以将重放值配置为零。
这种流程更加灵活，允许我们调整溢出缓冲区等参数。如果缓冲区已满，我们可以选择暂停发送方或丢弃最旧或最新的值。一个关键优势是 SharedFlow允许您发送重复值；如果您需要发送三次相同的“连接错误”消息，SharedFlow 会毫不犹豫地执行，而 StateFlow 则会将其过滤掉。
技术对比：StateFlow、SharedFlow 和 LiveData
为了避免在技术面试或架构设计中产生混淆，务必考虑以下关键点。LiveData 简单易用，能够自动管理生命周期，但它与 Android 平台紧密相关。StateFlow 和 SharedFlow 作为 Kotlin 协程的一部分，具有平台无关性，这极大地简化了单元测试和清晰的领域层构建。
- StateFlow：强制设置初始值，具有 .value 属性，对值进行去重，非常适合用于 UI 状态。
- 共享流它不需要初始值，可以配置重放，是短暂事件的理想选择。
- 实时数据它不需要初始值，它了解生命周期，但在异步转换方面功能较弱。
安全收割的重要性
一个非常常见的错误是在 Activity 的简单协程作用域内执行 `collect` 方法。这很危险，因为即使应用在后台运行，流程也会继续处理数据，这可能导致崩溃或 CPU 使用率过高。更现代的解决方案是使用`repeatOnLifecycle(Lifecycle.State.STARTED)` API 。
此函数会在视图可见时激活集合，并在集合达到 STOPPED 状态时自动取消。对于 Jetpack Compose，建议使用`collectAsStateWithLifecycle()`，它原生集成了此逻辑，并确保应用程序高效利用设备资源。
将冷流转化为热流
有时我们会收到来自数据库（例如 Room）或存储库的数据流，但它是冷的。为了将其变为热数据，我们使用`stateIn` 或 `shareIn`操作符。这些操作符需要一个 `CoroutineScope` 和一个启动策略。最常用的是`SharingStarted.WhileSubscribed(5000)`。
这种配置非常巧妙，因为它能保证只要有订阅者，视频流就会保持活跃；如果屏幕关闭，它会等待 5 秒钟才会停止视频流。这一点至关重要，因为这样在屏幕旋转期间，视频流就不会被销毁并重新创建，从而避免对服务器或本地数据库发出不必要的请求。
掌握这些工具的关键在于理解状态必须持久化并使用 StateFlow 进行去重，而一次性操作则应通过 SharedFlow 处理。结合生命周期感知和使用 stateIn 进行冷流转换，我们可以构建一个强大且完全响应式的 Android 架构，并针对移动设备上的实际性能进行优化。分享本指南，帮助更多人了解这个主题。
