测试 docker engine 需要构建包含核心守护进程、api 接口及 cli 交互的集成测试套件，通常基于 go 语言编写并挂载临时数据目录进行隔离验证。具体做法是启动一个干净的 docker daemon 实例，通过 http api 发送请求来模拟容器生命周期操作，如创建、启动和停止容器，同时检查返回状态码与日志输出是否符合预期。若涉及网络或存储驱动测试，需确保宿主机环境已正确配置相应模块，否则测试将因依赖缺失而失败。
如何启动用于测试的独立 Docker Daemon
启动独立 Daemon 的核心在于使用 dockerd 命令并指定 --storage-driver 和 --data-root 参数以隔离环境。开发者应调用 exec.Command 在后台运行该进程，并通过 --host 参数暴露 Unix Socket 供后续 API 请求连接。这样做能避免干扰宿主机的现有容器服务，确保测试环境的纯净性。若未指定 --storage-driver，Daemon 可能默认使用宿主机的驱动，导致跨平台测试失效。
package main
import (
"fmt"
"os"
"os/exec"
"path/filepath"
"time"
)
func startTestDaemon() (*exec.Cmd, error) {
// 创建临时目录作为数据根
tmpDir, err := os.MkdirTemp("", "docker-test-")
if err != nil {
return nil, err
}
// 构建 dockerd 命令
cmd := exec.Command("dockerd",
"--storage-driver=vfs", // 使用 vfs 驱动简化测试
"--data-root="+tmpDir,
"--host=unix:///var/run/docker-test.sock",
"--log-level=fatal", // 减少日志噪音
)
// 重定向输出以便调试
cmd.Stdout = os.Stdout
cmd.Stderr = os.Stderr
if err := cmd.Start(); err != nil {
return nil, err
}
// 等待 Daemon 就绪
time.Sleep(2 * time.Second)
return cmd, nil
}
func main() {
cmd, err := startTestDaemon()
if err != nil {
fmt.Println("Failed to start daemon:", err)
return
}
defer cmd.Process.Kill()
fmt.Println("Daemon started successfully")
}
上述代码展示了如何通过 Go 标准库启动一个使用 VFS 存储驱动的独立 Docker 守护进程。运行该程序后，会在系统临时目录下生成一个专属的数据根目录，并通过 Unix Socket 提供服务。开发者可通过 curl --unix-socket /var/run/docker-test.sock http://localhost/images/json 验证服务是否就绪。此方法确保了每次测试都从干净的状态开始，避免了残留容器对测试结果的影响。
Docker Hub (hub.docker.com)。此技能适用于所有 Docker Hub 操作，包括读取、创建、更新和删除数据。只要任务涉及 Docker Hub，就使用此技能。
如何通过 HTTP API 验证容器创建流程
验证容器创建流程需向 Daemon 的 /containers/create 端点发送 POST 请求，并携带有效的镜像 ID 和配置 JSON。开发者应构造包含 Image、Cmd 和 HostConfig 字段的请求体，随后解析响应中的 ID 字段以获取新容器的标识符。若镜像不存在或配置格式错误，API 将返回 404 或 400 状态码，此时需捕获异常并进行断言。正确的配置传递是确保容器按预期启动的关键条件。
package main
import (
"bytes"
"encoding/json"
"fmt"
"io/ioutil"
"net/http"
)
type ContainerCreateRequest struct {
Image string `json:"Image"`
Cmd []string `json:"Cmd"`
HostConfig map[string]interface{} `json:"HostConfig"`
}
func createContainer(socketPath string, image string) (string, error) {
client := &http.Client{}
reqBody := ContainerCreateRequest{
Image: image,
Cmd: []string{"echo", "hello"},
HostConfig: map[string]interface{}{},
}
jsonData, _ := json.Marshal(reqBody)
req, _ := http.NewRequest("POST", "/containers/create", bytes.NewBuffer(jsonData))
// 使用 Unix Socket 传输
transport := &http.Transport{Dial: func(network, addr string) (conn net.Conn, err error) {
return net.Dial("unix", socketPath)
}}
client.Transport = transport
resp, err := client.Do(req)
if err != nil {
return "", err
}
defer resp.Body.Close()
body, _ := ioutil.ReadAll(resp.Body)
if resp.StatusCode != 201 {
return "", fmt.Errorf("API Error: %s", string(body))
}
var result map[string]string
json.Unmarshal(body, &result)
return result["Id"], nil
}
func main() {
id, err := createContainer("/var/run/docker-test.sock", "alpine:latest")
if err != nil {
fmt.Println("Error:", err)
return
}
fmt.Printf("Created container ID: %s\n", id)
}
该代码片段演示了如何通过自定义 Transport 使用 Unix Socket 与 Docker Daemon 通信，并调用 /containers/create 接口。请求体中明确指定了 alpine:latest 镜像和简单的 echo 命令。执行成功后，函数返回新生成容器的 ID。开发者可利用此 ID 进一步调用 /containers/{id}/start 启动容器，并通过 /containers/{id}/logs 获取执行结果。这种基于 HTTP API 的测试方式能够精确控制每一步的状态变更，适合自动化测试场景。
当 HostConfig 缺少 Binds 时卷挂载行为如何表现
当 HostConfig 中未设置 Binds 字段时，Docker Engine 不会自动创建任何持久化卷，容器内的文件系统更改仅在容器生命周期内有效。这意味着如果测试用例期望验证数据持久化，必须显式提供 Binds 或 Mounts 配置。若仅依赖默认行为，容器删除后所有写入数据将丢失，导致持久化相关的断言失败。因此，在涉及文件 I/O 的测试中，必须明确注入绑定路径以确保可重现的结果。
