我建议围绕在EOF上运行的阅读器创建包装器:
type tailReader struct { io.ReadCloser}func (t tailReader) Read(b []byte) (int, error) { for { n, err := t.ReadCloser.Read(b) if n > 0 { return n, nil } else if err != io.EOF { return n, err } time.Sleep(10 * time.Millisecond) }}func newTailReader(fileName string) (tailReader, error) { f, err := os.Open(fileName) if err != nil { return tailReader{}, err } if _, err := f.Seek(0, 2); err != nil { return tailReader{}, err } return tailReader{f}, nil}该阅读器可以在任何可以使用io.Reader的地方使用。这是使用bufio.Scanner循环行的方法:
t, err := newTailReader("somefile")if err != nil { log.Fatal(err)}defer t.Close()scanner := bufio.NewScanner(t)for scanner.Scan() { fmt.Println(scanner.Text())}if err := scanner.Err(); err != nil { fmt.Fprintln(os.Stderr, "reading:", err)}阅读器还可用于循环附加到文件的JSON值:
t, err := newTailReader("somefile")if err != nil { log.Fatal(err)}defer t.Close()dec := json.NewDeprer(t)for { var v SomeType if err := dec.Depre(&v); err != nil { log.Fatal(err) } fmt.Println("the value is ", v)}与问题中概述的goroutine方法相比,这种方法有两个优点。首先是关机很容易。只需关闭文件。无需向goroutine发出退出信号的信号。第二个优点是许多软件包都可以与io.Reader一起使用。
可以调整睡眠时间,以满足特定需求。减少时间以降低延迟,并增加时间以减少CPU使用量。100ms的睡眠对于显示给人类的数据可能足够快。



