在Linux环境中，tail -f命令是实时查看文件新增内容的常用工具，很多开发场景下需要在Go语言中复现这个功能，比如日志实时监控、数据流实时采集等。实现该功能的核心在于持续监听文件变化，精准读取新增内容，同时处理各种文件异常场景。
核心实现思路
要模拟tail -f的功能，需要解决三个核心问题：记录当前读取位置避免重复读取、监听文件是否有新增内容、处理文件被截断或轮转的特殊情况。整体流程可以分为以下几步：
- 打开目标文件，获取文件初始信息
- 记录当前文件大小和读取偏移量
- 定时检查文件状态，判断是否有新增内容
- 读取新增内容并输出，更新读取偏移量
- 处理文件被修改、截断、轮转等边界情况
基础实现代码
首先实现最基础的文件实时追踪逻辑，不包含复杂的边界处理，核心是通过循环检查文件大小变化来读取新增内容。
package main
import (
"fmt"
"io"
"os"
"time"
)
func main() {
// 目标文件路径，可替换为实际需要追踪的文件
filename := "test.log"
// 打开文件，以只读模式打开
file, err := os.Open(filename)
if err != nil {
fmt.Printf("打开文件失败: %vn", err)
return
}
defer file.Close()
// 初始读取偏移量，从文件末尾开始读取
offset, err := file.Seek(0, io.SeekEnd)
if err != nil {
fmt.Printf("获取文件偏移量失败: %vn", err)
return
}
// 循环监听文件变化
for {
// 获取当前文件信息
fileInfo, err := file.Stat()
if err != nil {
fmt.Printf("获取文件信息失败: %vn", err)
time.Sleep(1 * time.Second)
continue
}
// 当前文件大小
currentSize := fileInfo.Size()
// 如果文件大小大于偏移量，说明有新增内容
if currentSize > offset {
// 移动文件指针到上次读取的位置
_, err := file.Seek(offset, io.SeekStart)
if err != nil {
fmt.Printf("移动文件指针失败: %vn", err)
time.Sleep(1 * time.Second)
continue
}
// 读取新增内容
buf := make([]byte, 1024)
for {
n, err := file.Read(buf)
if err != nil && err != io.EOF {
fmt.Printf("读取文件失败: %vn", err)
break
}
if n == 0 {
break
}
// 输出新增内容
fmt.Print(string(buf[:n]))
// 更新偏移量
offset += int64(n)
}
} else if currentSize < offset {
// 文件被截断的情况，重新从文件开头读取
offset = 0
_, err := file.Seek(0, io.SeekStart)
if err != nil {
fmt.Printf("处理文件截断失败: %vn", err)
}
}
// 间隔1秒检查一次文件变化
time.Sleep(1 * time.Second)
}
}
边界情况处理
上述基础代码可以处理大部分常规场景，但实际使用中还会遇到文件轮转、文件被删除重建等情况，需要进一步优化。
文件轮转处理
很多日志系统会定期进行日志轮转，即把当前日志文件重命名，然后创建新的同名日志文件。此时原文件的描述符指向的是旧文件，需要重新打开新文件。
可以通过对比文件的inode信息来判断文件是否被轮转，Go语言中可以通过os.SameFile函数判断两个文件信息是否指向同一个文件。
package main
import (
"fmt"
"io"
"os"
"time"
)
func tailF(filename string) {
var file *os.File
var offset int64
var lastFileInfo os.FileInfo
// 初始化打开文件
reopenFile := func() error {
if file != nil {
file.Close()
}
f, err := os.Open(filename)
if err != nil {
return err
}
file = f
// 获取文件初始信息
info, err := f.Stat()
if err != nil {
return err
}
lastFileInfo = info
// 从文件末尾开始读取
offset, err = f.Seek(0, io.SeekEnd)
if err != nil {
return err
}
return nil
}
// 初始打开文件
if err := reopenFile(); err != nil {
fmt.Printf("初始打开文件失败: %vn", err)
return
}
defer file.Close()
for {
// 获取当前文件信息
currentInfo, err := os.Stat(filename)
if err != nil {
fmt.Printf("获取当前文件信息失败: %vn", err)
time.Sleep(1 * time.Second)
continue
}
// 判断文件是否被轮转
if !os.SameFile(lastFileInfo, currentInfo) {
fmt.Println("检测到文件轮转，重新打开文件")
if err := reopenFile(); err != nil {
fmt.Printf("重新打开文件失败: %vn", err)
time.Sleep(1 * time.Second)
continue
}
}
// 读取新增内容逻辑和基础实现一致
currentSize := currentInfo.Size()
if currentSize > offset {
_, err := file.Seek(offset, io.SeekStart)
if err != nil {
fmt.Printf("移动指针失败: %vn", err)
time.Sleep(1 * time.Second)
continue
}
buf := make([]byte, 1024)
for {
n, err := file.Read(buf)
if err != nil && err != io.EOF {
fmt.Printf("读取失败: %vn", err)
break
}
if n == 0 {
break
}
fmt.Print(string(buf[:n]))
offset += int64(n)
}
} else if currentSize < offset {
// 文件被截断，重新从开头读取
offset = 0
file.Seek(0, io.SeekStart)
}
time.Sleep(1 * time.Second)
}
}
func main() {
tailF("test.log")
}
优化建议
上述实现已经可以满足大部分场景的需求，还可以根据实际需求进行优化：
- 可以使用
inotify等系统调用替代定时轮询，减少CPU占用，Go语言中可以使用github.com/fsnotify/fsnotify库实现 - 增加配置项，支持指定从文件开头读取还是末尾读取，支持自定义检查间隔
- 增加错误重试机制，当文件读取失败时可以多次重试
- 支持多文件同时追踪，通过goroutine并发处理多个文件的监控逻辑
总结
用Go语言实现tail -f功能的核心在于维护文件读取偏移量，同时监听文件变化并处理边界情况。基础实现可以通过定时检查文件大小变化来读取新增内容，进阶实现需要处理文件轮转、截断等场景，保证功能的稳定性。开发者可以根据实际需求调整代码逻辑，适配不同的使用场景。