1. 準備工作
1.1 準備環(huán)境
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. 實現(xiàn)
為了實現(xiàn)可以查看后臺程序的日志, 那么需要做好兩點:
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進程后續(xù)會被用戶程序覆蓋)
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]---環(huán)境說明
2. [mydocker]---urfave cli 理解
3. [mydocker]---Linux Namespace
4. [mydocker]---Linux Cgroup
5. [mydocker]---構造容器01-實現(xiàn)run命令
6. [mydocker]---構造容器02-實現(xiàn)資源限制01
7. [mydocker]---構造容器02-實現(xiàn)資源限制02
8. [mydocker]---構造容器03-實現(xiàn)增加管道
9. [mydocker]---通過例子理解存儲驅動AUFS
10. [mydocker]---通過例子理解chroot 和 pivot_root
11. [mydocker]---一步步實現(xiàn)使用busybox創(chuàng)建容器
12. [mydocker]---一步步實現(xiàn)使用AUFS包裝busybox
13. [mydocker]---一步步實現(xiàn)volume操作
14. [mydocker]---實現(xiàn)保存鏡像
15. [mydocker]---實現(xiàn)容器的后臺運行
16. [mydocker]---實現(xiàn)查看運行中容器
17. [mydocker]---實現(xiàn)查看容器日志
18. [mydocker]---實現(xiàn)進入容器Namespace
19. [mydocker]---實現(xiàn)停止容器
20. [mydocker]---實現(xiàn)刪除容器
21. [mydocker]---實現(xiàn)容器層隔離
22. [mydocker]---實現(xiàn)通過容器制作鏡像
23. [mydocker]---實現(xiàn)cp操作
24. [mydocker]---實現(xiàn)容器指定環(huán)境變量
25. [mydocker]---網際協(xié)議IP
26. [mydocker]---網絡虛擬設備veth bridge iptables
27. [mydocker]---docker的四種網絡模型與原理實現(xiàn)(1)
28. [mydocker]---docker的四種網絡模型與原理實現(xiàn)(2)
29. [mydocker]---容器地址分配
30. [mydocker]---網絡net/netlink api 使用解析
31. [mydocker]---網絡實現(xiàn)
32. [mydocker]---網絡實現(xiàn)測試


