os/exec包可用于调用外部命令,可以使用管道连接输入输出,并支持阻塞与非阻塞方式执行命令。
os/exec包中关键的类型为Cmd,以下介绍的所有方法皆服务于该类型:
func Command(name string, arg ...string) *Cmd
方法返回一个*Cmd, 用于执行name指定的程序(携带arg参数)
func (c *Cmd) Run() error
执行Cmd中包含的命令,阻塞直到命令执行完成
func (c *Cmd) Start() error
执行Cmd中包含的命令,该方法立即返回,并不等待命令执行完成
func (c *Cmd) Wait() error
该方法会阻塞直到Cmd中的命令执行完成,但该命令必须是被Start方法开始执行的
func (c *Cmd) Output() ([]byte, error)
执行Cmd中包含的命令,并返回标准输出的切片
func (c *Cmd) CombinedOutput() ([]byte, error)
执行Cmd中包含的命令,并返回标准输出与标准错误合并后的切片
func (c *Cmd) StdinPipe() (io.WriteCloser, error)
返回一个管道,该管道会在Cmd中的命令被启动后连接到其标准输入
func (c *Cmd) StdoutPipe() (io.ReadCloser, error)
返回一个管道,该管道会在Cmd中的命令被启动后连接到其标准输出
func (c *Cmd) StderrPipe() (io.ReadCloser, error)
返回一个管道,该管道会在Cmd中的命令被启动后连接到其标准错误
普通调用示例:
调用Shell命令或可执行文件
演示在当前目录创建一个空文件
package main import ( "fmt" "os/exec" ) func main(){ cmd := exec.Command("touch", "test_file") err := cmd.Run() if err != nil { fmt.Println("Execute Command failed:" + err.Error()) return } fmt.Println("Execute Command finished.") }
一般不建议使用这种默认方式调用Shell脚本:
cmd := exec.Command("my_shell.sh")
因为这种方式实际的执行结果和命令行执行#sh my_shell.sh一样,如果你的Shell脚本不满足sh的规范,就会调用失败。
调用Shell脚本
设置bash来调用指定Shell脚本,dir_size.sh为我们测试用的Shell脚本。调用完成后打印Shell脚本的标准输出到控制台。
package main import ( "fmt" "os/exec" ) func main(){ command := `./dir_size.sh .` cmd := exec.Command("/bin/bash", "-c", command) output, err := cmd.Output() if err != nil { fmt.Printf("Execute Shell:%s failed with error:%s", command, err.Error()) return } fmt.Printf("Execute Shell:%s finished with output:\n%s", command, string(output)) }
dir_size.sh示例文件内容如下,用于输出当前目录的大小:
#!/bin/bash du -h --max-depth=1 $1
Go程序运行结果:
[root@localhost opt]# ll total 2120 -rwx------. 1 root root 36 Jan 22 16:37 dir_size.sh -rwx------. 1 root root 2152467 Jan 22 16:39 execCommand drwxrwxr-x. 11 1000 1000 4096 Jul 12 2017 kibana drwx------. 2 root root 4096 Jan 16 10:45 sftpuser drwx------. 3 root root 4096 Jan 22 16:41 upload [root@localhost opt]# ./execCommand Execute Shell:./dir_size.sh . finished with output: 4.0K ./sftpuser 181M ./kibana 1.1G ./upload 1.2G .
使用输入输出Pipe
演示使用管道连接到grep命令的标准输入,过滤包含test的字符串,并使用管道连接标准输出,打印运行结果:
package main import ( "fmt" "io/ioutil" "os/exec" ) func main(){ cmd := exec.Command("/bin/bash", "-c", "grep test") stdin, _ := cmd.StdinPipe() stdout, _ := cmd.StdoutPipe() if err := cmd.Start(); err != nil{ fmt.Println("Execute failed when Start:" + err.Error()) return } stdin.Write([]byte("go text for grep\n")) stdin.Write([]byte("go test text for grep\n")) stdin.Close() out_bytes, _ := ioutil.ReadAll(stdout) stdout.Close() if err := cmd.Wait(); err != nil { fmt.Println("Execute failed when Wait:" + err.Error()) return } fmt.Println("Execute finished:" + string(out_bytes)) }
Go程序运行结果:
[root@localhost ~]# ./execCommand
Execute finished:go test text for grep
阻塞/非阻塞方式调用
文章开头方法介绍处已经介绍的很清楚,且前面示例都有涉及,就不另行说明了。
参考文档:
GoLang标准库文档
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
- 群星.2006-失而复得2辑【新艺宝】【WAV+CUE】
- 《张震岳6CD合集》1993-2000全套[WAV+CUE][3.1G]
- 周华健《粤语精选+国语精选》日本母带 [WAV+CUE][1.2G]
- 《陈楚生6CD合集》[WAV+CUE][2.2G]
- dnf经验胶囊快速获得
- dnf结婚地下城入场材料怎么获得
- dnf结婚戒指属性和婚房属性
- FlorianNoack-IWannaBeLikeYou(2024)【Hi-Res】24bit-96kHz【flac】
- 张国荣.1995-狂恋·国语经典【新艺宝】【WAV+CUE】
- 佛教音乐.2012-《藏传密咒精选集》[FLAC+CUE]
- 微软在Win11中加入内置广告:宣传XGP服务
- 《地狱之刃2》官方:游戏中美景都是取材于真实地点
- 对漫威太失望!叉骨叔确认加盟DC《和平使者》第2季
- 李克勤.1998-寻最这五年2CD【艺能动音】【WAV+CUE】
- 彭莉.1995-感谢你的爱【宝丽金】【WAV+CUE】