领域数据同步不一致

Question

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

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

@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调用在数据库中插入我的项。IO（）使用线程池重用线程，或者创建新的线程。假设它产生了一个叫做“a”的线程。线程获取是一个领域实例（假设该领域快照是“1”），并将创建的项插入其中。在此之后，调用SyncAdapter get，它也得到了一个具有相同领域快照“1”的新领域实例。在SyncAdapter完成向服务器上传数据之后，它会删除旧项，并插入从服务器获得的新项。因此，在这个领域数据发生变化后，最新的领域快照现在是“2”。SyncAdapter向活动发送一个广播，说明上传已经完成，它应该从领域数据库中获得新的数据。

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

希望这能帮助到别人！