首页 > Golang > Go问答

追加写入

来源：17golang原创

时间：2026-11-11 17:30:05 339浏览收藏

Go 里做“追加写入”，直接使用 os.OpenFile 的 os.O_APPEND|os.O_CREATE|os.O_WRONLY 组合即可。它会让每次 Write 在写入前定位到文件末尾；但这不等于整个业务记录自动具备跨机器一致性，也不等于多段 Write 会被合并成一条不可拆分的日志。

适合单机上的小型追加记录：一次把完整记录组装成字节切片，再调用一次 Write。如果要跨进程协调、跨主机写入或保证崩溃后的持久性，还需要文件锁、专用日志组件或更可靠的存储。

Go os.OpenFile O_APPEND 追加写入边界说明图 — 图1：O_APPEND 把每次 Write 定位到文件末尾的结构示意图；这是原创静态说明图，不是运行截图。

先把追加写入的契约说清楚

O_APPEND 解决的是“写入位置”的竞争：每次写操作开始前，文件偏移会被放到末尾。O_CREATE 负责文件不存在时创建，O_WRONLY 表示只写。不要把 O_APPEND 换成 O_TRUNC，后者会在打开可写文件时截断旧内容。

这个小项目把每条记录先拼成一行，再一次写出。这样能把“追加定位”与“记录组装”分开，避免一条业务记录被自己的多次写入拆开。

从零实现一个追加记录工具

package main

import (
    "fmt"
    "os"
    "sync"
)

var fileMu sync.Mutex

func appendRecord(path, message string) error {
    // O_APPEND 保证每次 Write 从当前文件末尾开始；O_CREATE 允许首次运行创建文件。
    f, err := os.OpenFile(path, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0644)
    if err != nil {
        return fmt.Errorf("打开追加文件: %w", err)
    }
    defer func() {
        // 真正的 Close 错误在主流程中返回，defer 只负责兜底关闭句柄。
        _ = f.Close()
    }()

    line := message + "\n"
    fileMu.Lock()
    defer fileMu.Unlock()

    // 一次 Write 写出完整记录；n 不足时返回错误，避免静默丢半行。
    n, err := f.Write([]byte(line))
    if err != nil {
        return fmt.Errorf("追加记录: %w", err)
    }
    if n != len(line) {
        return fmt.Errorf("追加记录不完整: 写入 %d/%d 字节", n, len(line))
    }
    return nil
}

func main() {
    if err := appendRecord("events.log", "job=42 status=done"); err != nil {
        fmt.Println(err)
    }
}

示例里的互斥锁只保护当前进程内的文件句柄使用，并不替代 O_APPEND。如果所有写入都来自同一个进程，它可以让“拼接记录—调用 Write”的边界更清楚；如果还有其他进程，其他进程必须遵守相同的单次写入约定，进程内的 sync.Mutex 看不到它们。

并发时哪些结论可以相信

多个 goroutine 共享同一个打开的文件时，锁可以让当前进程内的记录按完整行依次写出。即使去掉这把锁，O_APPEND 仍然解决每次写入从末尾开始的问题，但你不应把“多个 Write 的字节永远不会交错”扩展成所有平台、所有文件系统都成立的保证。

场景	可依赖的能力	额外措施
单进程，多 goroutine	追加定位；锁可保护记录边界	一次 Write 写完整记录
同机多个进程	普通文件追加定位	需要跨进程锁或统一记录协议
NFS 等网络文件系统	行为受实现影响	不要把 O_APPEND 当分布式日志方案
要求崩溃后必然落盘	Write 成功不等于持久化策略完成	评估 Sync、日志系统或数据库

Go 追加写入按进程和文件系统划分边界的示意图 — 图2：单进程锁、同机多进程和网络文件系统的职责边界；这是原创静态说明图，不是运行截图。

WriteAt 和 Seek 不要混用

追加模式的目标是“由文件系统选择末尾位置”，所以 WriteAt 与它的语义冲突。Go 的 os.File.WriteAt 在文件以 O_APPEND 打开时会返回错误；Seek 在追加模式下的行为也没有被 Go API 规定。需要固定偏移覆盖数据时，应使用普通读写模式并自行管理并发，而不是打开追加模式后再移动偏移。

func appendJSONLine(path string, payload []byte) error {
    f, err := os.OpenFile(path, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0644)
    if err != nil {
        return err
    }
    defer f.Close() // 示例保持短小；生产代码应按需要合并 Close 错误。

    record := append(append([]byte(nil), payload...), '\n')
    // 不要拆成“先 Seek 末尾、再 Write”；追加定位应由 O_APPEND 完成。
    n, err := f.Write(record)
    if err != nil {
        return err
    }
    if n != len(record) {
        return fmt.Errorf("short append: %d/%d", n, len(record))
    }
    return nil
}