java - setDefaultHighRepJobPolicyUnappliedJobPercentage(100) 真的有效吗？

Question

根据https://cloud.google.com/appengine/docs/java/tools/localunittesting#Writing_HRD_Datastore_Tests ，“如果您的应用程序使用高复制数据存储(HRD)，您可能需要编写测试来验证应用程序在最终一致性方面的行为。LocalDatastoreServiceTestConfig 公开了使这一切变得容易的选项。”您应该设置 setDefaultHighRepJobPolicyUnappliedJobPercentage(100)，然后“通过将未应用的作业百分比设置为 100，我们指示本地数据存储以最大的最终一致性进行操作。最大最终一致性意味着写入将提交，但始终无法应用，因此全局(非祖先)查询将始终无法看到更改。”

但是，我认为 setDefaultHighRepJobPolicyUnappliedJobPercentage(100) 不起作用。

如果确实如此，那么我下面的测试用例 testEventualConsistency() 应该通过，但在第二个断言上失败。在第一个断言中，我读回了使用 Objectifyancestor() 查询保存的对象。它按照记录工作，因为对象已被检索。然而，第二个断言失败了。在该断言中，我还读回了我保存的对象，但我没有使用 Objectify祖先() 查询，因此它不应该检索任何内容，因为我已经指定不应该完成任何作业(即 setDefaultHighRepJobPolicyUnappliedJobPercentage(100) 设置)。

EventualConsistencyTest 测试用例

import static com.googlecode.objectify.ObjectifyService.begin;
import static com.googlecode.objectify.ObjectifyService.ofy;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.equalTo;

import java.util.List;

import org.junit.Test;

import com.google.appengine.tools.development.testing.LocalDatastoreServiceTestConfig;
import com.google.appengine.tools.development.testing.LocalServiceTestHelper;
import com.googlecode.objectify.ObjectifyService;
import com.googlecode.objectify.Ref;
import com.googlecode.objectify.util.Closeable;
import com.netbase.followerdownloader.model.DownloadTask;
import com.netbase.followerdownloader.model.User;

public class EventualConsistencyTest {
    private final LocalServiceTestHelper helper =
            new LocalServiceTestHelper(new LocalDatastoreServiceTestConfig()
                .setDefaultHighRepJobPolicyUnappliedJobPercentage(100));    

    @Test
    public void testEventualConsistency() {
        helper.setUp();
        ObjectifyRegistrar.registerDataModel();

        User user = new User();
        user.id = 1L;
        Closeable closeable1 = begin();
        ofy().save().entity(user);
        closeable1.close();

        Closeable closeable2 = begin();
        DownloadTask downloadTask = new DownloadTask();
        downloadTask.owner = Ref.create(user);
        ofy().save().entity(downloadTask);
        closeable2.close();

        Closeable closeable3 = ObjectifyService.begin();
        List<DownloadTask> downloadTasks1 = ofy().load().type(DownloadTask.class).ancestor(user).list();
        assertThat(downloadTasks1.size(), equalTo(1));
        closeable3.close();

        Closeable closeable4 = ObjectifyService.begin();
        List<DownloadTask> downloadTasks2 = ofy().load().type(DownloadTask.class).list();
        assertThat(downloadTasks2.size(), equalTo(0));  //  THIS SHOULD PASS IF setDefaultHighRepJobPolicyUnappliedJobPercentage(100) WORKED
        closeable4.close();

        helper.tearDown();
    }

}

用户定义

import com.googlecode.objectify.annotation.Entity;
import com.googlecode.objectify.annotation.Id;

@Entity
public class User {
    @Id public Long id;

    public User () {

    }
}

下载任务定义

import com.googlecode.objectify.Ref;
import com.googlecode.objectify.annotation.Entity;
import com.googlecode.objectify.annotation.Id;
import com.googlecode.objectify.annotation.Parent;

@Entity
public class DownloadTask {
    @Id public Long id;

    @Parent public Ref<User> owner;

    public DownloadTask() {

    }
}

环境:

• appengine-api-1.0-sdk-1.9.17.jar
• appengine-testing-1.9.17.jar
• appengine-api-stubs-1.9.17.jar
• junit-4.11.jar
• objectify-5.1.3.jar

如果我错过了其他重要的内容，这里有一个更详尽的列表:

我的问题是:

1. setDefaultHighRepJobPolicyUnappliedJobPercentage(100) 是否损坏？

2. setDefaultHighRepJobPolicyUnappliedJobPercentage(100) 是否真的按照文档说明的那样工作？尽管文档说不应该这样做，但它实际上是否适用于该工作？

3. 传递给 setDefaultHighRepJobPolicyUnappliedJobPercentage() 的值真的应该是 100 而不是 1.0f 吗？

4. Objectify 祖先查询是否真的按照记录的那样工作？

Answer 1

这个问题可以通过https://cloud.google.com/appengine/docs/java/tools/localunittesting#Java_Writing_High_Replication_Datastore_tests处的观察来解释。 :“在本地环境中，对属于具有未应用写入的实体组的实体执行 get() 始终会使未应用写入的结果对后续全局查询可见。”

在本文中，这意味着祖先查询:

List<DownloadTask> downloadTasks1 = ofy().load().type(DownloadTask.class).ancestor(user).list();

其内部“对属于具有未应用写入的实体组的Entity执行get()”会影响紧随其后的全局查询的行为:

List<DownloadTask> downloadTasks2 = ofy().load().type(DownloadTask.class).list();

为了避免您的测试相互影响，特别是以这种方式相互干扰，最好对每个测试操作使用单独的方法(每个操作都有所有需要的设置和拆卸部分)，而不是让在单个测试方法中连续进行测试操作。