Go语言使用buffer读取文件
2021年1月31日 | by tgcode
buffer 是缓冲器的意思,Go语言要实现缓冲读取需要使用到 bufio 包。bufio 包本身包装了 io.Reader 和 io.Writer 对象,同时创建了另外的 Reader 和 Writer 对象,因此对于文本 I/O 来说,bufio 包提供了一定的便利性。
buffer 缓冲器的实现原理就是,将文件读取进缓冲(内存)之中,再次读取的时候就可以避免文件系统的 I/O 从而提高速度。同理在进行写操作时,先把文件写入缓冲(内存),然后由缓冲写入文件系统。
使用 bufio 包写入文件
bufio 和 io 包中有很多操作都是相似的,唯一不同的地方是 bufio 提供了一些缓冲的操作,如果对文件 I/O 操作比较频繁的,使用 bufio 包能够提高一定的性能。
在 bufio 包中,有一个 Writer 结构体,而其相关的方法支持一些写入操作,如下所示。
//Writer 是一个空的结构体,一般需要使用 NewWriter 或者 NewWriterSize 来初始化一个结构体对象 type Writer struct { // contains filtered or unexported fields } //NewWriterSize 和 NewWriter 函数 //返回默认缓冲大小的 Writer 对象(默认是4096) func NewWriter(w io.Writer) *Writer //指定缓冲大小创建一个 Writer 对象 func NewWriterSize(w io.Writer, size int) *Writer //Writer 对象相关的写入数据的方法 //把 p 中的内容写入 buffer,返回写入的字节数和错误信息。如果 nn 示例代码如下所示:package main import ( "bufio" "fmt" "os" ) func main() { name := "demo.txt" content := "http://c.biancheng.net/golang/" fileObj, err := os.OpenFile(name, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0644) if err != nil { fmt.Println("文件打开失败", err) } defer fileObj.Close() writeObj := bufio.NewWriterSize(fileObj, 4096) //使用 Write 方法,需要使用 Writer 对象的 Flush 方法将 buffer 中的数据刷到磁盘 buf := []byte(content) if _, err := writeObj.Write(buf); err == nil { if err := writeObj.Flush(); err != nil { panic(err) } fmt.Println("数据写入成功") } }运行上面的代码会在当前目录之下生成 demo.txt 文件,并将“http://c.biancheng.net/golang/”写入到该文件中。
使用 bufio 包读取文件
使用 bufio 包读取文件也非常方便,我们先来看下 bufio 包的相关的 Reader 函数方法:
//首先定义了一个用来缓冲 io.Reader 对象的结构体,同时该结构体拥有以下相关的方法 type Reader struct { } //NewReader 函数用来返回一个默认大小 buffer 的 Reader 对象(默认大小是 4096) 等同于 NewReaderSize(rd,4096) func NewReader(rd io.Reader) *Reader //该函数返回一个指定大小 buffer(size 最小为 16)的 Reader 对象,如果 io.Reader 参数已经是一个足够大的 Reader,它将返回该 Reader func NewReaderSize(rd io.Reader, size int) *Reader //该方法返回从当前 buffer 中能被读到的字节数 func (b *Reader) Buffered() int //Discard 方法跳过后续的 n 个字节的数据,返回跳过的字节数。如果 0 示例代码如下:
package main import ( "bufio" "fmt" "os" "strconv" ) func main() { fileObj, err := os.Open("demo.txt") if err != nil { fmt.Println("文件打开失败:", err) return } defer fileObj.Close() //一个文件对象本身是实现了io.Reader的 使用bufio.NewReader去初始化一个Reader对象,存在buffer中的,读取一次就会被清空 reader := bufio.NewReader(fileObj) buf := make([]byte, 1024) //读取 Reader 对象中的内容到 []byte 类型的 buf 中 info, err := reader.Read(buf) if err != nil { fmt.Println(err) } fmt.Println("读取的字节数:" + strconv.Itoa(info)) //这里的buf是一个[]byte,因此如果需要只输出内容,仍然需要将文件内容的换行符替换掉 fmt.Println("读取的文件内容:", string(buf)) }运行结果如下:
go run main.go
读取的字节数:30
读取的文件内容: http://c.biancheng.net/golang/在Go语言中,不仅结构体与结构体之间可以嵌套,接口与接口间也可以通过嵌套创造出新的接口。 一个接口可以包含一个或多个其他的接口,这相当于直接将这些内嵌接口的方法列举在外层接口中一样。只要接口的所有方法被实现,则这个接口中的所有嵌套接口的方法均可以被调用。 系统…