1. package main
    3. import (
    4.     "fmt"
    5.     "time"
    7.     "github.com/hpcloud/tail"
    8. )
    9. //tailf
    10. //下载  go get github.com/hpcloud/tail   日志采集
    11. //go get github.com/Shopify/sarama   压缩算法
    12. // tailf的用法示例
    13. func main() {
    14.     fileName := "./my111.log"
    15.     config := tail.Config{
    16.         ReOpen:    true,                                 // 重新打开
    17.         Follow:    true,                                 // 是否跟随
    18.         Location:  &tail.SeekInfo{Offset: 0, Whence: 2}, // 从文件的哪个地方开始读
    19.         MustExist: false,                                // 文件不存在不报错
    20.         Poll:      true,
    21.     }
    22.     tails, err := tail.TailFile(fileName, config)
    23.     if err != nil {
    24.         fmt.Println("tail file failed, err:", err)
    25.         return
    26.     }
    27.     var (
    28.         line *tail.Line
    29.         ok   bool
    30.     )
    31.     for {
    32.         line, ok = <-tails.Lines
    33.         if !ok {
    34.             fmt.Printf("tail file close reopen, filename:%s\n", tails.Filename)
    35.             time.Sleep(time.Second)
    36.             continue
    37.         }
    38.         fmt.Println("line:", line.Text)
    39.     }
    42. }