Android中LoginUtil.kt如何向ViewModel及UI推送登录状态更新？

完全可以在非ViewModel类中使用StateFlow，它并不依赖ViewModel的生命周期，只需自己管理协程作用域即可。以下是具体实现方案：

1. 在LoginUtil中定义StateFlow #

首先在LoginUtil里声明一个可变的MutableStateFlow来持有用户状态，对外暴露不可变的StateFlow供ViewModel观察：

class LoginUtil {
    private val _currentUser = MutableStateFlow<FirebaseUser?>(null)
    // 对外暴露只读的StateFlow
    val currentUser: StateFlow<FirebaseUser?> = _currentUser.asStateFlow()
    
    private val auth = FirebaseAuth.getInstance()
    private lateinit var authStateListener: FirebaseAuth.AuthStateListener
    
    init {
        // 监听FirebaseAuth的全局状态变化（比如其他设备登出、账号删除等）
        authStateListener = FirebaseAuth.AuthStateListener { firebaseAuth ->
            _currentUser.value = firebaseAuth.currentUser
        }
        auth.addAuthStateListener(authStateListener)
        // 初始化当前用户状态
        _currentUser.value = auth.currentUser
    }
}

2. 登录/登出时更新状态 #

在登录、登出方法中直接更新MutableStateFlow的值，状态变化会自动推送给订阅者：

fun login(email: String, password: String) {
    auth.signInWithEmailAndPassword(email, password)
        .addOnCompleteListener { task ->
            // 即使AuthStateListener会自动更新，手动赋值可以确保状态同步更及时
            _currentUser.value = task.result?.user
            // 这里可以处理登录失败逻辑，比如抛出异常或回调通知
        }
}

fun logout() {
    auth.signOut()
    // 同样，AuthStateListener会触发，但手动赋值更直接
    _currentUser.value = null
}

3. 在ViewModel中观察状态 #

ViewModel使用viewModelScope来收集StateFlow的状态变化，确保协程生命周期和ViewModel绑定：

class LoginViewModel(private val loginUtil: LoginUtil) : ViewModel() {
    fun observeUserState() {
        viewModelScope.launch {
            loginUtil.currentUser.collect { user ->
                when (user) {
                    null -> {
                        // 处理未登录状态，比如跳转登录页、更新UI
                    }
                    else -> {
                        // 处理已登录状态，比如获取用户信息、跳转主页
                    }
                }
            }
        }
    }
}

4. 清理资源避免泄漏 #

如果LoginUtil是长生命周期对象（比如单例），可以不用额外清理；如果是和页面绑定的实例，记得在销毁时移除监听器并取消协程作用域：

// 在LoginUtil中添加清理方法
fun cleanup() {
    auth.removeAuthStateListener(authStateListener)
    // 如果自定义了协程作用域，这里取消它
    // scope.cancel()
}

为什么选StateFlow？ #

• 状态持久化：新订阅者会立即收到当前最新状态，无需等待下一次变化
• 高效推送：仅在状态实际变化时发送更新，避免普通Flow需要轮询的冗余操作
• 无ViewModel依赖：只要管理好协程作用域，任何类都能使用

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