Golang bufio提升I/O性能：缓冲读写与Scanner详解

bufio通过缓冲机制减少系统调用提升I/O性能1.使用bufio.Reader和bufio.Writer将数据缓存至内存，减少实际I/O操作次数；2.Scanner支持按行、单词、字符或自定义分隔符读取，适用于日志分析等场景；3.写入时需调用Flush()确保数据落地；4.可调整缓冲区大小并处理长行限制；5.并发操作需自行保证线程安全。

在处理文件或网络数据时，频繁的I/O操作往往会成为性能瓶颈。Golang 的 bufio 库通过缓冲机制和灵活的读取方式，能够有效减少系统调用次数，从而显著提升 I/O 性能。特别是结合其 Scanner 的高级用法，可以更方便地按行、按分隔符等模式读取数据。

什么是 bufio 缓冲 I/O

Go 标准库中的 bufio 包提供带缓冲的 I/O 操作，主要目的是减少底层系统调用的次数。通常，每次调用 Read() 或 Write() 都会触发一次系统调用，而系统调用的成本相对较高。使用 bufio.Reader 和 bufio.Writer 后，数据会被先写入内存缓冲区，等到缓冲区满或者主动调用 Flush() 时才进行实际 I/O 操作。

举个例子：

file, _ := os.Open("example.txt")
defer file.Close()

reader := bufio.NewReader(file)
for {
    line, err := reader.ReadString('\n')
    if err != nil {
        break
    }
    fmt.Println(line)
}

这里使用了 bufio.NewReader 来包装一个文件句柄，每次读取以换行符为界，但背后可能只发生几次系统调用，而不是每行都调用一次。

bufio.Scanner：简洁高效的逐行/分块读取

对于文本处理来说，最常用的可能是 bufio.Scanner。它封装了常见的扫描逻辑，支持按行、单词甚至自定义分隔符来读取内容，非常适合日志分析、配置解析等场景。

基本用法如下：

scanner := bufio.NewScanner(file)
for scanner.Scan() {
    fmt.Println(scanner.Text())
}

• 默认是以行为单位进行扫描（即分隔符是 \n）。
• 如果想按空格分隔词，可以设置拆分函数：

scanner.Split(bufio.ScanWords)

常见拆分函数包括：

• bufio.ScanLines：按行拆分（默认）
• bufio.ScanWords：按空白字符拆分
• bufio.ScanRunes：按 rune（字符）拆分
• 自定义函数：满足特定格式需求

例如，如果你想按某个特殊符号（如 |）拆分内容，可以这样写：

splitFunc := func(data []byte, atEOF bool) (advance int, token []byte, err error) {
    if i := bytes.IndexByte(data, '|'); i >= 0 {
        return i + 1, data[0:i], nil
    }
    if atEOF && len(data) > 0 {
        return len(data), data, nil
    }
    return 0, nil, nil
}

scanner.Split(splitFunc)

缓冲写入与 Flush 控制

除了读取，bufio.Writer 也非常实用。当你需要频繁写入小块数据时，直接使用 os.File.Write() 可能会导致大量系统调用。使用 bufio.Writer 能够将这些写操作合并，最后一次性刷盘。

使用示例：

file, _ := os.Create("output.txt")
defer file.Close()

writer := bufio.NewWriter(file)
for i := 0; i < 1000; i++ {
    writer.WriteString("some data\n")
}
writer.Flush()

注意：必须调用 Flush() 才能确保所有数据真正写入目标文件或连接。

小技巧与注意事项

• 缓冲大小默认是4KB，可以通过 NewReaderSize() 或 NewWriterSize() 设置更大的缓冲区，适用于大文件批量读写。
• Scanner 默认限制单次扫描内容不超过 64KB，如果遇到非常长的一行，会报错 bufio.Scanner: token too long，可以通过 scanner.Buffer() 手动扩展缓冲区。
• 在处理多 goroutine 并发读写时，要自行保证线程安全，因为 bufio 不是并发安全的。

基本上就这些，掌握好 bufio 的缓冲机制和 Scanner 的灵活用法，能让你在处理输入输出时更加高效和得心应手。