Golang如何处理多线程日志写入-Golang-PHP中文网

Golang如何处理多线程日志写入

P粉602998670

发布： 2025-10-24 10:26:02

原创

951人浏览过

使用sync.Mutex可确保多goroutine下日志写入的并发安全，通过加锁保证同一时间只有一个goroutine写入；示例中safeLog函数使用mutex.Lock和defer mutex.Unlock实现原子操作；另一种方式是通过带缓冲channel集中日志写入，由单独goroutine消费，实现生产者-消费者模型，避免竞争；还可使用zap或logrus等第三方库，其内部已实现线程安全，如zap通过锁保护写操作，支持高性能结构化日志。

golang如何处理多线程日志写入

Go语言中没有传统意义上的“多线程”，而是使用goroutine和channel来实现并发。当日志被多个goroutine同时写入时，如果不加控制，可能导致日志内容交错、混乱甚至文件损坏。因此，处理多goroutine下的日志写入需要保证写操作的线程安全（并发安全）。

使用sync.Mutex保护日志写入

最常见的方式是使用sync.Mutex来确保同一时间只有一个goroutine能执行写日志的操作。

示例：

package main
<p>import (
"log"
"os"
"sync"
)</p><p>var (
logFile *os.File
mutex   sync.Mutex
)</p><p>func init() {
var err error
logFile, err = os.OpenFile("app.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666)
if err != nil {
log.Fatal(err)
}
log.SetOutput(logFile)
}</p><p>func safeLog(message string) {
mutex.Lock()
defer mutex.Unlock()
log.Println(message)
}</p><p>func main() {
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
safeLog("来自 goroutine " + string(rune('0'+id)))
}(i)
}
wg.Wait()
logFile.Close()
}

登录后复制

通过mutex.Lock()和defer mutex.Unlock()，我们确保了每次只允许一个goroutine写入日志，避免了数据竞争。

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

使用带缓冲的channel进行日志集中写入

另一种更优雅的方式是将所有日志消息发送到一个channel中，由单独的一个goroutine负责从channel读取并写入文件。这种方式实现了生产者-消费者模型，天然避免了并发冲突。

示例：

package main
<p>import (
"bufio"
"os"
)</p><p>var logChannel = make(chan string, 100)</p>
                    <div class="aritcle_card">
                        <a class="aritcle_card_img" href="/ai/%E5%A6%82%E7%9F%A5ai%E7%AC%94%E8%AE%B0">
                            <img src="https://img.php.cn/upload/ai_manual/000/000/000/175679994166405.png" alt="如知AI笔记">
                        </a>
                        <div class="aritcle_card_info">
                            <a href="/ai/%E5%A6%82%E7%9F%A5ai%E7%AC%94%E8%AE%B0">如知AI笔记</a>
                            <p>如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型</p>
                            <div class="">
                                <img src="/static/images/card_xiazai.png" alt="如知AI笔记">
                                <span>27</span>
                            </div>
                        </div>
                        <a href="/ai/%E5%A6%82%E7%9F%A5ai%E7%AC%94%E8%AE%B0" class="aritcle_card_btn">
                            <span>查看详情</span>
                            <img src="/static/images/cardxiayige-3.png" alt="如知AI笔记">
                        </a>
                    </div>
                <p>func initLogger() {
file, _ := os.OpenFile("app.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666)
writer := bufio.NewWriter(file)</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">go func() {
    for msg := range logChannel {
        writer.WriteString(msg + "\n")
        writer.Flush()
    }
    writer.Flush()
    file.Close()
}()

登录后复制

}

func logAsync(message string) { select { case logChannel <- message: default: // 防止阻塞，可丢弃或重试 } }

func main() { initLogger() var wg sync.WaitGroup for i := 0; i < 10; i++ { wg.Add(1) go func(id int) { defer wg.Done() logAsync("处理完成 - ID: " + string(rune('0'+id))) }(i) } wg.Wait() close(logChannel) }

这种方式的优点是解耦了日志写入逻辑，性能更高，尤其适合高并发场景。

使用第三方日志库（如zap、logrus）

在实际项目中，推荐使用成熟的日志库，它们内部已经处理了并发安全问题。

uber-go/zap：高性能结构化日志库，原生支持并发写入。
Sirupsen/logrus：功能丰富，支持hook和多种输出格式，其写入操作也是线程安全的。

例如使用zap：

logger, _ := zap.NewProduction()
defer logger.Sync()
<p>for i := 0; i < 10; i++ {
go func(id int) {
logger.Info("事件发生",
zap.Int("id", id),
zap.String("status", "done"))
}(i)
}

登录后复制

zap内部使用锁保护写操作，并且性能优秀，适合生产环境。

基本上就这些。无论选择哪种方式，关键是保证日志输出的原子性和顺序性，避免内容错乱。手动加锁简单直接，channel模式更灵活，第三方库则省心高效。

以上就是Golang如何处理多线程日志写入的详细内容，更多请关注php中文网其它相关文章！