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”是写入数据的字节片。

返回值：返回写入的字节数和错误（如果有）。但是，如果管道的读取端因错误而关闭，则该错误将作为err返回，否则返回的err是 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 错误。