如何避免Fragment中LiveData观察导致的数据重复问题？

问题根源 #

你使用activityViewModels()获取的CodeReaderViewModel属于Activity级别生命周期，其内部的barcode数据源（从代码看应为LiveData或类似可观察对象）会保留历史发送的数据。每次Fragment从回栈返回时，onViewCreated会重新执行并调用observeBarcode()订阅该数据源，而viewLifecycleOwner恢复活跃状态后，粘性事件会被再次分发，导致addProduct重复执行、数据重复。

解决方案 #

方案1：手动清除ViewModel中的历史数据（针对LiveData）

处理完条码后，调用ViewModel的方法清除barcode的当前值，避免粘性事件触发重复处理：

1. 在CodeReaderViewModel中新增清除方法：

class CodeReaderViewModel : ViewModel() {
    private val _barcode = MutableLiveData<String>()
    val barcode: LiveData<String> = _barcode

    // 发送条码的方法（原代码已有）
    fun sendBarcode(newBarcode: String) {
        _barcode.value = newBarcode
    }

    // 新增：清除条码数据
    fun clearBarcode() {
        _barcode.value = ""
    }
}

2. 修改Fragment中的observeBarcode方法，处理后清除数据：

private fun observeBarcode() {
    scanner.barcode.observe(viewLifecycleOwner) { barcode ->
        if (barcode.isNotEmpty()) {
            if (binding.searchView.isIconified) {
                addProduct(barcode)
                scanner.clearBarcode() // 处理后清除
            }

            if (!binding.searchView.isIconified) {
                binding.searchView.setQuery(barcode, true)
                scanner.clearBarcode() // 处理后清除
            }
        }
    }
}

方案2：改用非粘性的Flow（推荐）

将barcode改为SharedFlow（默认非粘性，仅发送订阅后的新事件），避免历史数据被重复接收：

1. 修改CodeReaderViewModel的数据源：

class CodeReaderViewModel : ViewModel() {
    private val _barcode = MutableSharedFlow<String>()
    val barcode: SharedFlow<String> = _barcode

    fun sendBarcode(newBarcode: String) {
        viewModelScope.launch {
            _barcode.emit(newBarcode)
        }
    }
}

2. 在Fragment中使用Flow的生命周期安全收集方式：

private fun observeBarcode() {
    viewLifecycleOwner.lifecycleScope.launch {
        // 仅在Fragment处于STARTED及以上状态时收集事件
        viewLifecycleOwner.repeatOnLifecycle(Lifecycle.State.STARTED) {
            scanner.barcode.collect { barcode ->
                if (barcode.isNotEmpty()) {
                    if (binding.searchView.isIconified) {
                        addProduct(barcode)
                    }
                    if (!binding.searchView.isIconified) {
                        binding.searchView.setQuery(barcode, true)
                    }
                }
            }
        }
    }
}

方案3：本地记录已处理的条码（快速临时方案）

在Fragment中维护一个变量，记录最近处理过的条码，处理前判断是否重复：

private var lastProcessedBarcode = ""

private fun observeBarcode() {
    scanner.barcode.observe(viewLifecycleOwner) { barcode ->
        // 仅处理未处理过的非空条码
        if (barcode.isNotEmpty() && barcode != lastProcessedBarcode) {
            lastProcessedBarcode = barcode
            if (binding.searchView.isIconified) {
                addProduct(barcode)
            }
            if (!binding.searchView.isIconified) {
                binding.searchView.setQuery(barcode, true)
            }
        }
    }
}

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