应用后台切换后LiveData重复创建观察者引发重复发射问题求助

问题根源在于你当前的写法中，repeatOnLifecycle(Lifecycle.State.STARTED)的代码块会在Activity每次进入STARTED状态时重新执行，每次执行都会调用observe给LiveData新增一个观察者。而LiveData具备粘性分发特性——新注册的观察者会立即收到当前的最新数据，导致每次切前台时，已有观察者+新观察者都会触发回调，次数随切前台次数递增。

下面是两种可行的解决方案：

方案一：改用Flow直接收集（官方推荐） #

这是Jetpack组件推荐的现代生命周期感知型数据处理方式，避免LiveData的粘性和重复注册问题。

1. 修改ViewModel代码 #

直接暴露Flow，无需转成LiveData：

// ViewModel.kt
val currentStockPriceFlow: Flow<UiState> = stockPriceDataSource.latestStockList
    .map { listOfStock ->
        UiState.Success(listOfStock)
    }

如果需要粘性数据（比如切前台要立即获取最新缓存值），可以将Flow转为StateFlow：

// ViewModel.kt
val currentStockPriceFlow: StateFlow<UiState> = stockPriceDataSource.latestStockList
    .map { listOfStock ->
        UiState.Success(listOfStock)
    }
    .stateIn(
        scope = viewModelScope,
        started = SharingStarted.WhileSubscribed(5000), // 退后台5秒后停止上游收集
        initialValue = UiState.Loading // 设置初始状态
    )

2. 修改Activity代码 #

用repeatOnLifecycle配合collect收集Flow，每次进入STARTED状态只会重新启动收集，不会新增观察者：

// Activity.kt
override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    setContentView(binding.root)
        
    lifecycleScope.launch {
        lifecycle.repeatOnLifecycle(Lifecycle.State.STARTED) {
            viewModel.currentStockPriceFlow.collect { uiState ->
                if (uiState is UiState.Success) {
                    Timber.d("Received ${uiState.stockList.first()}")
                }
                render(uiState)
            }
        }
    }
}

方案二：保留LiveData，避免重复注册观察者 #

如果必须继续使用LiveData，需要确保观察者只注册一次。可以将observe移出repeatOnLifecycle代码块（因为onCreate只会执行一次），若需要退后台停止观察，需手动管理观察者的注册与注销：

// Activity.kt
private lateinit var stockObserver: Observer<UiState>

override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    setContentView(binding.root)
    
    stockObserver = Observer { uiState ->
        if (uiState is UiState.Success) {
            Timber.d("Received ${uiState.stockList.first()}")
        }
        render(uiState)
    }
        
    lifecycleScope.launch {
        lifecycle.repeatOnLifecycle(Lifecycle.State.STARTED) {
            viewModel.currentStockPriceAsLiveData.observe(this@FlowUseCase1Activity, stockObserver)
        }.invokeOnCompletion {
            // 退后台时移除观察者
            viewModel.currentStockPriceAsLiveData.removeObserver(stockObserver)
        }
    }
}

不过这种写法相对繁琐，不如方案一简洁可靠。

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