流式读取程序输出的概念是否存在？

学习知识要善于思考，思考，再思考！今天golang学习网小编就给大家带来《流式读取程序输出的概念是否存在？》，以下内容主要包含等知识点，如果你正在学习或准备学习Golang，就都不要错过本文啦~让我们一起来看看吧，能帮助到你就更好了！

我有一个 shell 命令（例如 journalctl -f -o json），它不断地将行流传输到标准输出。

我想逐行检索此输出并进一步处理。

os/exec 的文档解决了如何读取命令的输出，io 处理流缓冲。

在我看来，处理过程都经过一个固定的缓冲区，该缓冲区被读入、处理和进一步写入。我的问题是该缓冲区的大小是固定的并且与内容无关。

有没有办法逐行读取传入流（在我的例子中是 shell 命令的输出）？可能有比 io 读者更高级的库？

正确答案

使用 cmd.stdoutpipe() 获取（管道）使用 cmd.start() 启动该进程之前的输出（ start() 启动命令但不等待其完成）。

并使用 bufio.scanner 读取输入 (io.reader) 行 -逐行。

例如，我将使用这个 bash 脚本打印当前时间 3 次，并在每次之间睡眠 1 秒：

for i in {1..3}; do date; sleep 1; done

执行此命令并逐行读取其输出的示例：

cmd := exec.command("bash", "-c", "for i in {1..3}; do date; sleep 1; done")
out, err := cmd.stdoutpipe()
if err != nil {
    log.fatal(err)
}
defer out.close()

err = cmd.start()
if err != nil {
    log.fatal(err)
}

scanner := bufio.newscanner(out)
for scanner.scan() {
    line := scanner.text()
    fmt.println("output:", line)
}

示例输出：

2022/11/29 14:38:48 Output: Tue Nov 29 02:38:48 PM CET 2022
2022/11/29 14:38:49 Output: Tue Nov 29 02:38:49 PM CET 2022
2022/11/29 14:38:50 Output: Tue Nov 29 02:38:50 PM CET 2022

（每行开头的第一个日期时间来自 log 包，以验证每行在第二次延迟后打印，另一个时间戳是 date 命令的输出。）

理论要掌握，实操不能落！以上关于《流式读取程序输出的概念是否存在？》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！