golang 执行命令行

川长思鸟来 2022-09-16 04:59 397阅读 0赞

## 第一种 ##

**直接调用 Cmd 对象的 Run 函数，返回的只有成功和失败，获取不到任何输出的结果。**

package main
    
    import (
    	"log"
    	"os/exec"
    )
    
    /**
     * @author micro.cloud.fly
     * @date 2021/10/8 3:15 下午
     * @desc 直接调用 Cmd 对象的 Run 函数，返回的只有成功和失败，获取不到任何输出的结果。
    
    
     */
    func main() {
        
    	command := exec.Command("ls", "-lh", "/usr/local/log")
    	err := command.Run()
    	if err != nil {
        
    		log.Fatalf("cmd.run() failed with %s",err)
    	}
    }

执行会输出

2021/10/15 17:04:22 cmd.run() failed with exit status 1

## 第二种 ##

**有时候我们执行一个命令就是想要获取输出结果，此时你可以调用 Cmd 的 CombinedOutput 函数。**

package main
    
    import (
    	"fmt"
    	"log"
    	"os/exec"
    )
    
    /**
     * @author micro.cloud.fly
     * @date 2021/10/8 3:15 下午
     * @desc 有时候我们执行一个命令就是想要获取输出结果，此时你可以调用 Cmd 的 CombinedOutput 函数。
    
    
    
     */
    func main() {
        
    	//command := exec.Command("ls", "-lh", "/usr/local/logs/")
    	command := exec.Command("/bin/sh",  "-c"," go run /Users/java0904/goProject/demo-os-exec/demo07/main.go")
    	out,err := command.CombinedOutput()
    	if err != nil {
        
    		log.Fatalf("cmd.run() failed with %s",err)
    	}
    	fmt.Println(string(out))
    }

其中，**demo07/main.go**的内容为：

package main
    
    import "fmt"
    
    /**
     * @author micro.cloud.fly
     * @date 2021/10/15 4:34 下午
     * @desc
     */
    func main() {
        
    	for i := 0; i < 10; i++ {
        
    		fmt.Println(i)
    	}
    }

执行输出：

0
    1
    2
    3
    4
    5
    6
    7
    8
    9

## 第三种 ##

**执行命令，并区分stdout标准输出 和 stderr标准错误输出**

package main
    
    import (
    	"bytes"
    	"fmt"
    	"log"
    	"os/exec"
    )
    
    /**
     * @author micro.cloud.fly
     * @date 2021/10/8 3:22 下午
     * @desc 执行命令，并区分stdout 和 stderr
     */
    func main() {
        
    	//cmd := exec.Command("ls", "-lh", "/usr/local/logs/*.log")
    	cmd := exec.Command("/bin/sh",  "-c"," go run /Users/java0904/goProject/demo-os-exec/demo07/main.go")
    	var stdout, stderr bytes.Buffer
    	cmd.Stdout = &stdout  // 标准输出
    	cmd.Stderr = &stderr  // 标准错误
    	err := cmd.Run()
    	outStr, errStr := string(stdout.Bytes()), string(stderr.Bytes())
    	fmt.Printf("out:\n%s\nerr:\n%s\n", outStr, errStr)
    	if err != nil {
        
    		log.Fatalf("cmd.Run() failed with %s\n", err)
    	}
    }

执行输出

out:
    0
    1
    2
    3
    4
    5
    6
    7
    8
    9
    
    err:

## 第四种 ##

**有管道符的命令**

package main
    
    import (
    	"os"
    	"os/exec"
    )
    
    /**
     * @author micro.cloud.fly
     * @date 2021/10/8 3:25 下午
     * @desc 相当于执行了命令行（查看文件的行数）：grep ERROR /var/log/messages | wc -l
     */
    func main() {
        
    	c1 := exec.Command("grep", "Email", "/usr/local/logs/producer.log")
    	c2 := exec.Command("wc", "-l")
    	c2.Stdin, _ = c1.StdoutPipe()
    	c2.Stdout = os.Stdout
    	_ = c2.Start()
    	_ = c1.Run()
    	_ = c2.Wait()
    }

执行输出：

## 第五种 ##

**设置环境变量**

package main
    
    
    /**
     * @author micro.cloud.fly
     * @date 2021/10/8 3:29 下午
     * @desc
     */
    import (
    	"fmt"
    	"log"
    	"os"
    	"os/exec"
    )
    func main() {
        
    	os.Setenv("NAME", "cloud")
    	cmd := exec.Command("echo", os.ExpandEnv("$NAME"))
    	out, err := cmd.CombinedOutput()
    	if err != nil {
        
    		log.Fatalf("cmd.Run() failed with %s\n", err)
    	}
    	fmt.Printf("%s", out)
    }

执行输出：

cloud

## 第六种 ##

**进程之间的通信**

package main
    
    import (
    	"context"
    	"fmt"
    	"os/exec"
    	"time"
    )
    
    /**
     * @author micro.cloud.fly
     * @date 2021/10/15 4:44 下午
     * @desc
     */
    type Result struct {
        
    	output string
    	err error
    }
    
    func main() {
        
    
    	results := make(chan Result, 100)
    	ctc, cancelFunc := context.WithCancel(context.TODO())
    
    	go func() {
        
    		cmd := exec.CommandContext(ctc, "/bin/sh", "-c", "echo hello;sleep 2;echo world")
    		output, err := cmd.CombinedOutput()
    		result := Result{
        
    			output: string(output),
    			err:    err,
    		}
    		results<-result
    	}()
    	time.Sleep(time.Duration(1)*time.Second)
    	cancelFunc()
    	result:=<-results
    	fmt.Println(result.output,result.err.Error())
    
    }

执行输出

hello
     signal: killed