Golang基于文件的分布式锁实现逻辑-Golang-PHP中文网

flock不能用作分布式锁，因其是单机内核级劝告锁，在nfs等共享存储上不保证跨节点一致性，多节点调用可能同时成功；真正可行的是基于原子写+时间戳的租约式文件锁方案。

golang基于文件的分布式锁实现逻辑

为什么不能直接用 `os.OpenFile` 加 `flock` 做分布式锁

因为 flock 是内核级的 advisory 锁，只在单机文件系统生效，NFS、Ceph、S3 等共享存储不保证一致性，多个节点调用 flock 可能同时成功。Golang 标准库的 os.File 无法跨机器协同，这不是代码写得对不对的问题，是底层语义就不支持。

`syscall.Flock` 在分布式场景下会失效的具体表现

常见错误现象：本地测试一切正常，一上 K8s 多副本或跨 VM 就出现双写、任务重复执行；syscall.Flock 返回 nil，但其他节点也拿到锁；日志里看不到报错，逻辑却乱了。

即使挂载同一块 NFS 卷，Linux 内核对 flock 的实现不跨主机同步状态
syscall.Flock 不会阻塞等待，也不会自动重试，需手动轮询，但轮询间隔和超时难控制
锁文件被意外删除后，flock 不会自动释放（因为没进程持有），导致死锁

真正可用的替代方案：基于原子写 + 时间戳的文件锁

核心思路是放弃依赖内核锁，改用「文件存在性 + 内容校验 + 过期时间」三重判断。本质是把锁降级为“租约”，靠应用层逻辑保障互斥。

Golang Naming

Go（Golang）命名规范 — 包括包、构造函数、结构体、接口、常量、枚举、错误、布尔值、接收器、getter/setter、函数等。

下载

用 os.WriteFile（或 ioutil.WriteFile）配合 os.O_CREATE | os.O_EXCL 标志尝试创建锁文件，失败说明已被占
锁文件内容必须包含持有者标识（如 hostname + pid）和过期时间（Unix 时间戳），例如：{"holder":"node-1:1234","expire":1717023456}
每次获取锁前先读取现有锁文件，检查是否过期；过期则尝试用 os.Rename 原子替换（注意：不是覆盖写，是 rename 覆盖）
持有锁期间需定期刷新过期时间（通过重新 write + rename），否则可能被其他节点抢占

示例关键片段：

data := []byte(`{"holder":"` + hostname + `:` + strconv.Itoa(os.Getpid()) + `","expire":` + strconv.FormatInt(time.Now().Add(10*time.Second).Unix(), 10) + `}`)
err := os.WriteFile(lockPath, data, 0644)
if err != nil && os.IsExist(err) {
    // 文件已存在，读取并检查过期
    if !isLockExpired(lockPath) {
        return false, errors.New("lock held by another process")
    }
    // 尝试原子替换
    tmpPath := lockPath + ".tmp"
    os.WriteFile(tmpPath, data, 0644)
    os.Rename(tmpPath, lockPath)
}