假设我们需要在go中运行下面的命令:
ps -a | grep wget
这里需要写成两个exec.command,如下,第一个命令为cmd,第二个为cmd2:
cmd := exec.command("ps", "-a")
cmd2 := exec.command("grep", "wget")
然后使用管道连接二者的标准输出和标准输入,需要注意第一个命令cmd的标准输出应该使用cmd.stdoutpipe(),而不是stdout,如下(忽略了错误err和其处理):
cmd2.stdin, _ = cmd.stdoutpipe()
因为cmd.stdout是一个io.writer,是一个写入器,因为这个输出是要写入某些地方的。而同理,cmd2.stdin是一个io.reader,是一个读取器,用来读取一些地方的内容。二者直接赋值的话会出现类型不匹配的错误。所以需要使用stdoutpipe()函数,这个函数会返回一个io.reader。(这里比较绕,所以可能需要想一下)
在获取了输出之后,需要将其转换成字符串的话,可以使用bytes.buffer来获取cmd2.stdout的标准输出(记住这是个io.writer),然后再转换成字符串。
我们是是无法直接将io.writer直接写入到bytes.buffer之中的,你可能会说bytes.buffer不是有两个方法readfrom和writeto吗?
前者只能读取io.reader的,后者只能写入io.writer,所以我们需要一个管道来将io.writer转换成io.reader,然后才能读取或复制其内容。而这个转换就是再使用一次管道,如下:
var buf bytes.buffer r, w, _ := os.pipe() cmd2.stdout = w go buf.readfrom(r)
这里buf.readfrom(r)必须使用 goroutine,也就是让这个代码并行运行,所以在前面加上go。
这里的
go buf.readfrom(r)也可以使用go io.copy(&buf, r)替代,效果一样。
因为命令执行的顺序是先启动cmd2,然后运行cmd,cmd运行完之后,数据流通过管道传递给cmd2,cmd2再运行。不然cmd运行的时候的标准输出是空的,就会一直等。
buf.readfrom(r)对cmd2也是同理,不过由于这是行代码,无法使用start启动它,所以并行就行了。
接下来的命令如下:
cmd2.start() cmd.run() cmd2.wait()
这里就是前面说的流程:cmd2启动,运行cmd,让cmd2等待cmd的输出。
需要注意一点:go buf.readfrom(r)其实可以放在上面代码中,除了最后一行之外的任何地方。之所以不能放在最后是因为这时候都运行完了,再读取就是空的了。
然后将其转换成字符串:
str := buf.string()
打印看看:
fmt.println("123" + str + "123")
之所以要前后都加上"123"是为了避免调试的时候把输出到标准输出文件的内容当成这里打印的。
结果如下:
% go run main.go
12360651 ttys010 0:00.00 grep wget
123
这里分成两行是因为获取的时候grep wget后面有个\n,这里看不出来,如果%#v格式化打印就能看到了。
完整代码如下:
func main() {
cmd := exec.command("ps", "-a")
cmd2 := exec.command("grep", "wget")
cmd2.stdin, _ = cmd.stdoutpipe()
var buf bytes.buffer
r, w, _ := os.pipe()
cmd2.stdout = w
// 下面这行代码可以替换为:go io.copy(&buf, r)
go buf.readfrom(r)
cmd2.start()
cmd.run()
cmd2.wait()
str := buf.string()
fmt.println("123" + str + "123")
}
到此这篇关于go实现将io.writer转换成字符串的文章就介绍到这了,更多相关go io.writer转换成字符串内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网!
发表评论