Kotlin冷熱流：你的代碼會選"點唱機"還是"廣播站"
作者：沐雨花飛碟
在Kotlin協程的世界里，數據流動居然有"冷熱"之分——冷流像傲嬌的藝術家只在觀眾到場時表演，熱流像熱情的主持人不管有沒有觀眾都自嗨。今天我們用三個腦洞大開的比喻，讓這兩個概念變成你的編程好幫手！
在Kotlin協程的世界里，數據流動居然有"冷熱"之分——冷流像傲嬌的藝術家只在觀眾到場時表演，熱流像熱情的主持人不管有沒有觀眾都自嗨。今天我們用三個腦洞大開的比喻，讓這兩個概念變成你的編程好幫手！
冷流：你的私人點唱機
特性揭秘
- ? 隨叫隨到：只有投幣（調用collect）才會開始唱歌
- ? 專屬服務：每個聽眾都有全新歌單從頭播放
- ? 完美復刻：第100位聽眾也能聽到完整版《最炫民族風》
實戰代碼秀
fun createColdPlaylist() = flow {
// 冷流在collect時才會開始生產數據
println("?? 正在準備全新歌單...")
listOf("只因你太美", "Deadman").forEach {
delay(1000) // 模擬音樂加載過程
emit(it)
}
}
// 第一個聽眾
coroutineScope.launch {
createColdPlaylist().collect { song ->
println("???? 聽眾A收到: $song")
}
}
// 第二個聽眾（5秒后加入）
coroutineScope.launch {
delay(5000)
createColdPlaylist().collect { song ->
println("???? 聽眾B收到: $song")
}
}運行效果
???? 聽眾A收到: 只因你太美 (1秒后)
???? 聽眾A收到: Deadman (2秒后)
???? 聽眾B收到: 只因你太美 (5秒后)
???? 聽眾B收到: Deadman (6秒后)每個新聽眾都會觸發全新的播放列表，就像給每個用戶單獨開了一臺點唱機。
熱流：永不停止的廣播站 ??
特性揭秘
? 24小時放送：不管有沒有聽眾，節目照常播出
? 共享頻道：所有聽眾聽到相同內容
? 過時不候：遲到聽眾錯過已播內容
實戰代碼秀
val radioChannel = MutableSharedFlow<String>()
// 電臺自動播放
coroutineScope.launch {
listOf("新聞聯播", "天氣預報", "音樂時間").forEach {
radioChannel.emit(it)
delay(2000) // 每2秒播報一次
}
}
// 早起聽眾
coroutineScope.launch {
radioChannel.collect { program ->
println("?? 早鳥聽眾聽到: $program")
}
}
// 賴床聽眾（3秒后加入）
coroutineScope.launch {
delay(3000)
radioChannel.collect { program ->
println("?? 遲到大王聽到: $program")
}
}運行效果
?? 早鳥聽眾聽到: 新聞聯播 (立即)
?? 早鳥聽眾聽到: 天氣預報 (2秒后)
?? 遲到大王聽到: 天氣預報 (3秒時加入剛好趕上)
?? 早鳥聽眾聽到: 音樂時間 (4秒后)
?? 遲到大王聽到: 音樂時間 (4秒后)早起的鳥兒能聽到完整節目，賴床的聽眾只能聽到加入后的內容，就像現實中的電臺廣播。
選擇困難癥急救包 ??
選冷流：
? 需要精確控制數據生產過程（像現點現做的私房菜）
? 每個訂閱需要獨立上下文（像銀行交易隔離）
? 數據需要重復使用（像回放監控錄像）
選熱流：
? 多個訂閱共享實時狀態（像會議室大屏幕）
? 需要持續后臺更新（像天氣預報自動刷新）
? 不關心歷史數據（像直播彈幕）
冷熱流神比喻PK
對比維度 | 冷流 (VIP點唱機) | 熱流 (公共廣播) |
數據保鮮度 | 每次都是現做現賣 | 可能是隔夜飯（歷史數據不保留） |
資源消耗 | 每個用戶單獨開火 | 一鍋飯大家分 |
適用場景 | 需要完整重放的操作 | 實時狀態同步 |
典型應用 | 分頁加載、文件下載 | 即時消息、股票行情 |
內存影響 | 可能多個副本占用內存 | 單一數據源節省內存 |
注意：需要添加協程依賴
implementation "org.jetbrains.kotlinx:kotlinx-coroutines-core:1.6.0"現在你已經是冷熱流的選擇大師了！下次寫Flow代碼時，不妨想想這個場景需要點唱機般的專屬服務，還是廣播站式的共享狂歡？
責任編輯：武曉燕
來源：
Reathin
