在命名管道中写入数据，实现 echo 的功能

在 Go 中使用命名管道实现 echo 功能时，用户遇到了写入管道失败的问题。虽然 echo 命令可以正常工作，但在 Go 中使用 `w.write()` 函数写入管道却无法获得响应。经过分析，发现问题出在缺少对写入缓冲区的刷新操作。

我正在尝试以从属模式运行 mplayer，并在 go 中控制它。命名管道用于获取位置、查找等。由于某种原因，echo 命令可以工作，但在 go 中写入会失败。

package main

import (
    "os"
    "fmt"
    "time"
    "syscall"
    "bufio"
    "os/exec"
    . "csystem"
)

func main() {
    namedpipe := "pipe"
    syscall.mkfifo(namedpipe, 0666)
    player := "/usr/bin/mplayer";
    playfile := os.args[1]
    cmd := exec.command(player,"-vo","null","-slave","-quiet",
            "-input","file="+namedpipe,playfile)
    stdout,_ := cmd.stdoutpipe()
    cmd.start()
    go func () {
        // file, err := os.openfile(namedpipe, os.o_rdwr, os.modenamedpipe)
        file, err := os.openfile(namedpipe, os.o_rdwr|os.o_create|os.o_append, 0777)
        if err != nil {
            fmt.println(err)
            return
        }
        fmt.println("pipe is open")
        defer file.close()
        w := bufio.newwriter(file)
        optiona := false
        optionb := true
        for ;; {
            time.sleep(time.second)
            if optiona {
                system("echo \"get_time_pos\" > "+namedpipe)
            }
            if optionb {
                n,err := w.write([]byte("get_time_pos\n"))
                if err != nil {
                    fmt.println(err)
                    return
                } else {
                    fmt.println("write pipe ",n)
                }
            }
        }
    } ()
    defer cmd.wait()
    scanner := bufio.newscanner(stdout)
    for scanner.scan() {
        text := scanner.text()
        fmt.println(text)
    }
}

选项a： 我得到标准输出输出，echo 命令给我响应 ans_time_position=0.9

./mplayergo file.flac
pipe is open
mplayer 1.3.0 (debian), built with gcc-9 (c) 2000-2016 mplayer team

playing file.flac.
libavformat version 58.29.100 (external)
audio only file format detected.
==========================================================================
opening audio decoder: [ffmpeg] ffmpeg/libavcodec audio decoders
libavcodec version 58.54.100 (external)
audio: 192000 hz, 2 ch, s32le, 5497.4 kbit/44.74% (ratio: 687172->1536000)
selected audio codec: [ffflac] afm: ffmpeg (ffmpeg flac audio)
==========================================================================
ao: [pulse] 192000hz 2ch s32le (4 bytes per sample)
video: no video
starting playback...
ans_time_position=0.9
ans_time_position=1.8

选项b： 没有发生错误，管道已打开并且写入已成功处理，但没有响应。

./mplayergo file.flac
pipe is open
MPlayer 1.3.0 (Debian), built with gcc-9 (C) 2000-2016 MPlayer Team

Playing file.flac.
libavformat version 58.29.100 (external)
Audio only file format detected.
==========================================================================
Opening audio decoder: [ffmpeg] FFmpeg/libavcodec audio decoders
libavcodec version 58.54.100 (external)
AUDIO: 192000 Hz, 2 ch, s32le, 5497.4 kbit/44.74% (ratio: 687172->1536000)
Selected audio codec: [ffflac] afm: ffmpeg (FFmpeg FLAC audio)
==========================================================================
AO: [pulse] 192000Hz 2ch s32le (4 bytes per sample)
Video: no video
Starting playback...
write pipe  13
write pipe  13

为什么选项 b 不起作用？我错过了什么？

解决方案

@volker 的评论解决了这个问题。 写入后缺少w.flush()。

我不需要缓冲区，所以

io.WriteString(file,"get_time_pos\n")

是更好的解决方案。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~