Objectify 不同步存储，即使现在

Question

我的 servlet 应该执行以下操作：当用户在某个场所注册时，我检查他当前是否在某个地方注册（即使它是同一个场所）如果是，请取消注册并再次注册他。

我有以下代码，为了显示我的问题，我已对其进行了简化：

    Date tempDate = new Date();


    Visit v = ofy().load().type(Visit.class)
            .filter(Visit.USER_ID, 5L)
            .filter(Visit.EXIT_DATE, null).first().get();

    if(v != null)
        exitVenue(5L, 7L, tempDate);

    Visit visit = new Visit(5L, 7L, tempDate);      
    ofy().save().entity(visit).now();

    Date tempDate2 = new Date();


    Visit v2 = ofy().load().type(Visit.class)
            .filter(Visit.USER_ID, 5L)
            .filter(Visit.EXIT_DATE, null).first().get();

    if(v2 != null)
        exitVenue(5L, 7L, tempDate2);

    Visit visit2 = new Visit(5L, 7L, tempDate2);        
    ofy().save().entity(visit2).now();
}


public void exitVenue(Long userID, Long venueID, Date exitDate) {

    Visit visit = ofy().load().type(Visit.class)
            .filter(Visit.USER_ID, userID)
            .filter(Visit.VENUE_ID, venueID)
            .filter(Visit.EXIT_DATE, null).first().get();

    if(visit == null){
        log.info("ERROR : User " + userID + " exited venue " + venueID + ", but Visit was not found");
        return;
    }
    visit.setExitDate(exitDate);

    ofy().save().entity(visit).now();
}

问题是，当我第二次执行所有这些操作时，它并不总是发现数据存储中已经有访问（每隔一次测试，左右）。而且我很困惑'now（）'是否应该立即存储它然后才能继续运行？

非常感谢您的帮助， 丹

Answer 1

发生这种情况是因为 GAE 数据存储区是 eventually consistent：当您创建/更新实体时，该方法会立即返回，但 indexes are still being built asynchronously。由于查询依赖于索引，因此您不会立即看到更改。

此外，这与 objectify 无关 - 这是底层数据存储的属性。同步写入 (.now()) 等待 提交阶段 完成，而异步甚至在此之前立即返回。