当前位置：首页 > 文章列表 > Golang > Go教程 > Golang文件加锁与并发同步方法

Golang文件加锁与并发同步方法

2026-03-24 22:05:42 0浏览收藏

在 Go 中实现安全的并发文件访问，关键在于突破单进程 sync 包的局限，借助操作系统级的文件锁机制（如 Unix 的 flock 或 Windows 的 LockFile）实现跨进程同步；本文深入解析了如何使用 syscall.Flock 进行阻塞/非阻塞的独占锁与共享锁操作，强调 defer 释放锁、重试策略和“劝告式锁”的协作前提，并推荐跨平台成熟的 gofrs/flock 库来统一处理系统差异——掌握这些技巧，你就能在分布式协作、日志写入、配置更新等场景中，可靠地避免数据竞争与文件损坏。

如何用 Golang 实现文件加锁_Golang 并发文件访问同步方法

在 Golang 中实现文件加锁，主要是为了防止多个进程或协程同时读写同一个文件导致数据不一致或损坏。虽然 Go 的 sync 包能处理同一进程内的 goroutine 同步，但它无法跨进程生效。要实现真正的并发文件访问控制，必须使用 文件系统级别的锁。这通常通过操作系统提供的文件锁机制完成。

使用 syscall.Flock 实现文件加锁

Go 标准库没有直接提供文件锁的包，但可以通过 syscall.Flock（Unix 系统）或 syscall.LockFile（Windows）来实现。以下以 Linux/macOS 常见的 flock 为例说明。

基本思路是：打开一个文件句柄，然后对该句柄加锁。其他进程尝试对同一文件加锁时会被阻塞或返回错误。

共享锁（读锁）：多个进程可同时持有，适用于只读操作。
独占锁（写锁）：仅一个进程可持有，适用于写入操作。

示例代码：

package main

import (
    "fmt"
    "log"
    "os"
    "syscall"
    "time"
)

func main() {
    file, err := os.OpenFile("shared.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
    if err != nil {
        log.Fatal(err)
    }
    defer file.Close()

    // 尝试加独占锁（阻塞直到获取）
    err = syscall.Flock(int(file.Fd()), syscall.LOCK_EX)
    if err != nil {
        log.Fatal("无法加锁:", err)
    }
    defer syscall.Flock(int(file.Fd()), syscall.LOCK_UN) // 释放锁

    // 模拟写入操作
    _, err = file.WriteString(fmt.Sprintf("写入数据: %s\n", time.Now().Format("15:04:05")))
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("成功写入并自动解锁")
    time.Sleep(time.Second) // 观察锁效果
}

说明：

LOCK_EX 表示独占锁，用于写操作。
LOCK_SH 表示共享锁，用于读操作。
LOCK_UN 用于释放锁。
使用 defer 确保锁最终被释放，避免死锁。

非阻塞加锁与重试机制

默认 flock 是阻塞的。如果希望非阻塞，可以使用 LOCK_NB 标志：

err = syscall.Flock(int(file.Fd()), syscall.LOCK_EX|syscall.Lock_NB)
if err != nil {
    if err == syscall.EWOULDBLOCK {
        fmt.Println("文件已被锁定，跳过...")
        return
    }
    log.Fatal(err)
}

你也可以在此基础上实现重试逻辑，比如每隔 100ms 尝试一次，最多尝试 5 次。

跨平台兼容性考虑

syscall.Flock 在 Windows 上不可用。若需跨平台支持，推荐使用第三方库：

github.com/gofrs/flock：封装了不同系统的文件锁，API 简洁，支持 Unix 和 Windows。

示例：

import "github.com/gofrs/flock"

l := flock.New("data.lock")
locked, err := l.TryLock()
if err != nil {
    log.Fatal(err)
}
if !locked {
    fmt.Println("无法获取锁")
    return
}
defer l.Unlock()

这个库会自动处理平台差异，是生产环境中的常用选择。