1. 准备工作

1.1 准备环境

root@nicktming:~/go/src/github.com/nicktming/mydocker# git clone https://github.com/nicktming/mydocker.git
root@nicktming:~/go/src/github.com/nicktming/mydocker# git checkout code-4.4
root@nicktming:~/go/src/github.com/nicktming/mydocker# git checkout -b dev-5.1

1.2 准备busybox.tar

// 前提条件
root@nicktming:/nicktming# pwd
/nicktming
root@nicktming:/nicktming# ls
busybox.tar

1.3 预期效果

root@nicktming:~/go/src/github.com/nicktming/mydocker# git clone https://github.com/nicktming/mydocker.git
root@nicktming:~/go/src/github.com/nicktming/mydocker# git checkout code-5.3
root@nicktming:~/go/src/github.com/nicktming/mydocker# go build .
root@nicktming:~/go/src/github.com/nicktming/mydocker# ./mydocker run -d /bin/top
2019/04/12 21:35:51 rootPath:
2019/04/12 21:35:51 rootPath is empaty, set cmd.Dir by default: /nicktming/mnt
2019/04/12 21:35:51 mkdir /nicktming/writerLayer err:mkdir /nicktming/writerLayer: file exists
2019/04/12 21:35:51 containerId:15550761518017354161
2019/04/12 21:35:51 jsonInfo:{"pid":"11447","id":"15550761518017354161","name":"15550761518017354161","command":"/bin/top","createTime":"2019-04-12 21:35:51","status":"running"}
2019/04/12 21:35:51 mount -f /nicktming/mnt, err:exit status 1
root@nicktming:~/go/src/github.com/nicktming/mydocker# ./mydocker ps
ID                     NAME                   PID         STATUS      COMMAND     CREATED
15550761518017354161   15550761518017354161   11447       running     /bin/top    2019-04-12 21:35:51
root@nicktming:~/go/src/github.com/nicktming/mydocker# ./mydocker logs 15550761518017354161

Mem: 881648K used, 136164K free, 400K shrd, 110080K buff, 558300K cached
CPU:  0.0% usr  0.0% sys  0.0% nic  100% idle  0.0% io  0.0% irq  0.0% sirq
Load average: 0.02 0.04 0.05 1/102 3
  PID  PPID USER     STAT   VSZ %VSZ CPU %CPU COMMAND
    1     0 root     R     1280  0.1   0  0.0 /bin/top

2. 实现

为了实现可以查看后台程序的日志, 那么需要做好两点:

1. 将后台程序日志持久化到文件中.
2. 查看容器日志时读取文件内容显示.

2.1 将后台程序日志持久化到文件中

如果容器是后台运行, 就需要把标准输出重定向到某一个文件中.

在command/utils.go中加入变量:

var (
    ...
    CONTAINERLOGS    = "container.log"
)

在command/utils.go中增加如下方法:

func GetLogFile(containerName string) (*os.File, error) {
    path := fmt.Sprintf(INFOLOCATION, containerName)
    logFile := path + "/" + CONTAINERLOGS
    if err := os.MkdirAll(path, 0622); err != nil {
        return nil, fmt.Errorf("create %s error : %v\n", path, err)
    }
    if file , err := os.Create(logFile); err != nil {
        return nil, fmt.Errorf("os.Create(%s) error : %v\n", path, err)
    } else {
        return file, nil
    }
}

func ReadLogs(containerName string) string {
    path := fmt.Sprintf(INFOLOCATION, containerName)
    logFile := path + "/" + CONTAINERLOGS
    data, _ := ioutil.ReadFile(logFile)
    return string(data)
}

在command/run.go中的Run方法修改如下:

func Run(command string, tty bool, cg *cgroups.CroupManger, rootPath string, volumes []string, containerName string)  {
    ...

    id := ContainerUUID()
    if containerName == "" {
        containerName = id
    }
    if tty {
        cmd.Stderr = os.Stderr
        cmd.Stdout = os.Stdout
        cmd.Stdin = os.Stdin
    } else {
        logFile, err := GetLogFile(containerName)
        if err != nil {
            fmt.Errorf("GetLogFile error:%v\n", err)
            return
        }
        cmd.Stdout = logFile
    }
    /**
     *   Start() will not block, so it needs to use Wait()
     *   Run() will block
     */
    if err := cmd.Start(); err != nil {
        log.Printf("Run Start err: %v.\n", err)
        log.Fatal(err)
    }

    ...

    RecordContainerInfo(strconv.Itoa(cmd.Process.Pid), containerName, id, command)

    // false 表明父进程(Run程序)无须等待子进程(Init程序,Init进程后续会被用户程序覆盖)
    if tty {
        cmd.Wait()
        DeleteContainerInfo(containerName)
    }
}

2.2 增加logs命令

