Golang如何实现并发文件写入-Golang-PHP中文网

Golang如何实现并发文件写入

P粉602998670

发布： 2025-10-30 15:38:02

原创

194人浏览过

使用互斥锁可确保多goroutine安全写入同一文件，通过sync.Mutex实现原子操作；采用channel结合生产者-消费者模型能提升效率与可扩展性，由单一goroutine集中写入；若无需共用文件，可让每个goroutine写独立文件最后合并，避免竞争。

golang如何实现并发文件写入

Go语言通过goroutine和channel机制天然支持高并发编程，实现并发文件写入时需要考虑数据一致性、写入顺序以及文件锁等问题。直接让多个goroutine同时写同一个文件会导致内容错乱，因此要结合同步机制或集中写入策略来安全操作。

使用互斥锁（sync.Mutex）控制并发写入

当多个goroutine需要向同一文件写入数据时，最简单的方式是用sync.Mutex保证同一时间只有一个goroutine在执行写操作。

示例代码：

package main
<p>import (
"os"
"sync"
)</p><p>func main() {
file, err := os.OpenFile("output.txt", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
if err != nil {
panic(err)
}
defer file.Close()</p><pre class='brush:php;toolbar:false;'>var mu sync.Mutex
var wg sync.WaitGroup

for i := 0; i < 10; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        data := []byte("goroutine " + string(rune('0'+id)) + " writing\n")

        mu.Lock()
        file.Write(data)
        mu.Unlock()
    }(i)
}

wg.Wait()

登录后复制

}

立即学习“go语言免费学习笔记（深入）”；

说明：每次写入前获取锁，写完释放，确保写操作原子性。适合写入频率不高但并发量大的场景。

通过channel集中写入（生产者-消费者模型）

更高效且可扩展的做法是使用一个单独的写入goroutine负责实际写文件，其他goroutine通过channel发送数据给它。

优点：避免频繁加锁，写入顺序可控，易于添加缓冲和错误处理。

知网AI智能写作

知网AI智能写作，写文档、写报告如此简单

查看详情

package main
<p>import (
"bufio"
"os"
)</p><p>func main() {
file, err := os.OpenFile("output.txt", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
if err != nil {
panic(err)
}
defer file.Close()</p><pre class='brush:php;toolbar:false;'>writer := bufio.NewWriter(file)
defer writer.Flush()

dataChan := make(chan string, 100) // 缓冲channel
var wg sync.WaitGroup

// 启动消费者：写入文件
go func() {
    for line := range dataChan {
        writer.WriteString(line + "\n")
    }
}()

// 启动多个生产者
for i := 0; i < 10; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        for j := 0; j < 5; j++ {
            dataChan <- "data from worker " + string(rune('0'+id))
        }
    }(i)
}

// 所有生产者结束后关闭channel
wg.Wait()
close(dataChan)

// 消费者自动退出

登录后复制

}

立即学习“go语言免费学习笔记（深入）”；

说明：利用bufio.Writer提升IO性能，所有写请求通过channel传递，由单个goroutine统一处理。