android - Realm 数据同步不一致

Question

我遇到一个问题，Realm 有时会在我每次执行相同的查询时返回不同的数据。目前我正在使用 SyncAdapter 进行上传。这个想法是我们正在尝试实现离线模式。

因此，当用户创建一个项目时，它会被添加到 Realm 数据库中。我通过获取 maxId 并向其添加 1000 来手动生成该项目的 ID。之后，我将 itemID 发送到 UploadSyncAdapter，在那里我获取 itemById 并将其发送到后端，后端返回给我具有真实 ID 的项目。所以在那之后我删除旧项目并将新项目插入 Realm。

在我返回并读取数据后，它每隔一秒返回一次，例如大小为 115 的数组，另一次返回大小为 116 的数组。我什至用调试器按 ID 搜索项目，它确实找到了一次该项目，第二次它没有。但看起来在我重建项目后项目在那里并且工作正常，或者如果我使用 Instant Run 重新运行应用程序。

感谢任何帮助...

更新顺便说一句，我正在使用 RXjava 从服务器获取数据，但它正在当前线程(SyncAdapter 线程)上被订阅和观察。

代码如下:

@Override
public void onNext(TaskResponse taskResponse) {
     tasksDatabaseManager.deleteTaskById(taskId);
     List<Task> tasks = taskResponse.getTaskDataList();
     tasksDatabaseManager.insertTasks(tasks);
 }

public void deleteTaskById(int taskId){
    Realm realm = Realm.getDefaultInstance();
    realm.beginTransaction();
    RealmResults<Task> rows = realm.where(Task.class).equalTo(ID, taskId).findAll();
    rows.deleteAllFromRealm();
    realm.commitTransaction();
    realm.close();
}

private void copyOrUpdateTasks(List<Task> tasksList){
    Realm realm = Realm.getDefaultInstance();
    ArrayList<Task> updatedTaskList;
    //first initialize task permissions
    updatedTaskList = filterTasksByPermission(tasksList);
    //initialize custom task data
    for (Task task : updatedTaskList) {
        initializeTaskCustomFields(task);
    }
    //save new data
    Log.d(TAG, "tasks number before update: " + getTasks().size());
    realm.beginTransaction();
    realm.copyToRealmOrUpdate(updatedTaskList);
    realm.commitTransaction();
    realm.close();

    Log.d(TAG, "tasks number after update: " + getTasks().size());
}

在 filterTasksByPermission 中，我只是计算了任务的一些权限，但任务正在列表中返回。在 initializeTaskCustomFields 中，我也只是在保存到 Realm 之前计算对象的 2 个字段(以便我将这些值也保存在 Realm 中)

Answer 1

经过一番研究，我发现了问题所在。但如果我错了请纠正我。我在我的 Rx 调用中用 Subscribers.newThread() 替换了我的 Subscribers.io() ，现在它工作正常。所以我的理论是:

在调用我的 UploadAdapter 上传更改的数据之前，我使用 Subscribers.io() 的 Rx 调用将我的项目插入数据库。 Subscribers.io() 使用线程池来重用线程，或者在必要时创建新线程。因此，假设它产生了一个名为“A”的线程。线程 A 获取一个 Realm 实例(假设 Realm 快照为“1”)并将创建的项目插入其中。在 SyncAdapter get 被调用之后，它还获得了一个具有相同 Realm 快照“1”的新 Realm 实例。 SyncAdapter 完成将数据上传到服务器后，它会删除旧项目，并插入从服务器获得的新项目。所以在这个 Realm 数据改变之后，最新的 Realm 快照现在是“2”。 SyncAdapter 向 Activity 发送广播，告知上传已完成，它应该从 Realm 数据库中获取新数据。

为了从 Realm 读取数据，我还使用了带有 Subscribers.io() 的 Rx。因此，当从 Realm 请求新数据时，Subscribers.io() 的池中已经有一个线程正在等待重用，这就是线程“A”。由于这个线程是一个非 Looper 线程，它不知道 Realm 数据发生了变化，它仍然使用 Realm 快照“1”，所以这就是我从 Realm 获取旧数据的原因。刷新几次后 Subscribers.io() 可能会创建一个新线程，假设线程“B”。

所以线程“B”也得到了一个 Realm 快照，这次是最新的快照，所以快照“2”。并返回正确的数据。

所以当使用 Subscribers.newThread() 时，它总是创建一个新线程并且它总是有最新的 Realm 快照。

这是关于 Subscribers.io() 和 Subscribers.newThread() 之间区别的链接: Retrofit with Rxjava Schedulers.newThread() vs Schedulers.io()

希望这对某人有帮助!