如何處理使用命名管道的過程輸出

我正在嘗試從tmux中的運行進程建立管道，
以便逐行處理其輸出。如何處理使用命名管道的過程輸出

我看了一下this guide to pipe the output of a tmux session to stdout
和this article about (named) pipes in go。

我一直在嘗試，目前已有相當一段時間，
但仍沒有得到任何值得注意的結果。

我真的很感激任何想法如何設置管道，
理想情況下，我可以在它的範圍內逐行。

非常感謝

2017-08-20 Hendrik Evert

這裏是我發現here解決方案（謝謝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會話的輸出也沒有顯示。我希望這可以幫助任何人

來源

2017-08-20 13:21:33

如何處理使用命名管道的過程輸出

回答

相關問題