go - Libcontainer - 在容器中运行多个进程

Question

我正在尝试使用 libcontainer 实现 docker run 和 docker exec 的效果。

我已经能够使用以下代码创建一个容器并在其中运行一个进程:

func Run(id string, s *specs.LinuxSpec, f *Factory) (int, error) {
    ...
    container, err := f.CreateContainer(id, config)
    if err != nil {
        return -1, err
    }

    process := newProcess(s.Process)
    tty, err := newTty(s.Process.Terminal, process, rootuid)
    defer tty.Close()
    if err != nil {
        return -1, err
    }

    defer func() {
        if derr := Destroy(container); derr != nil {
            err = derr
        }
    }()

    handler := NewSignalHandler(tty)
    defer handler.Close()
    if err := container.Start(process); err != nil {
        return -1, err
    }

    return handler.forward(process)
}

这很好用(我相信)，但是当我必须在同一个容器中运行另一个进程时，问题就来了。例如，一个容器已经在运行(主进程在前台模式下运行):如何实现 Docker 允许您使用 docker exec 执行的操作？

我有以下代码:

func Exec(container libcontainer.Container, process *libcontainer.Process, onData func(data []byte), onErr func(err error)) (int, error) {
    reader, writer := io.Pipe()
    process.Stdin = os.Stdin

    rootuid, err := container.Config().HostUID()
    if err != nil {
        return -1, err
    }

    tty, err := newTty(true, process, rootuid)
    defer tty.Close()
    if err != nil {
        return -1, err
    }

    handler := NewSignalHandler(tty)
    defer handler.Close()

    // Redirect process output
    process.Stdout = writer
    process.Stderr = writer

    // Todo: Fix this, it waits for the main process to exit before it starts
    if err := container.Start(process); err != nil {
        return -1, err
    }

    go func(reader io.Reader) {
        scanner := bufio.NewScanner(reader)
        for scanner.Scan() {
            onData(scanner.Bytes())
        }
        if err := scanner.Err(); err != nil {
            onErr(err)
        }
    }(reader)

    return handler.forward(process)
}

这也行，但问题是:它在运行之前等待主进程退出。有时它会运行，但在运行一个简单的 whoami 命令调用该函数 5 到 7 次后，我的内存力达到了 100%。

我很确定我做错了什么，我只是不知道是什么。还是我对容器的理解让我失望了？

我用这个项目作为引用: https://github.com/opencontainers/runc

Answer 1

使用 docker 作为您案例的引用可能更好，因为它使用相同的 libcontainer.Container 对象来启动和执行容器中的新进程。您可以在此处找到与 libcontainer 交互的代码: https://github.com/docker/docker/tree/master/daemon/execdriver/native

另外，最好发布完整的代码，这样人们可以尝试调试它来帮助您。

编辑:以下是运行多个容器的示例代码:https://gist.github.com/anonymous/407eb530c0cb6c87ec9f

我是这样运行的

go run procs.go path-to-busybox

用ps可以看到容器中确实有多个进程。如果您有任何问题，请随时提出。