Go语言中bufio.Writer的正确关闭与刷新机制

package main

import (
    "bufio"
    "fmt"
    "os"
    "log"
)

func main() {
    // 1. 创建或打开一个文件作为底层io.Writer
    // os.Create 返回一个 *os.File，它实现了io.Writer和io.Closer接口
    file, err := os.Create("output.txt")
    if err != nil {
        log.Fatalf("无法创建文件: %v", err)
    }
    // 使用 defer 确保文件在函数退出时被关闭
    // 注意：defer的顺序是LIFO（后进先出），所以file.Close()会在writer.Flush()之后执行
    // 但在这里，我们显式调用Flush，所以defer file.Close()是安全的。
    defer func() {
        if cerr := file.Close(); cerr != nil {
            log.Printf("关闭文件失败: %v", cerr)
        }
    }()

    // 2. 创建一个 bufio.Writer 包装文件
    writer := bufio.NewWriter(file)
    // 同样，为 writer 的 Flush 操作设置 defer
    // 这一步至关重要，它确保在函数退出前所有缓冲区数据都被写入文件
    defer func() {
        if ferr := writer.Flush(); ferr != nil {
            log.Printf("刷新缓冲区失败: %v", ferr)
        }
    }()

    // 3. 通过 bufio.Writer 写入数据
    _, err = writer.WriteString("Hello, bufio.Writer!\n")
    if err != nil {
        log.Fatalf("写入字符串失败: %v", err)
    }

    _, err = writer.WriteString("This is a buffered write example.\n")
    if err != nil {
        log.Fatalf("写入字符串失败: %v", err)
    }

    fmt.Println("数据已写入缓冲区。")
    // 此时数据可能仍在缓冲区中，尚未写入文件

    // 4. 显式调用 Flush() 将缓冲区数据写入底层文件
    // 即使有defer，在某些情况下（如需要立即确保数据写入），显式调用也是有用的
    // 例如，在长时间运行的程序中，周期性刷新可以减少数据丢失的风险
    // 如果不在这里显式调用，defer func() { writer.Flush() } 会在函数退出时执行
    // if err := writer.Flush(); err != nil {
    //  log.Fatalf("刷新缓冲区失败: %v", err)
    // }
    // fmt.Println("缓冲区已刷新，数据已写入文件。")

    // 5. 函数退出时，defer注册的 Flush() 和 Close() 会依次执行
    // 首先执行 writer.Flush()，然后执行 file.Close()
}

package main

import (
    "bufio"
    "fmt"
    "io"
    "log"
    "os"
)

func readExample() {
    file, err := os.Open("input.txt") // 假设 input.txt 存在
    if err != nil {
        log.Fatalf("无法打开文件: %v", err)
    }
    defer func() {
        if cerr := file.Close(); cerr != nil {
            log.Printf("关闭文件失败: %v", cerr)
        }
    }()

    reader := bufio.NewReader(file)

    // 从 bufio.Reader 读取数据
    for {
        line, _, err := reader.ReadLine()
        if err == io.EOF {
            break
        }
        if err != nil {
            log.Fatalf("读取文件失败: %v", err)
        }
        fmt.Printf("读取到一行: %s\n", string(line))
    }
}

func main() {
    // 为了演示readExample，先创建 input.txt
    f, _ := os.Create("input.txt")
    f.WriteString("Line 1\nLine 2\nLine 3\n")
    f.Close()

    readExample()
    os.Remove("input.txt") // 清理文件
}