Android Kotlin环境下使用协程按顺序处理Socket.io连续传入的温度消息

你当前的实现每次收到消息都会创建独立的协程任务，多个任务并行在IO调度器执行，调度顺序不可控，自然会出现后到的消息先处理完成的情况。以下两种方案都适配你使用的协程1.4.1版本，可直接落地：

方案1：Channel + 单消费者常驻协程（匹配你现有代码的修正实现） #

你之前注释的循环接收逻辑是可行的，只需要将Channel的关闭时机和页面生命周期绑定即可，不需要提前预知消息总数量：

1. 首先在Activity/Fragment中定义Channel作为消息队列，并用和页面绑定的lifecycleScope管理协程生命周期，避免内存泄漏：

// 定义无限容量的Channel存储温度数据
private val tmpChannel = Channel<String>(Channel.UNLIMITED)

override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    // 启动单消费者协程，串行处理所有消息
    lifecycleScope.launch(Dispatchers.IO) {
        // 循环遍历Channel接收消息，协程随页面销毁取消时自动退出循环
        for (data in tmpChannel) {
            // 先执行数据存储逻辑
            usersBg(data)
            // 切主线程更新UI
            withContext(Dispatchers.Main) {
                // 此处写温度数据展示逻辑
            }
        }
    }
}

2. 接收消息的函数直接往Channel投递数据即可，UNLIMITED容量的Channel调用trySend不会挂起，不需要额外开协程：

fun receiveTmps(data: String) {
    tmpChannel.trySend(data)
}

3. 页面销毁时手动关闭Channel即可：

override fun onDestroy() {
    super.onDestroy()
    tmpChannel.close()
}

方案2：Mutex互斥锁（更轻量的实现，适合小型业务场景） #

如果不想引入Channel做队列，也可以通过互斥锁保证任务串行执行，只要消息是按顺序调用receiveTmps，处理顺序就不会乱：

// 定义互斥锁
private val taskMutex = Mutex()

fun receiveTmps(data: String) {
    // 复用页面生命周期绑定的协程作用域
    lifecycleScope.launch(Dispatchers.IO) {
        // 抢锁执行，上一个任务释放锁后下一个任务才会进入执行
        taskMutex.withLock {
            usersBg(data)
            withContext(Dispatchers.Main) {
                // 温度数据展示逻辑
            }
        }
    }
}

注意事项 #

• 不要每次接收消息都新建独立的CoroutineScope，必须复用和页面/业务生命周期绑定的作用域（如lifecycleScope、viewModelScope），避免内存泄漏。
• 如果数据处理逻辑可能抛出异常，建议加try-catch捕获，避免协程崩溃导致后续消息无法处理。

内容的提问来源于stack exchange，提问作者Riccoh