Android中MutableLiveData重复触发：第二次调用时Observer执行两次

问题根源 #

你的问题出在Observer重复注册：每次Fragment执行onCreateView时，都会调用quizViewModel.loginH5P.observe(...)添加新的Observer实例。当Fragment因配置变更（如屏幕旋转）或其他原因重建后，旧的Observer未被正确清理，或者新的Observer被重复添加，导致同一个LiveData存在多个Observer监听。第二次调用API时，所有Observer都会收到Success回调，最终日志被打印两次。

具体解决方案 #

方案1：使用一次性Observer（适合单次请求场景） #

给LiveData添加一个observeOnce扩展函数，让Observer仅接收一次回调后自动移除，避免重复触发：

// 扩展函数定义
fun <T> LiveData<T>.observeOnce(lifecycleOwner: LifecycleOwner, observer: Observer<T>) {
    observe(lifecycleOwner, object : Observer<T> {
        override fun onChanged(t: T?) {
            observer.onChanged(t)
            removeObserver(this)
        }
    })
}

然后在Fragment中替换原有的observe调用：

quizViewModel.loginH5P.observeOnce(viewLifecycleOwner) { response ->
    when (response) {
        is Resource.Success -> {
            hideProgressBar()
            response.data?.let {
                Log.i("MYTAG", "AL " + it.loginurl!!)
            }
        }
        is Resource.Error -> {
            hideProgressBar()
            response.message?.let {
                Log.i("MYTAG", "AP " + it)
            }
        }
        is Resource.Loading -> {
            showProgressBar()
            Log.i("MYTAG", "AT ")
        }
    }
}

方案2：手动管理Observer的注册与移除 #

如果需要多次监听该LiveData，可在Fragment中持有Observer实例，并在视图销毁时手动移除，避免重复注册：

// Fragment中声明Observer变量
private lateinit var loginH5PObserver: Observer<Resource<LoginH5PEntity>>

override fun onCreateView(
    inflater: LayoutInflater,
    container: ViewGroup?,
    savedInstanceState: Bundle?
): View {
    // ... 其他初始化逻辑
    loginH5PObserver = Observer { response ->
        // 原有的回调处理逻辑
        when (response) {
            is Resource.Success -> {
                hideProgressBar()
                response.data?.let {
                    Log.i("MYTAG", "AL " + it.loginurl!!)
                }
            }
            is Resource.Error -> {
                hideProgressBar()
                response.message?.let {
                    Log.i("MYTAG", "AP " + it)
                }
            }
            is Resource.Loading -> {
                showProgressBar()
                Log.i("MYTAG", "AT ")
            }
        }
    }
    quizViewModel.loginH5P.observe(viewLifecycleOwner, loginH5PObserver)
    quizViewModel.getLoginH5P()
    // ...
}

override fun onDestroyView() {
    super.onDestroyView()
    // 视图销毁时移除Observer
    quizViewModel.loginH5P.removeObserver(loginH5PObserver)
}

方案3：用SingleEvent封装LiveData（避免粘性事件+重复消费） #

如果需要确保每个事件仅被消费一次（同时解决粘性事件问题），可以封装一个SingleEvent类：

open class SingleEvent<out T>(private val content: T) {
    var hasBeenHandled = false
        private set

    // 获取未处理的内容，标记为已处理
    fun getContentIfNotHandled(): T? {
        return if (hasBeenHandled) {
            null
        } else {
            hasBeenHandled = true
            content
        }
    }

    // 仅查看内容，不标记为已处理
    fun peekContent(): T = content
}

修改ViewModel中的LiveData类型：

class QuizViewModel(
    private val getQuizUseCase: GetQuizUseCase
) : ViewModel() {
    val loginH5P: MutableLiveData<SingleEvent<Resource<LoginH5PEntity>>> = MutableLiveData()
    
    fun getLoginH5P() = viewModelScope.launch(Dispatchers.IO) {
        loginH5P.postValue(SingleEvent(Resource.Loading()))
        try {
            val apiResult = getQuizUseCase.execute()
            loginH5P.postValue(SingleEvent(apiResult))
        } catch (e: Exception) {
            loginH5P.postValue(SingleEvent(Resource.Error(e.message.toString())))
        }
    }
}

Fragment中处理事件：

quizViewModel.loginH5P.observe(viewLifecycleOwner) { event ->
    // 仅处理未被消费过的事件
    event.getContentIfNotHandled()?.let { response ->
        when (response) {
            is Resource.Success -> {
                hideProgressBar()
                response.data?.let {
                    Log.i("MYTAG", "AL " + it.loginurl!!)
                }
            }
            is Resource.Error -> {
                hideProgressBar()
                response.message?.let {
                    Log.i("MYTAG", "AP " + it)
                }
            }
            is Resource.Loading -> {
                showProgressBar()
                Log.i("MYTAG", "AT ")
            }
        }
    }
}

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