面试题：Flutter Stream 的复杂场景应用

实现思路

缓存消息：在获取消息时，将接收到的消息缓存到本地，如使用内存缓存（如在内存中维护一个队列）或者持久化缓存（如 SQLite 数据库）。这样即使网络中断，消息也不会丢失。
监控网络状态：使用平台提供的网络状态监听机制，如在 Android 中可使用 ConnectivityManager，在 iOS 中可使用 Reachability 类。当网络中断时，触发相应处理逻辑；当网络恢复时，尝试重新连接 Stream。
处理 Stream 中断：当检测到网络中断导致 Stream 中断时，暂停从 Stream 获取新消息，并标记当前获取位置（如果 Stream 支持标记位置，如文件流的偏移量概念，对于网络流可记录消息序号等）。
重新连接 Stream：网络恢复后，根据之前标记的位置，重新连接 Stream 并从该位置继续获取消息。同时，将缓存中的消息按顺序逐步更新到 UI 上，避免一次性大量更新造成卡顿。
UI 更新：在消息缓存和重新连接获取消息过程中，合理安排 UI 更新逻辑。比如，可以使用数据绑定机制（如 Android 的 LiveData、iOS 的 Combine 框架等），使得数据变化能自动反映到 UI 上，并且处理好更新频率，避免过于频繁更新影响性能。

关键代码逻辑（以 Android 为例，使用 Kotlin 语言）

缓存消息：

使用 MutableList 作为内存缓存，这里简单示例，实际可能需要持久化存储。

private val messageCache = mutableListOf<String>()

假设消息获取逻辑在一个 ChatStream 类中，在获取消息时添加到缓存。

class ChatStream {
    fun receiveMessage() {
        // 模拟获取到消息
        val message = "new message"
        messageCache.add(message)
        // 这里可能还有处理消息显示到 UI 等逻辑
    }
}

监控网络状态：

注册网络变化监听。

class NetworkObserver(private val context: Context) : ConnectivityManager.NetworkCallback() {
    override fun onAvailable(network: Network) {
        // 网络恢复，尝试重新连接 Stream
        reconnectStream()
    }

    override fun onLost(network: Network) {
        // 网络中断，处理 Stream 中断
        handleStreamInterrupt()
    }
}

val connectivityManager = context.getSystemService(Context.CONNECTIVITY_SERVICE) as ConnectivityManager
val networkObserver = NetworkObserver(context)
connectivityManager.registerDefaultNetworkCallback(networkObserver)

处理 Stream 中断：

private var isStreamConnected = true
private var lastMessageIndex = 0

private fun handleStreamInterrupt() {
    isStreamConnected = false
    // 记录当前消息位置，这里简单以缓存列表索引为例
    lastMessageIndex = messageCache.size - 1
}

重新连接 Stream：

private fun reconnectStream() {
    isStreamConnected = true
    // 假设重新连接成功，从缓存中继续显示消息到 UI
    for (i in lastMessageIndex until messageCache.size) {
        updateUIWithMessage(messageCache[i])
    }
    // 继续从 Stream 获取新消息逻辑
}

UI 更新：

假设使用 LiveData 来更新 UI。

private val messageLiveData = MutableLiveData<String>()

private fun updateUIWithMessage(message: String) {
    messageLiveData.value = message
}

// 在 Activity 或 Fragment 中观察 LiveData 更新 UI
messageLiveData.observe(this, Observer { message ->
    // 实际更新 UI 逻辑，如设置 TextView 的文本
    textView.text = message
})

以上代码只是一个简单示例，实际应用中还需要处理更多细节，如异常处理、多线程问题等。在其他平台和语言中，思路类似，但具体实现方式会有所不同。

星途面试题库

面试题：Flutter Stream 的复杂场景应用

知识考点

面试题答案

实现思路

关键代码逻辑（以 Android 为例，使用 Kotlin 语言）