Android ViewModel中init块重复调用：如何正确收集Flow？

一、ViewModel切换至前台时init块是否总会被调用？ #

不会。ViewModel的init块仅在ViewModel实例首次创建时执行一次。只要ViewModel未被销毁（比如Fragment/Activity未被彻底销毁、未发生配置变化重建、进程未被杀），切换前台不会触发ViewModel重新实例化，自然init块不会重复执行。

你遇到的init块重复执行，说明ViewModel被意外重新创建了，常见原因包括：

• Koin模块中错误使用factory绑定ViewModel（而非viewModel），导致每次获取都生成新实例；
• Fragment被意外重建（如未正确处理配置变化、Fragment实例被重复创建）；
• 代码中存在多次获取ViewModel实例的错误逻辑。

二、如何避免init块内方法重复执行+实现Flow的安全收集？ #

1. 先解决ViewModel重复创建的问题 #

（1）修正Koin的ViewModel绑定

确保在Koin模块中使用viewModel绑定，而非factory，这样ViewModel会与Fragment/Activity的生命周期绑定，同一个组件实例只会获取到同一个ViewModel：

module {
    // 正确绑定：ViewModel与组件生命周期关联
    viewModel { MyViewModel(get()) }
    // 错误示例：factory每次调用都会创建新实例
    // factory { MyViewModel(get()) }
}

（2）修复ViewModel的语法错误

你的代码中ViewModel重复继承了ViewModel，这是语法错误，需修正：

// 错误写法
// class MyViewModel: ViewModel(private val repository: MyRepository): ViewModel()

// 正确写法
class MyViewModel(private val repository: MyRepository) : ViewModel()

2. 确保init块内的网络请求仅执行一次 #

即使ViewModel不会重复创建，也可以通过以下方式避免重复请求：

方式一：通过StateFlow的初始状态判断

检查当前UI状态是否已有数据，仅在数据为空时发起请求：

class MyViewModel(private val repository: MyRepository) : ViewModel() {
    private val _uiState: MutableStateFlow<MyUiState> = MutableStateFlow(MyUiState.Success(emptyList()))
    val uiState: StateFlow<MyUiState> = _uiState

    init {
        getSomeDataFromNetwork()
    }
    
    private fun getSomeDataFromNetwork() {
        viewModelScope.launch {
            // 仅当数据为空时发起请求
            val currentState = _uiState.value
            if (currentState is MyUiState.Success && currentState.data.isEmpty()) {
                val response = repository.getSomeDataFromNetwork()
                // 处理响应，更新_uiState
                _uiState.value = MyUiState.Success(response.data)
            }
        }
    }
}

方式二：使用标志位记录请求状态

用布尔变量标记是否已发起过请求，避免重复执行：

class MyViewModel(private val repository: MyRepository) : ViewModel() {
    private val _uiState: MutableStateFlow<MyUiState> = MutableStateFlow(MyUiState.Success(emptyList()))
    val uiState: StateFlow<MyUiState> = _uiState
    private var hasFetchedData = false

    init {
        getSomeDataFromNetwork()
    }
    
    private fun getSomeDataFromNetwork() {
        viewModelScope.launch {
            if (!hasFetchedData) {
                hasFetchedData = true
                val response = repository.getSomeDataFromNetwork()
                // 处理响应，更新_uiState
                _uiState.value = MyUiState.Success(response.data)
            }
        }
    }
}

3. 实现Flow的安全收集（避免重复处理） #

（1）使用repeatOnLifecycle替代launchWhenStarted

launchWhenStarted仅暂停协程，不会在生命周期退出STARTED时取消；repeatOnLifecycle会在生命周期退出STARTED时取消协程，再次进入时重新启动，更符合生命周期安全：

class MyFragment: Fragment() {
    private val viewModel: MyViewModel by viewModel()

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        super.onViewCreated(view, savedInstanceState)
        collectSomeFlow()
    }

    private fun collectSomeFlow() {
        viewLifecycleOwner.lifecycleScope.launch {
            viewLifecycleOwner.repeatOnLifecycle(Lifecycle.State.STARTED) {
                viewModel.uiState.collect { state ->
                    // 处理UI状态
                }
            }
        }
    }
}

（2）避免重复处理相同状态

如果不需要处理重复的相同状态，可在Flow上添加distinctUntilChanged()操作符：

private fun collectSomeFlow() {
    viewLifecycleOwner.lifecycleScope.launch {
        viewLifecycleOwner.repeatOnLifecycle(Lifecycle.State.STARTED) {
            viewModel.uiState.distinctUntilChanged().collect { state ->
                // 仅当状态真正变化时才处理
            }
        }
    }
}

（3）单次收集最新状态

如果只需要获取一次最新状态，之后不再接收更新，可使用first()：

private fun collectSomeFlow() {
    viewLifecycleOwner.lifecycleScope.launch {
        val initialState = viewModel.uiState.first()
        // 处理初始状态
    }
}

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