func main()  {
    ...
    app.Commands = []cli.Command{
        ...
        command.LogCommand,
    }
    ...
}

增加Logs命令

var LogCommand = cli.Command{
    Name: "logs",
    Action: func(c *cli.Context) error {
        containerName := c.Args().Get(0)
        Logs(containerName)
        return nil
    },
}

增加command/logs.go

func Logs(containerName string) {
    data := ReadLogs(containerName)
    fmt.Println(data)
}

2.3 测试

测试如下:

------------------------------------terminal 01-----------------------------------------------------
root@nicktming:~/go/src/github.com/nicktming/mydocker# go build .
root@nicktming:~/go/src/github.com/nicktming/mydocker# ./mydocker run -d -name test /bin/top
2019/04/12 19:55:46 rootPath:
2019/04/12 19:55:46 rootPath is empaty, set cmd.Dir by default: /nicktming/mnt
2019/04/12 19:55:46 containerId:15550701463180420741
2019/04/12 19:55:46 jsonInfo:{"pid":"2440","id":"15550701463180420741","name":"test","command":"/bin/top","createTime":"2019-04-12 19:55:46","status":"running"}
2019/04/12 19:55:46 remove /nicktming/writerLayer, err:remove /nicktming/writerLayer: device or resource busy
root@nicktming:~/go/src/github.com/nicktming/mydocker# 
root@nicktming:~/go/src/github.com/nicktming/mydocker# 
root@nicktming:~/go/src/github.com/nicktming/mydocker# ./mydocker ps
ID                     NAME        PID         STATUS      COMMAND     CREATED
15550701463180420741   test        2440        running     /bin/top    2019-04-12 19:55:46
root@nicktming:~/go/src/github.com/nicktming/mydocker# ./mydocker logs test
Mem: 887176K used, 130636K free, 408K shrd, 108584K buff, 571360K cached
CPU:  0.6% usr  0.6% sys  0.0% nic 98.6% idle  0.2% io  0.0% irq  0.0% sirq
Load average: 0.00 0.01 0.05 2/98 3
  PID  PPID USER     STAT   VSZ %VSZ CPU %CPU COMMAND
    1     0 root     R     1280  0.1   0  0.0 /bin/top
------------------------------------terminal 02-----------------------------------------------------
root@nicktming:/var/run/mydocker# pwd
/var/run/mydocker
root@nicktming:/var/run/mydocker# ls
test
root@nicktming:/var/run/mydocker# tree test
test
|-- config.json
`-- container.log

0 directories, 2 files
root@nicktming:/var/run/mydocker# cat test/container.log 
Mem: 888184K used, 129628K free, 400K shrd, 108568K buff, 571360K cached
CPU: 10.0% usr  0.0% sys  0.0% nic 80.0% idle 10.0% io  0.0% irq  0.0% sirq
Load average: 0.00 0.01 0.05 2/99 3
  PID  PPID USER     STAT   VSZ %VSZ CPU %CPU COMMAND
    1     0 root     R     1280  0.1   0  0.0 /bin/top

3. 时序图

logs.png

logs-1.png

4. 参考

1. 自己动手写docker.(基本参考此书,加入一些自己的理解,加深对docker的理解)

5. 全部内容

mydocker.png

1. [mydocker]---环境说明
2. [mydocker]---urfave cli 理解
3. [mydocker]---Linux Namespace
4. [mydocker]---Linux Cgroup
5. [mydocker]---构造容器01-实现run命令
6. [mydocker]---构造容器02-实现资源限制01
7. [mydocker]---构造容器02-实现资源限制02
8. [mydocker]---构造容器03-实现增加管道
9. [mydocker]---通过例子理解存储驱动AUFS
10. [mydocker]---通过例子理解chroot 和 pivot_root
11. [mydocker]---一步步实现使用busybox创建容器
12. [mydocker]---一步步实现使用AUFS包装busybox
13. [mydocker]---一步步实现volume操作
14. [mydocker]---实现保存镜像
15. [mydocker]---实现容器的后台运行
16. [mydocker]---实现查看运行中容器
17. [mydocker]---实现查看容器日志
18. [mydocker]---实现进入容器Namespace
19. [mydocker]---实现停止容器
20. [mydocker]---实现删除容器
21. [mydocker]---实现容器层隔离
22. [mydocker]---实现通过容器制作镜像
23. [mydocker]---实现cp操作
24. [mydocker]---实现容器指定环境变量
25. [mydocker]---网际协议IP
26. [mydocker]---网络虚拟设备veth bridge iptables
27. [mydocker]---docker的四种网络模型与原理实现(1)
28. [mydocker]---docker的四种网络模型与原理实现(2)
29. [mydocker]---容器地址分配
30. [mydocker]---网络net/netlink api 使用解析
31. [mydocker]---网络实现
32. [mydocker]---网络实现测试