go - 从 cmd.StdoutPipe() 读取

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: %v\n", 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)

    }
}()

我的目标是取货 debug-events来自 stdOut io.ReadCloser相当快 - 当它们发生和出现时 - 而不是带有 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 问题，而只是需要使用 the stdbuf command在 GNU/Linux 系统上。另见 this unix.stackexchange.com question and answer .一般的想法是确保您使用 exec.Command 运行的程序不会不恰本地缓冲自己的输出。
(stdbuf 程序通常使用 LD_PRELOAD 为 stdin、stdout 和 stderr 插入备用 I/O 缓冲，或者可以内置到操作系统的标准库中。)