正在从cmd读取.标准输出管道()

Question

请考虑这个Go代码：

package main
import (
"fmt"
"os/exec"
"strings"
"time"
)
const (
debugCmd = "/usr/bin/libinput debug-events"
//debugCmd = "tail -f /tmp/syslog"
)
func main() {
fmt.Println("Hello!")
fmt.Println("cmd", debugCmd)
cmdSplat := strings.Split(debugCmd, " ")
cmd := exec.Command(cmdSplat[0], cmdSplat[1:]...)
stdOut, err := cmd.StdoutPipe()
if err != nil {
fmt.Println("cmd.StdOut failed", err)
}
defer stdOut.Close()
go func() {
tempBuf := make([]byte, 1024)
for {
n, err := stdOut.Read(tempBuf)
if n > 0 {
fmt.Printf("Read: %d bytes, err: %vn", n, err)
someSlice := tempBuf[:n]
fmt.Println("text", string(someSlice))
} else {
fmt.Printf("Zero Read :%d, err: %v", n, err)
}
}
}()
fmt.Println("STarting cmd")
err = cmd.Start()
if err != nil {
fmt.Println("cmd.start", err)
}
fmt.Println("All done!")
// cmd.Wait()
time.Sleep(60 * time.Second)
fmt.Println("Done sleeping!")
}

在现实生活中，它只有在读取1024个字节后才会拾取。早些时候，我用bufio做了这个，但速度也很慢：

go func() {
r := bufio.NewReader(stdOut)
for {
line, err := r.ReadString('n')
if err != nil {
fmt.Println("End of things!")
break
}
fmt.Print(line)
}
}()

我的目标是以相当快的速度从stdOut io.ReadCloser中提取debug-events，而不是使用1024字节的水印进行批量处理。

这是我的输出：

Read: 1024 bytes, err: <nil> // <------------ this 
text finger)
event5   POINTER_AXIS     +2.380s  vert -11.14/0* horiz 10.75/0* (finger)
event5   POINTER_AXIS     +2.400s  vert -8.97/0* horiz 6.54/0* (finger)
<snip>
event5   POINTER_AXIS     +3.219s  vert 7.42/0* horiz 0.00/0 (finger)
event5   POINTER_AXIS 
Read: 1024 bytes, err: <nil> // <-------------- this 
text     +3.238s    vert 9.28/0* horiz -15.89/0* (finger)
event5   POINTER_AXIS     +3.257s  vert 8.66/0* horiz -17.29/0* (finger)
event5   POINTER_AXIS     +3.277s  vert 7.42/0* horiz -11.69/0* (finger) 
<snip>
event5   POINTER_AXIS     +3.491s  vert 0.00/0* horiz 0.00/0* (finger)
event5   POINTER_MOTION   +3
Read: 1024 bytes, err: <nil>
text .980s   -0.23/ -0.90 ( -1.00/ -3.97)

你能给我指正确的路吗？

Answer 1

正如评论中所讨论的，这根本不是Go问题，而只是需要在GNU/Linux系统上使用stdbuf命令。另请参阅此unix.stackexchange.com问答。一般的想法是确保使用exec.Command运行的程序不会不适当地缓冲自己的输出。

(stdbuf程序通常使用LD_PRELOAD为stdin、stdout和stderr插入可选的I/O缓冲，也可以内置到操作系统上的标准库中。(