Golang io.PipeWriter.Write() 函数及示例

Go 语言的 io 包提供了基本的 I/O 原语接口。它的主要工作是封装此类原语的正在进行的实现。 Go 语言中的 PipeWriter.Write() 函数用于实现 Write 的标准接口。它将信息写入管道并阻塞它，直到一个或多个读取器取走所有信息或者管道的读取端关闭。此外，此函数在 io 包中定义。在此，您需要导入 “io” 包才能使用这些函数。

语法：

func (w *PipeWriter) Write(data []byte) (n int, err error)

在这里，“w”是 PipeWriter 的指针。其中 PipeWriter 是管道的写半部分，“data”是写入数据的字节切片。

返回值： 它返回写入的字节数和任何错误。但是，如果管道的读取端关闭并带有错误，则返回该错误作为错误，否则返回一个 ErrClosedPipe 错误作为错误。

实例 1：

// Golang program to illustrate the usage of
// io.pipeWriter.Write() function
  
// Including main package
package main
  
// Importing fmt and io
import (
    "fmt"
    "io"
)
  
// Calling main
func main() {
  
    // Calling Pipe method
    pipeReader, pipeWriter := io.Pipe()
  
    // Defining data parameter of Read method
    data := make([]byte, 20)
  
    // Reading data into the buffer stated
    go func() {
        pipeReader.Read(data)
  
        // Closing read half of the pipe
        pipeReader.Close()
    }()
  
    // Using for loop
    for i := 0; i < 1; i++ {
  
        // Calling pipeWriter.Write() method
        n, err := pipeWriter.Write([]byte("GfG!"))
  
        // If error is not nil panic
        if err != nil {
            panic(err)
        }
  
        // Prints the content written
        fmt.Printf("%v\n", string(data))
  
        // Prints the number of bytes
        fmt.Printf("%v\n", n)
    }
} 

输出：

GfG!
4

在这里，由于 “for” 循环运行时未关闭管道的读取端，因此没有返回错误。

实例 2：

// Golang program to illustrate the usage of
// io.pipeWriter.Write() function
  
// Including main package
package main
  
// Importing fmt and io
import (
    "fmt"
    "io"
)
  
// Calling main
func main() {
  
    // Calling Pipe method
    pipeReader, pipeWriter := io.Pipe()
  
    // Defining data parameter of Read method
    data := make([]byte, 20)
  
    // Reading data into the buffer stated
    go func() {
        pipeReader.Read(data)
  
        // Closing read half of the pipe
        pipeReader.Close()
    }()
  
    // Using for loop
    for i := 0; i < 2; i++ {
  
        // Calling pipeWriter.Write() method
        n, err := pipeWriter.Write([]byte("GfG!"))
  
        // If error is not nil panic
        if err != nil {
            panic(err)
        }
  
        // Prints the content written
        fmt.Printf("%v\n", string(data))
  
        // Prints the number of bytes
        fmt.Printf("%v\n", n)
    }
} 

输出：

GfG!
4
panic: io: read/write on closed pipe

goroutine 1 [running]:
main.main()
    /tmp/sandbox367087659/prog.go:38 +0x3ad

在这里，由于管道的读取端在第一次 for 循环迭代后关闭，因此返回一个 ErrClosedPipe 错误。