如何使用命名管道处理进程输出

Question

我正在尝试从 tmux 中的运行进程设置管道，
为了逐行处理它的输出。

我看过this guide to pipe the output of a tmux session to stdout
和 this article about (named) pipes in go.

我已经尝试了很长一段时间，
但仍然没有得到任何值得注意的结果。

如果有任何关于如何设置该管道的想法，我将不胜感激，
理想情况下，我可以按行对其进行范围调整。

非常感谢

Answer 1

这是我找到的解决方案 here (thank you Malcolm)

func Readln(r *bufio.Reader) (string, error) {
    var (
        isPrefix = true
        err      error
        line, ln []byte
    )
    for isPrefix && err == nil {
        line, isPrefix, err = r.ReadLine()
        ln = append(ln, line...)
    }
    return string(ln), err
}

func handle(s string) {
    //Do something with your string
}

func main() {
    c := exec.Command("sh", "./tmuxpipe.sh")
    err := c.Run()
    if err != nil {
        log.Fatal(err)
    }

    f, err := os.Open("/tmp/tmuxpipe")
    if err != nil {
        fmt.Printf("error opening file: %v\n", err)
        os.Exit(1)
    }
    r := bufio.NewReader(f)
    s, e := Readln(r)
    for e == nil {
        handle(s)
        log.Println(s)
        s, e = Readln(r)
    }
}

这里是 tmuxpipe.sh:

mkfifo /tmp/tmuxpipe
tmux pipe-pane -o -t tmuxSession 'cat >> /tmp/tmuxpipe'

我之所以没有在那里使用 exec.Command()，是因为出于某种我无法理解的原因：

c := exec.Command("tmux", "pipe-pane", "-o", "-t", "tmuxSession", 'cat >> /tmp/tmuxpipe'") 
err := c.Run()
handleError(err)

没有用（对我来说）。没有发生错误，但也没有显示 tmux 会话的输出。

希望对大家有所帮助

如何使用命名管道处理进程输出

how to handle process output in go using named pipe

go

named-pipes

tmux

mkfifo