Kotlin/Android中Preferences DataStore无法读取初始值求助

核心问题分析 #

• getLiveCount 方法逻辑错误：将Flow转为LiveData后直接获取value，此时LiveData尚未完成数据收集，必然返回null，最终触发默认值500。
• 滥用runBlocking：在主线程（包括Activity onCreate和Composable）使用runBlocking会阻塞UI线程，不仅影响性能，还会导致DataStore操作无法正确异步执行。
• 未正确监听DataStore的Flow：定义了myStateFlow但未用于驱动UI更新，导致UI无法感知DataStore中的计数变化。

修复方案 #

1. 修正仓库层方法 #

删除错误的getLiveCount，直接使用已定义的myStateFlow来获取和监听计数变化；简化getInitialCount的实现：

class MyStateRepository(
    private val dataStore: DataStore<Preferences>
) {
    private val countKey = intPreferencesKey("COUNT")

    val myStateFlow: Flow<MyState> = dataStore.data
        .catch { exception ->
            if (exception is IOException) emit(emptyPreferences()) else throw exception
        }.map { preferences ->
            MyState(preferences[countKey] ?: 100)
        }

    suspend fun updateCount(newCount: Int) {
        dataStore.edit { preferences -> preferences[countKey] = newCount }
    }

    suspend fun getInitialCount(): Int {
        // 直接获取Flow的第一个值，避免不必要的操作
        return myStateFlow.first().count
    }
}

2. 优化Activity中的协程处理 #

• 初始化Repository不需要runBlocking，构造函数无挂起操作。
• 使用lifecycleScope异步初始化currentCount，避免阻塞UI；在Composable中用LaunchedEffect安全收集Flow，驱动UI状态更新。

3. 重构Composable逻辑 #

• 移除Composable中的runBlocking，改用协程安全的方式处理数据更新。
• 让UI直接响应DataStore的Flow变化，保证数据一致性。

完整修正代码 #

Repository层 #

data class MyState(val count: Int)

private val Context.dataStore by preferencesDataStore(
    name = "MY_PREFS"
)

class MyStateRepository(
    private val dataStore: DataStore<Preferences>
) {
    private val countKey = intPreferencesKey("COUNT")

    val myStateFlow: Flow<MyState> = dataStore.data
        .catch { exception ->
            if (exception is IOException) emit(emptyPreferences()) else throw exception
        }.map { preferences ->
            MyState(preferences[countKey] ?: 100)
        }

    suspend fun updateCount(newCount: Int) {
        dataStore.edit { preferences -> preferences[countKey] = newCount }
    }

    suspend fun getInitialCount(): Int {
        return myStateFlow.first().count
    }
}

MainActivity层 #

class MainActivity : ComponentActivity() {

    private lateinit var myStateRepository: MyStateRepository
    private var currentCount by mutableIntStateOf(200)

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        // 直接初始化Repository，无需runBlocking
        myStateRepository = MyStateRepository(dataStore)
        
        lifecycleScope.launch {
            // 异步获取初始计数，避免阻塞UI
            currentCount = myStateRepository.getInitialCount()
        }
        
        setContent {
            Counter()
        }
    }

    @Composable
    private fun Counter() {
        // 收集Flow，实时同步DataStore中的计数变化
        LaunchedEffect(Unit) {
            myStateRepository.myStateFlow.collect { state ->
                currentCount = state.count
            }
        }

        Button(
            onClick = {
                lifecycleScope.launch {
                    val newCount = currentCount + 1
                    myStateRepository.updateCount(newCount)
                }
            },
            content = { Text(text = "$currentCount") }
        )
    }
}

依赖保持不变 #

implementation("androidx.datastore:datastore-preferences:1.0.0")
implementation("org.jetbrains.kotlinx:kotlinx-coroutines-android:1.6.4")
implementation("androidx.lifecycle:lifecycle-runtime-ktx:2.6.2")
implementation("androidx.lifecycle:lifecycle-livedata-ktx:2.6.2")

关键说明 #

• 避免阻塞UI线程：所有DataStore操作必须在协程中执行，使用lifecycleScope（Activity/Fragment）或LaunchedEffect（Composable）来处理异步任务。
• 用Flow驱动UI：DataStore的核心是Flow，通过收集Flow可以自动感知数据变化，保证UI和持久化数据的一致性。
• 简化数据获取：直接通过myStateFlow.first()获取初始值，无需额外封装错误的同步方法。

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