程序VS命令

  • 执行程序： /usr/bin/python xxx.py
  • 调用命令: cat nginx.log | grep “something”

命令解释器bash

  • 交互模式: ls -al
  • 非交互模式: /bin/bash -c “ls -al”

/bin/bash -c “命令”

任务执行原理

  • 提交任务->创建管道->fork子进程->重定向输出->exec执行/bin/bash程序->输出到管道
  • pipe(): 创建2个文件描述符, fd[0]可读, fd[1]可写
  • fork(): 创建子进程, fd[1]被继承到子进程
  • dup2(): 重定向子进程stdout/stderr到fd[1]
  • exec(): 在当前进程内, 加载并执行二进制程序

执行命令, 捕获了子进程的输出(pipe)

  1. func main() {
  2.     // 生成cmd
  3.     cmd := exec.Command("/bin/bash", "-c", "sleep 5; ls -al")
  5.     // 执行命令, 捕获了子进程的输出(pipe)
  6.     if output, err := cmd.CombinedOutput(); err != nil {
  7.         fmt.Println(err)
  8.         return
  9.     } else {
  10.         // 打印子进程的输出
  11.         fmt.Println(string(output))
  12.     }
  13. }

执行cmd, 杀死

  2. type result struct {
  3.     err    error
  4.     output []byte
  5. }
  7. func main() {
  9.     ctx, cancelFunc := context.WithCancel(context.TODO())
  11.     // 创建了一个结果队列
  12.     resultChan := make(chan *result, 1000)
  14.     go func() {
  15.         cmd := exec.CommandContext(ctx, "/bin/bash", "-c", "sleep 2; echo hello;")
  16.         // 执行任务, 捕获输出
  17.         output, err := cmd.CombinedOutput()
  19.         // 把任务输出结果, 传给main协程
  20.         resultChan <- &result{
  21.             err:    err,
  22.             output: output,
  23.         }
  24.     }()
  26.     time.Sleep(1 * time.Second)
  28.     // 取消上下文
  29.     cancelFunc()
  31.     // 在main协程里, 等待子协程的退出，并打印任务执行结果
  32.     res := <-resultChan
  34.     // 打印任务执行结果
  35.     fmt.Println(res.err, string(res.output))
  36. }