异步日志通过Goroutine和Channel解耦日志生成与写入，主协程将日志发送至缓冲通道，后台协程消费并写入文件，提升系统响应速度；示例中定义LogEntry结构体和容量为1000的logChan，InitLogger启动后台写入协程，Info、Error函数实现非阻塞日志发送；生产环境需处理通道满时的降级（如select+default非阻塞丢弃）、程序退出前刷出剩余日志、结合lumberjack实现轮转、添加写入失败重试机制，并可封装zap等高性能库以支持结构化日志与异步输出。
在高并发服务中，日志写入如果采用同步方式，容易因磁盘I/O阻塞影响主业务逻辑的性能。Golang通过Goroutine和Channel机制可以轻松实现异步日志写入，既能保证程序效率，又能确保日志不丢失。
异步日志的基本原理
异步日志的核心思想是：将日志内容从主协程发送到一个缓冲通道（Channel），由专门的日志处理协程从通道中读取并写入文件或输出设备。这样主流程无需等待磁盘写入完成，极大提升了响应速度。
关键组件包括：
- 日志通道（logChan）：用于接收来自各处的日志消息，通常设置一定缓冲容量
- 日志写入协程：后台运行，持续监听通道中的日志条目，并执行实际的写操作
- 日志结构体：定义日志级别、时间、内容等字段，便于统一处理
使用Goroutine实现异步写入
下面是一个简单的异步日志实现示例：
立即学习“go语言免费学习笔记（深入）”；
type LogEntry struct {
Level string
Time time.Time
Message string
}
var logChan = make(chan *LogEntry, 1000) // 缓冲通道
func InitLogger() {
go func() {
for entry := range logChan {
// 模拟写入文件，可替换为实际的文件操作
fmt.Printf("[%s] %s - %s\n", entry.Level, entry.Time.Format("2006-01-02 15:04:05"), entry.Message)
}
}()
}
func Info(msg string) {
logChan <- &LogEntry{
Level: "INFO",
Time: time.Now(),
Message: msg,
}
}
func Error(msg string) {
logChan <- &LogEntry{
Level: "ERROR",
Time: time.Now(),
Message: msg,
}
}
启动时调用 InitLogger() 启动后台写入协程，之后所有日志调用如 Info、Error 都是非阻塞的，直接发往通道即可。
优化与注意事项
在生产环境中使用异步日志需考虑以下几点：
- 通道满时的处理：若日志量突增导致通道满，直接发送会阻塞。可使用 select + default 实现非阻塞写入或丢弃低优先级日志
- 程序退出时的日志刷出：应在关闭前关闭通道，并等待后台协程处理完剩余日志，避免丢失
- 文件切割与轮转：结合第三方库如 lumberjack 实现按大小或时间切分日志文件
- 错误处理：写入失败时应有重试机制或至少记录到控制台作为后备
例如非阻塞写入：
select {
case logChan <- entry:
// 成功发送
default:
// 通道满，可选择丢弃或打印到 stderr
fmt.Fprintln(os.Stderr, "Log dropped due to buffer full:", entry.Message)
}
结合现有日志库使用
虽然可以自建异步日志系统，但在实际项目中推荐基于 zap、logrus 等高性能日志库进行封装。这些库本身支持 hook 机制，可通过自定义 writer 将输出桥接到异步通道，兼顾功能与性能。
例如使用 zap 的 io writer 包装，把输出导向我们自己的 channel 处理流程，既保留结构化日志能力，又实现异步化。
基本上就这些。异步日志的关键在于解耦“生成”和“写入”，利用Goroutine模型天然适合这种生产者-消费者模式。只要合理设计缓冲与降级策略，就能在高并发下稳定运行。
