Golang 中的 io.PipeReader.Read()函数示例

在 Go 语言中， io包为 I/O 原语提供基本接口。它的主要工作是封装这种原语之王的持续实现。 Go语言的PipeReader.Read()函数用于实现Read的标准接口。它从管道中读取信息并阻塞它，直到写入器出现或管道的写入端关闭。而且，这个函数是在io包下定义的。在这里，您需要导入“io”包才能使用这些功能。

句法：

func (r *PipeReader) Read(data []byte) (n int, err error)

这里，“r”是指向 PipeReader 的指针。其中，PipeReader 是管道的读取部分，“data”是指定长度的字节片，将写入的数据读入其中。

返回值：它返回读取的字节数和错误（如果有）。但是，如果管道的写入端因错误而关闭，则该错误将作为err返回，否则返回的err是 EOF 错误。

示例 1：

// Golang program to illustrate the usage of
// io.PipeReader.Read() function
  
// Including main package
package main
  
// Importing fmt and io
import (
    "fmt"
    "io"
)
  
// Calling main
func main() {
  
    // Calling Pipe method
    pipeReader, pipeWriter := io.Pipe()
  
    // Writing data to the pipe
    go func() {
        pipeWriter.Write([]byte("GfG"))
        pipeWriter.Write([]byte("GeeksforGeeks"))
        pipeWriter.Write([]byte("GfG is a CS-Portal."))
  
        // Closing write half of the pipe
        pipeWriter.Close()
  
        // Again calling Write method
        pipeWriter.Write([]byte("Author!"))
    }()
  
    // Defining data parameter of Read method
    data := make([]byte, 20)
  
    // Using for loop
    for i := 0; i < 3; i++ {
  
        // Calling pipeReader.Read() method
        n, err := pipeReader.Read(data)
  
        // If error is not nil panic
        if err != nil {
            panic(err)
        }
  
        // Prints the content read in buffer
        fmt.Printf("%s\n", data[:n])
  
        // Prints number of bytes read
        fmt.Printf("%v\n", n)
    }
}

输出：

GfG
3
GeeksforGeeks
13
GfG is a CS-Portal.
19

在这里，没有错误返回，因为在“for”循环运行之前，管道的写端不会关闭。

示例 2：

// Golang program to illustrate the usage of
// io.PipeReader.Read() function
  
// Including main package
package main
  
// Importing fmt and io
import (
    "fmt"
    "io"
)
  
// Calling main
func main() {
  
    // Calling Pipe method
    pipeReader, pipeWriter := io.Pipe()
  
    // Writing data to the pipe
    go func() {
        pipeWriter.Write([]byte("GfG"))
        pipeWriter.Write([]byte("GeeksforGeeks"))
        pipeWriter.Write([]byte("GfG is a CS-Portal."))
  
        // Closing write half of the pipe
        pipeWriter.Close()
  
        // Again calling Write method
        pipeWriter.Write([]byte("Author!"))
    }()
  
    // Defining data parameter of Read method
    data := make([]byte, 20)
  
    // Using for loop
    for i := 0; i < 4; i++ {
  
        // Calling pipeReader.Read() method
        n, err := pipeReader.Read(data)
  
        // If error is not nil panic
        if err != nil {
            panic(err)
        }
  
        // Prints the content read in buffer
        fmt.Printf("%s\n", data[:n])
  
        // Prints number of  bytes read
        fmt.Printf("%v\n", n)
    }
}

输出：

GfG
3
GeeksforGeeks
13
GfG is a CS-Portal.
19
panic: EOF

goroutine 1 [running]:
main.main()
    /tmp/sandbox634835876/prog.go:43 +0x364

在这里，当在 for 循环的第三次迭代后关闭管道的写端时，将返回 EOF 错误。