使用 Go 语言实现可扩展的日志收集器

唐可

发布时间：2026-10-15 | 2人浏览过

原创

在应用开发中，统一的日志记录是排查问题的关键。本文讲解如何使用 Go 语言实现一个支持多路输出的日志收集器，包含控制台的实时反馈与本地文件的持久化存储。

结果与目标

开发者通常需要同时观察控制台实时动态并将详细日志留存至文件。本方案的目标是实现一个中心化的 Logger，利用策略模式将不同目的地（如标准输出或磁盘文件）解耦为独立的写入器（Writer），从而支持后续轻松扩展新的日志通道。

准备条件

实现该功能需要满足以下基础环境要求：

Go 语言环境：建议使用 Go 1.16 及以上版本。
包管理工具：系统已安装 go 命令行工具。
依赖库：仅需使用 Go 标准库中的 fmt、os 及 errors。

操作顺序

第一步：定义日志接口与核心调度器

目的是建立一个通用的抽象层，使得任何符合规范的写入器都能被日志器调用。LogWriter 接口定义了唯一的 Write 方法，接收 interface{} 类型的数据以支持结构化或非结构化的日志内容。

// 声明日志写入器接口
type LogWriter interface {
	Write(data interface{}) error
}

// 日志器
type Logger struct {
	writerList []LogWriter
}

// 创建日志器的实例
func NewLogger() *Logger {
	return &Logger{}
}

在 Logger 结构体中维护一个写入器列表。通过 RegisterWriter 方法添加新路由，再通过 Log 方法循环遍历所有注册的写入器执行写入动作：

// 注册一个日志写入器
func (l *Logger) RegisterWriter(writer LogWriter) {
	l.writerList = append(l.writerList, writer)
}

// 将一个data类型的数据写入日志
func (l *Logger) Log(data interface{}) {
	for _, writer := range l.writerList {
		writer.Write(data)
	}
}

第二步：实现控制台输出写入器

此步骤实现基于 Stdout 的标准输出日志器，适用于开发环境下的实时调试。它实现了 Write 接口，将数据格式化为字符串后写入标准输出流。

type consoleWriter struct{}

// 实现LogWriter的Write()方法
func (f *consoleWriter) Write(data interface{}) error {
	str := fmt.Sprintf("%v\n", data)
	_, err := os.Stdout.Write([]byte(str))
	return err
}

// 创建命令行写入器实例
func NewConsoleWriter() *consoleWriter {
	return &consoleWriter{}
}

第三步：实现文件记录写入器

用于生产环境的日志归档。该写入器负责管理文件句柄，并在初始化时打开指定路径的文件，随后将日志内容追加写入。注意：若未调用 SetFile，写入操作将返回错误。

type fileWriter struct {
	file *os.File
}

// 设置文件写入器写入的文件名
func (f *fileWriter) SetFile(filename string) (err error) {
	if f.file != nil {
		f.file.Close()
	}
	f.file, err = os.Create(filename)
	return err
}

// 实现LogWriter的Write()方法
func (f *fileWriter) Write(data interface{}) error {
	if f.file == nil {
		return errors.New("file not created")
	}
	str := fmt.Sprintf("%v\n", data)
	_, err := f.file.Write([]byte(str))
	return err
}

// 创建文件写入器实例
func NewFileWriter() *fileWriter {
	return &fileWriter{}
}

第四步：组合并运行测试代码

在 main 函数中，我们将上述两种写入器分别注册到同一日志器实例中，从而实现一份日志双份输出的效果：

// 组装日志器
func createLogger() *Logger {
	l := NewLogger()
	cw := NewConsoleWriter()
	l.RegisterWriter(cw)
	
	fw := NewFileWriter()
	if err := fw.SetFile("log.log"); err != nil {
		fmt.Println(err)
	}
	l.RegisterWriter(fw)
	
	return l
}

func main() {
	l := createLogger()
	l.Log("hello") // 将在终端显示并生成 log.log 文件
}