import org.testcontainers.containers.wait.HttpWaitStrategy; //导入依赖的package包/类
@Override
    protected void configure() {
//        addExposedPorts(8091, 8092, 8093, 8094, 11207, 11210, 11211, 18091, 18092, 18093);
        addFixedExposedPort(8091, 8091);
        addFixedExposedPort(8092, 8092);
        addFixedExposedPort(8093, 8093);
        addFixedExposedPort(8094, 8094);
        addFixedExposedPort(8095, 8095);
        addFixedExposedPort(11207, 11207);
        addFixedExposedPort(11210, 11210);
        addFixedExposedPort(11211, 11211);
        addFixedExposedPort(18091, 18091);
        addFixedExposedPort(18092, 18092);
        addFixedExposedPort(18093, 18093);
        setWaitStrategy(new HttpWaitStrategy().forPath("/ui/index.html#/"));
    }
 

import org.testcontainers.containers.wait.HttpWaitStrategy; //导入依赖的package包/类
@Override protected ElasticsearchHttpStorage compute() {
  try {
    container = new GenericContainer(image)
        .withExposedPorts(9200)
        .withEnv("ES_JAVA_OPTS", "-Dmapper.allow_dots_in_name=true -Xms512m -Xmx512m")
        .waitingFor(new HttpWaitStrategy().forPath("/"));
    container.start();
    if (Boolean.valueOf(System.getenv("ES_DEBUG"))) {
      container.followOutput(new Slf4jLogConsumer(LoggerFactory.getLogger(image)));
    }
    System.out.println("Starting docker image " + image);
  } catch (RuntimeException e) {
    // Ignore
  }

  ElasticsearchHttpStorage result = computeStorageBuilder().build();
  CheckResult check = result.check();
  if (check.ok()) {
    return result;
  } else {
    throw new AssumptionViolatedException(check.error().getMessage(), check.error());
  }
}
 

import org.testcontainers.containers.wait.HttpWaitStrategy; //导入依赖的package包/类
@Override
protected void configure() {
    addFixedExposedPort(8091, 8091);
    addFixedExposedPort(8092, 8092);
    addFixedExposedPort(8093, 8093);
    addFixedExposedPort(8094, 8094);
    addFixedExposedPort(8095, 8095);
    addFixedExposedPort(11207, 11207);
    addFixedExposedPort(11210, 11210);
    addFixedExposedPort(11211, 11211);
    addFixedExposedPort(18091, 18091);
    addFixedExposedPort(18092, 18092);
    addFixedExposedPort(18093, 18093);
    setWaitStrategy(new HttpWaitStrategy().forPath("/ui/index.html#/"));
}
 

import org.testcontainers.containers.wait.HttpWaitStrategy; //导入依赖的package包/类
/**
 * @param ready the AtomicBoolean on which to indicate success
 * @return the WaitStrategy under test
 */
@NotNull
protected HttpWaitStrategy buildWaitStrategy(final AtomicBoolean ready) {
    return new HttpWaitStrategy() {
        @Override
        protected void waitUntilReady() {
            // blocks until ready or timeout occurs
            super.waitUntilReady();
            ready.set(true);
        }
    }.forResponsePredicate(s -> s.equals(GOOD_RESPONSE_BODY));
}
 

import org.testcontainers.containers.wait.HttpWaitStrategy; //导入依赖的package包/类
@Override
protected void configure() {
    addExposedPorts(8091, 8092, 8093, 8094, 11207, 11210, 11211, 18091, 18092, 18093);
    setWaitStrategy(new HttpWaitStrategy().forPath("/ui/index.html#/"));
}