Flow数据模型：冷流、状态、事件与共享策略
FlowStateFlow和SharedFlow的差异，不只是“冷”与“热”。它们分别表达按需执行的数据链路、始终可读取的当前状态，还有向多个订阅者发布的数据或事件。
stateIn和shareIn则处理另一层问题：当一条冷流不应该为每个收集者重复执行时如何把它变成由Scope管理、由启动策略控制的共享数据源。只有把数据语义、共享方式和生命周期放在一起，Flow选型才不会停留在类型对照表。
内容摘要
普通冷Flow由终止操作符启动，每个收集者通常拥有一份独立上游。
热流独立于某一次收集存在多个订阅者共享同一个数据源。
StateFlow始终保存当前值，适合表达可重复读取的状态。
SharedFlow面向广播和共享，通过replay决定新订阅者获得多少近期数据。
stateIn和shareIn把冷流转换为共享热流，Scope与SharingStarted 共同控制共享任务。
一、冷流与热流描述数据源如何存在
"为什么我的API请求会重复执行？" "设备连接总是被频繁断开重连..." 这些痛点往往源于错误使用了冷流而忽视了其按需执行特性。接下来来看看为什么会出现这些问题：
val users: Flow = flow {
val result = api.loadUsers
// 将本次请求结果发送给当前收集者
emit}
"定义这条Flow时,上游通常还没有执行. map,filter等中间操作符也只是在组装处理链,直到collect,first或toList等终止操作符出现。数据生产才真正启动."
collect出现→ 启动一份上游→ 上游emit→ 数据结果
"如果对同一条冷Flow收集两次,通常会执行两份上游:"
"这可能代表着两次网络请求、两次数据库查询或两条设备连接. 冷流的价值正是按需执行和收集者隔离；当重复执行不符合业务意图时,才需要进一步共享."
使用者痛点反馈:
"发现一样的API调用在Activity切换时总是触发两次!"
"BLE设备连接总是在页面旋转后断开又重连!"
"缓存策略失效导致频繁刷新页面!
"
`emit`也不是普通return. 一次Flow可以依次发出多个值。而每个值都沿当前收集链向下游传递."
冷与热是数据源和收集者之间的关系
"我看到很多教程简单说'StateFlow是热流',但具体该怎么区分?按理说，实际开发中经常搞混."这个典型困惑来自于仅从语法角度理解概念.
对比项 冷流 热流
数据源何时出现 收集时启动 独立于某一次收集存在td>
多个收集者 通常各自启动一份上游 订阅同一个共享数据源td>
没有收集者时 上游通常不执行 可以保存状态；话说回来，是否继续生产由实现和启动策略决定td>
常见类型 。Shared Flow td>
常见用途 查询、计算、按需加载 UI状态、共享连接、事件广播
"可以把两者理解成两种不同关系:"这个视角解决了大多数初学者遇到的困惑.
用代码观察冷流时,最明显的现象是每次collect都会重新执行建立器:
& nbsp;println } // 第二次收集:
打印 load countcoldCount.collect { value -> & nbsp;println }
热流则只有一个共享对象,多个订阅者观察的是同一份状态:
& nbsp;println } } scope.launch { & nbsp;// B 不会创建另一份上游,而是观察同一个状态源 & nbsp;hotCount.collect { value -> & nbsp;println } } //更新共享状态后活跃 的A 和B都会 收到 新 值hotC ount.value =
这两个示例关键差异不是emit 和value 的语法,而是生产关系 : 冷 流 把 生产过程交给每 次 收 集。热 流 把 数 据 放 在独立存在 的 常 有数 据 源 中 ."这里强调的是本质区别而非语法细节.
flow本身是 数 据 流 接口,并 不 代表着所有 flow实例都是 冷 流;通过 flow{}等 常 见 构 建 器创建 的 F low通常 是 冷 流。而 stateF low和 sharedF low明确属于热 流 ."
" '热 '也不等于 '创建后永远在后台运 行 '.主 动维护 的 mutable state flow即使 没有 收 集 器,也 能保存当 前状态;由 state in或 share in生成 的热浪其 上 游 是否运 行还要看scope 和sharing started ."
"注意 : 冷/熱與狀態 /事件不是同 一個判斷維度 : 前著描述數據源如何啟動 和 常 用,後著描述數據表達 '當前什麼 '還是 '發生什麼 '. shared flow 是熱浪但它既可以廣播持續數據又可以表達一次性事件."
本節小結
'開發中我們經常會遇到這樣的問題: "為什麼我的數據請求會執 行兩遍?"這些現象背後都是因為對於cold/hot stream理解上的偏差.本節通過具體例子展示了它們之間主要區別所在.'這種帶有實際場景痛點引導方式更容易幫助開發人員理解概念.
二 、狀態與事件需要不同數據語義
state flow保存當前狀態
預先准備的一些ui狀態示例:
state flow必須有初始值並且始終存在一個可讀取 的value .新 的訂閱著開始訂閱時會立即拿到當 前狀態之後繼續接受狀態變化."
這條語義適合頁面渲染 :
kotlin
// 頁面此刻應該顯示什麼?按理说，
內部保留mutable state flow負責修改外部只暴露state flow負責觀察可以把寫權限收入口到狀態所有著.
status update still should use immutable snapshots as much as possible :
kotlin
_uiState.update{ old ->
// update based on most recent old value atomic calculate new snapshot suitable for concurrent status updates old.copy(
loading=false。tasks=newTasks)
}
page can render based on any moment latest snapshot without relying wher notification was received properly.
。
