当前位置：首页 > 文章列表 > Golang > Go教程 > Go os.OpenFile O_CREATE 没有 O_EXCL 时为什么可能覆盖竞态

Go os.OpenFile O_CREATE 没有 O_EXCL 时为什么可能覆盖竞态

来源：17golang原创 2026-09-11 13:33:19 0浏览收藏

两个 Go worker 同时生成 daily.json，日志却显示它们都“打开成功”，最后文件内容时好时坏。问题通常不在 Go 的 File 并发安全，而在于把 O_CREATE 误当成了“只允许一个创建者”。

需要竞争同一个文件名时，使用 os.O_CREATE|os.O_EXCL。第一个成功打开的调用者获得创建资格；其他调用者应把 os.ErrExist 当作“已有生产者”的结果，而不是继续写同一路径。

要点速览

O_CREATE 是“没有就创建，有就打开”，单独使用不会拒绝第二个调用者。
O_EXCL 必须和 O_CREATE 一起用，才能让文件名争抢成为一次性判定。
O_CREATE 本身不截断文件；真正的覆盖风险来自后续写入、O_TRUNC 或多个写者的时序。

O_CREATE 只是兜底创建，不是独占创建

官方 os.OpenFile 文档把 O_CREATE 定义为：目标不存在时创建；如果目标已经存在，调用仍然可以成功打开它。O_EXCL 的含义则是与 O_CREATE 联用，文件必须不存在。三者边界可以这样记：

标志	目标不存在	目标已存在	是否独占
`O_CREATE`	创建并打开	打开已有文件	否
`O_CREATE\|O_EXCL`	创建并打开	返回 `os.ErrExist`	是
`O_CREATE\|O_TRUNC`	创建并打开	打开后截断	否

Go os.OpenFile O_CREATE 连接目标路径、已有文件、文件描述符和写入偏移的静态语义框图 — 图1：看清 O_CREATE 的“不存在才创建、存在仍可打开”关系，避免把它当作独占锁。

所以，O_CREATE 单独出现时并不等于“覆盖已有文件”。它只是把两个调用者导向同一个已存在对象；如果后面使用普通 Write、显式 Seek(0, 0)，或者叠加 O_TRUNC，才可能出现内容互相覆盖、交错或被截断。

没有 O_EXCL 时，竞态发生在打开之后

常见的生产代码是：

f, err := os.OpenFile(path, os.O_WRONLY|os.O_CREATE, 0o600)
if err != nil {
    return err
}
defer f.Close()
// 中文注释：多个调用者都可能拿到同一路径的描述符，下面的写入没有“赢家”概念。
_, err = f.Write(payload)
return err

当路径还不存在时，调用 A 负责创建；调用 B 紧接着发现它已经存在，于是也成功返回。两个描述符的当前偏移都可能从文件开头开始，写入顺序由调度和系统时序决定。若其中一方先写入较长内容，另一方再从开头写入较短内容，还可能残留旧尾部；若代码用了 O_TRUNC，后打开者会直接把前一个写者的内容清空。

这也是为什么“给每个 goroutine 加互斥锁”不一定够：锁只覆盖同一个进程，无法约束另一个进程、另一个容器或重启后恢复的任务。真正要保护的是文件名的创建资格。

用 O_CREATE|O_EXCL 让一个调用者成为赢家

把判断交给一次打开操作，不要先 Stat 再决定是否创建。后者把检查和创建拆成两次系统调用，中间始终存在窗口。

package main

import (
    "errors"
    "fmt"
    "os"
)

func createOnce(path string, payload []byte) error {
    // 中文注释：O_EXCL 与 O_CREATE 联用，要求路径在打开瞬间仍不存在。
    f, err := os.OpenFile(path, os.O_WRONLY|os.O_CREATE|os.O_EXCL, 0o600)
    if err != nil {
        // 中文注释：ErrExist 表示别的 worker 已占用文件名，调用方不应继续写入。
        if errors.Is(err, os.ErrExist) {
            return fmt.Errorf("文件已由其他任务创建: %w", err)
        }
        return fmt.Errorf("独占创建文件失败: %w", err)
    }

    // 中文注释：写入失败时关闭并删除半成品，避免下一次任务误把它当成完整文件。
    if _, err := f.Write(payload); err != nil {
        _ = f.Close()
        _ = os.Remove(path)
        return fmt.Errorf("写入新文件失败: %w", err)
    }
    // 中文注释：关闭失败也要报告，调用方可决定是否重试或清理文件。
    if err := f.Close(); err != nil {
        _ = os.Remove(path)
        return fmt.Errorf("关闭新文件失败: %w", err)
    }
    return nil
}

这个函数的关键不是“写得更快”，而是把“谁有资格创建”与“谁负责写入”绑定到同一个成功结果。失败者收到 os.ErrExist 后，可以转去读取已完成文件、等待 ready 标记，或记录“本次任务已被其他 worker 处理”。