import com.spotify.docker.client.messages.Image; //导入依赖的package包/类
@Override
public Set<String> listImageTags() throws IOException {

  final Set<String> result = new HashSet<>();

  try {

    for (Image image : CollectionUtils
        .nullToEmpty(this.client.listImages())) {
      for (String tag : CollectionUtils.nullToEmpty(image.repoTags())) {
        if (tag != null) {
          result.add(tag);
        }
      }
    }
  } catch (DockerException | InterruptedException e) {
    throw new IOException(e);
  }

  return result;
}
 

import com.spotify.docker.client.messages.Image; //导入依赖的package包/类
@Override
public void pullImageIfNotExists() throws IOException {

  try {

    for (Image image : nullToEmpty(this.dockerClient.listImages())) {
      for (String tag : nullToEmpty(image.repoTags())) {
        if (this.dockerImage.equals(tag)) {
          return;
        }
      }
    }

    getLogger().fine("Pull Docker image: " + this.dockerImage);
    this.dockerClient.pull(this.dockerImage);
  } catch (InterruptedException | DockerException e) {
    throw new IOException(e);
  }
}
 

import com.spotify.docker.client.messages.Image; //导入依赖的package包/类
@Override
public void start(WorkflowInstance workflowInstance, RunSpec runSpec) {
  final String imageTag = runSpec.imageName().contains(":")
      ? runSpec.imageName()
      : runSpec.imageName() + ":latest";

  final ContainerCreation creation;
  try {
    boolean found = false;
    for (Image image : client.listImages()) {
      found |= image.repoTags().contains(imageTag);
    }

    if (!found) {
      client.pull(imageTag, System.out::println); // blocking
    }

    final ContainerConfig containerConfig = ContainerConfig.builder()
        .image(imageTag)
        .cmd(runSpec.args())
        .build();
    creation = client.createContainer(containerConfig, runSpec.executionId());
    client.startContainer(creation.id());
  } catch (DockerException | InterruptedException e) {
    throw new RuntimeException(e);
  }

  inFlight.put(creation.id(), workflowInstance);
  LOG.info("Started container with id " + creation.id() + " and name " + runSpec.executionId());
}
 

import com.spotify.docker.client.messages.Image; //导入依赖的package包/类
/**
 * Pulls the image with the given name if it does not appear in the list of
 * available images.
 *
 * @param imageName
 *            the name of the image that should be pulled
 */
@SuppressWarnings("unused")
private void pullImageIfNeeded(String imageName) {
    // do not pull if env var is set to false
    if (!DOCKER_AUTOPULL) {
        return;
    }

    if (!containsVersionTag(imageName)) {
        imageName += ":latest";
    }

    // check if image is already available
    try {
        List<Image> images = dockerClient.listImages();
        for (Image image : images) {
            if (image.repoTags() != null) {
                for (String tag : image.repoTags()) {
                    if (tag.equals(imageName)) {
                        return;
                    }
                }
            }
        }

        // pull image and wait for the pull to finish
        pullImage(imageName);
    } catch (Exception e) {
        LOGGER.error("Exception while pulling the image \"" + imageName + "\". " + e.getClass().getName() + ": "
                + e.getLocalizedMessage());
    }
}
 

import com.spotify.docker.client.messages.Image; //导入依赖的package包/类
protected boolean findImageWithTag(final String id, final List<Image> images) {
    if (images != null) {
        for (Image image : images) {
            if (image.repoTags() != null) {
                for (String tag : image.repoTags()) {
                    if (tag.contains(id)) {
                        return true;
                    }
                }
            }
        }
    }
    return false;
}
 

import com.spotify.docker.client.messages.Image; //导入依赖的package包/类
@Before
public void initClient() throws Exception {
    dockerClient = DefaultDockerClient.fromEnv().build();
    // check if busybox is present
    List<Image> images = dockerClient.listImages(DockerClient.ListImagesParam.allImages());
    if (!findImageWithTag(busyboxImageName, images)) {
        dockerClient.pull(busyboxImageName);
    }
}
 

import com.spotify.docker.client.messages.Image; //导入依赖的package包/类
private boolean imageAvaliable(DockerClient dockerClient, String imageName) throws DockerException, InterruptedException {
    String imageNameWithTag = imageNameWithTag(imageName);
    List<Image> listImages = dockerClient.listImages(ListImagesParam.danglingImages(false));
    for (Image image : listImages) {
        if (image.repoTags() != null && image.repoTags().contains(imageNameWithTag)) {
            log.debug("image '{}' found", imageNameWithTag);
            return true;
        }
    }
    log.debug("image '{}' not found", imageNameWithTag);
    return false;
}
 

import com.spotify.docker.client.messages.Image; //导入依赖的package包/类
private boolean imageAvaliable(DockerClient dockerClient, String imageNameWithTag) throws DockerException, InterruptedException {
    List<Image> listImages = dockerClient.listImages(ListImagesParam.danglingImages(false));
    for (Image image : listImages) {
        if (image.repoTags() != null && image.repoTags().contains(imageNameWithTag)) {
            return true;
        }
    }
    return false;
}
 

import com.spotify.docker.client.messages.Image; //导入依赖的package包/类
@Override
public List<Image> listImages(ListImagesParam... lips) {
    throw new IllegalStateException(DISCONNECTED); 
}