帶有 O_RDONLY 的 os.OpenFile 掛在沒有編寫器的命名管道上

php小編香蕉為您介紹一種特殊的操作方式，即使用帶有 O_RDONLY 的 os.OpenFile 函數在沒有編寫器的命名管道上進行掛載。這種操作方式可以實現對命名管道的讀取操作，讓您能夠在不使用編寫器的情況下，輕鬆取得命名管道中的資料資訊。這項技巧簡單易懂，操作方便，是開發者在處理命名管道時的絕佳選擇。接下來，我們將為您詳細介紹如何使用此方法來實現命名管道的讀取操作。

問題內容

我正在編寫一個守護進程，它應該從臨時 cli 命令接收通知，並選擇透過 unix 命名管道來執行此操作。我編寫了一個簡短的包，一方面生成一個單獨的 goroutine 以從節點讀取並將收到的通知發送到通道（帶有單元測試的遊樂場）：

type Writer struct {
    f *os.File
}

func NewWriter(ipc string) (*Writer, error) {
    f, err := os.OpenFile(ipc, os.O_WRONLY, 0600)

    if err != nil {
        return nil, fmt.Errorf("writer: open file: %w", err)
    }

    return &Writer{f: f}, nil
}

func (w *Writer) WriteString(str string) (int, error) {
    return w.f.WriteString(fmt.Sprint(str, "\n"))

}

func (w *Writer) Close() error {
    return w.f.Close()
}

type Reader struct {
    f    *os.File
    rmFn func() error
    quit chan struct{}
    done *sync.WaitGroup
}

func NewReader(ipc string) (*Reader, error) {
    err := syscall.Mkfifo(ipc, 0640)
    if err != nil {
        return nil, fmt.Errorf("reader: create fifo: %w", err)
    }

    f, err := os.OpenFile(ipc, os.O_RDONLY, 0640)
    if err != nil {
        return nil, fmt.Errorf("reader: open fifo: %w", err)
    }
    return &Reader{
        f:    f,
        quit: make(chan struct{}),
        done: &sync.WaitGroup{},
        rmFn: func() error {
            return os.Remove(ipc)
        },
    }, nil
}

func (r *Reader) PollRead() <-chan string {
    reader := bufio.NewReader(r.f)
    out := make(chan string)
    r.done.Add(1)
    go func() {
        defer r.done.Done()
        for {
            line, err := reader.ReadBytes('\n')
            if err != nil {
                fmt.Printf("error reading from named pipe: %v\n", err)
                return
            }

            nline := string(line)
            nline = strings.TrimRight(nline, "\n")
            select {
            case out <- nline:
            case <-r.quit:
                close(out)
                return
            }
        }
    }()

    return out
}

func (r *Reader) Close() error {
    close(r.quit)
    r.done.Wait()
    err := r.f.Close()
    if err != nil {
        return fmt.Errorf("error closing named pipe: %v", err)
    }

    err = r.rmFn()
    if err != nil {
        return fmt.Errorf("error removing named pipe: %v", err)
    }
    return nil
}

這似乎確實有效，但是它受到一種特殊行為的影響，即在任何編寫者打開該文件之前，沒有讀者可以打開該文件，這似乎是根據我讀過的有關該主題的其他內容來扭轉行為；通常的抱怨是編寫器掛起，因為沒有任何讀取器，但是，這裡首先無法實例化讀取器。

解決方法

這是 posix 系統介面：

o_nonblock 當開啟設定了 o_rdonly 或 o_wronly 的 fifo 時： 如果 o_nonblock 被設置，只讀的 open() 將返回而不需要 延遲。如果沒有進程，只寫的 open() 將回傳錯誤 目前已開啟檔案供讀取。

如果 o_nonblock 被清除，則只讀的 open() 將阻塞 呼叫線程，直到線程打開檔案進行寫入。一個開放的() 只寫應阻塞呼叫線程，直到線程打開 供讀取的文件。

開啟支援的區塊特殊或字元特殊檔案時 非阻塞打開：

如果設定了 o_nonblock，則 open() 函數將傳回而不帶 阻止設備準備就緒或可用。隨後的行為 設備的屬性是特定於設備的。

如果 o_nonblock 被清除，則 open() 函數將阻止呼叫 l> 線程直到設備準備好或可用才返回。

否則，o_nonblock 標誌不會導致錯誤，但它是 未指定檔案狀態標誌是否包含 o_nonblock 標誌。

因此，解決方案是將 syscall.o_nonblock 標誌加入到 openfile 呼叫中：

f, err := os.OpenFile(ipc, os.O_RDONLY|syscall.O_NONBLOCK, 0640)

編輯：如評論中所討論的，此解決方案不可移植到 darwin 環境。更便攜的解決方案是在讀取器端使用 o_rdwr 開啟檔案。

以上是帶有 O_RDONLY 的 os.OpenFile 掛在沒有編寫器的命名管道上的詳細內容。更多資訊請關注PHP中文網其他相關文章！