github.com/hpcloud/tail监控追加文件
package main
import (
"fmt"
"github.com/hpcloud/tail"
"time"
)
func main(){
filename := `./xx.log`
config := tail.Config{
ReOpen: true,
Follow: true,
Location: &tail.SeekInfo{Offset: 0, Whence: 2},
MustExist: false,
Poll: true,
}
// 打开文件开始读取数据
tails, err := tail.TailFile(filename, config)
if err != nil {
fmt.Printf("tail %s failed, err:%v\n", filename, err)
return
}
for {
msg, ok:= <-tails.Lines // chan tail.Line
if !ok {
fmt.Printf("tail file close reopen, filename:%s\n",
tails.Filename)
time.Sleep(time.Second) // 读取出错等一秒
continue
}
fmt.Println("msg:", msg.Text)
}
}
先创建一个tail.config对象，其中location中的Whence决定相对位置：0为相对文件开头，1为相对当前位置，2为相对文件结尾。
tail每次都是从文件结尾开始读取
再根据文件路径和config创建一个TailFile对象
之后循环监控tails.Lines，如果文件有新的追加会被监控到，输出在终端。
使用原生golang实现以上功能
package main
import (
"bufio"
"fmt"
"io"
"log"
"os"
"time"
)
func main() {
file, err := os.Open("test.log") //针对test.log文件
if err != nil {
log.Fatalf("Open file fail:%v", err)
}
defer file.Close()
reader := bufio.NewReader(file)
for {
line, err := reader.ReadString('\n')
if err != nil {
if err == io.EOF {
time.Sleep(100 * time.Millisecond)
} else {
break
}
}
fmt.Print(string(line))
}
}
ReadString每次读取到\n停止，当读取完文件err为IO.EOF时，sleep一会，继续死循环，当出现其他错误时才终止循环，所以正常情况下程序会一直等待文件有追加新内容。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/133470.html
