Android中RxDataStore<Preferences>数据保存失效问题及Java方案咨询

一、RxPreferenceDataStoreBuilder 行为说明 #

RxPreferenceDataStoreBuilder(context, "MySettings").build() 每次调用都会创建一个新的 RxPreferenceDataStore 实例，但所有指向同一个文件名（此处为"MySettings"）的实例，都会操作设备上的同一个底层偏好文件（路径为 /data/data/[你的包名]/files/datastore/MySettings.preferences_pb）。

不过强烈建议全局单例使用DataStore，多个实例同时操作同一文件可能触发IllegalStateException，或是导致数据同步异常、持久化失败。

二、重启应用数据丢失的原因及Java解决方案 #

常见导致数据丢失的原因及对应解决方法如下：

1. 核心问题：DataStore未实现单例 #

如果你的DataStoreUtils每次读写都创建新的DataStore实例，会导致写入状态无法正确同步到磁盘，最终重启后数据丢失。

修正后的DataStoreUtils单例实现

import android.content.Context;
import androidx.datastore.rxjava2.RxPreferenceDataStoreBuilder;
import androidx.datastore.preferences.rxjava2.RxPreferenceDataStore;
import androidx.datastore.preferences.core.Preferences;
import androidx.datastore.preferences.core.PreferencesKeys;
import io.reactivex.Single;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;

public class DataStoreUtils {
    private static volatile RxPreferenceDataStore INSTANCE;

    private DataStoreUtils() {}

    // 获取全局单例DataStore，使用Application Context避免内存泄漏
    public static RxPreferenceDataStore getInstance(Context context) {
        if (INSTANCE == null) {
            synchronized (DataStoreUtils.class) {
                if (INSTANCE == null) {
                    INSTANCE = new RxPreferenceDataStoreBuilder(
                            context.getApplicationContext(),
                            "MySettings"
                    ).build();
                }
            }
        }
        return INSTANCE;
    }

    // 写入字符串数据示例
    public static Single<Preferences> putString(String key, String value) {
        return getInstance(App.getContext()) // 替换为你的全局Application Context获取方式
                .updateDataAsync(prefsIn -> {
                    Preferences.Builder builder = prefsIn.toBuilder();
                    builder.put(PreferencesKeys.stringKey(key), value);
                    return Single.just(builder.build());
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread());
    }

    // 读取字符串数据示例
    public static Single<String> getString(String key, String defaultValue) {
        return getInstance(App.getContext())
                .data()
                .map(prefs -> prefs.get(PreferencesKeys.stringKey(key)) != null 
                        ? prefs.get(PreferencesKeys.stringKey(key)) 
                        : defaultValue)
                .firstOrError()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread());
    }
}

2. 写入操作未订阅 #

RxJava的异步操作（如updateDataAsync返回的Single）如果不调用subscribe()，代码根本不会执行，数据自然不会写入磁盘。

正确的写入调用方式

// 写入数据时必须订阅，确保操作执行
DataStoreUtils.putString("user_name", "test_user")
        .subscribe(
                updatedPrefs -> { /* 写入成功后的逻辑 */ },
                throwable -> { /* 处理写入失败的异常，比如打印日志 */ }
        );

3. 其他可能的原因及解决 #

• 使用Activity Context导致内存泄漏：始终用Application Context创建DataStore，避免因Activity销毁导致DataStore实例异常，影响磁盘同步。
• 写入未完成就退出应用：如果需要确保数据在应用退出前写入完成，可在非主线程调用blockingGet()等待操作完成（注意不要在主线程调用，避免ANR）：

  // 仅在非主线程使用
  try {
      DataStoreUtils.putString("key", "value").blockingGet();
  } catch (Exception e) {
      e.printStackTrace();
  }
  

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