package main

import (

    "strings"

    "time"

    "fmt"

    "os"

    "bufio"

    "io"

)

type Reader interface {

    Read(rc chan []byte)

}

type Writer interface{

    Write(wc chan string)

}

type LogProcessOpt struct {

    rc chan []byte

    wc chan string

    read Reader

    write Writer

}

type ReadFromFile struct {

    path string

}

func (r *ReadFromFile) Read (rc chan []byte){

    //读取模块

    //打开文件

//fileName :="acc.txt";

    f, err := os.Open(r.path)

    if err != nil {

        panic(err)

    }

    result , err := f.Seek(0,2)

    fmt.Println(result)

    buf := bufio.NewReader(f)

    for {

        line,err := buf.ReadBytes('\n')

        if err ==io.EOF{

            time.Sleep(5*time.Second)

            continue

        } else if err!= nil{

            panic(fmt.Sprintf("ReadBytes error:%s",err.Error()))

        }

        rc<-line[:len(line)-1]

    }

}

type WriteToInfluxDB struct {

    influxDBDsn string //influx data source

}

func (w *WriteToInfluxDB) Write(wc chan string){

    //写入模块

    for v := range wc {

        fmt.Println(v)

    }

}

func (lp *LogProcessOpt) Process(){

    for v := range lp.rc {

        lp.wc <- strings.ToUpper(string(v[:]))

    }

    fmt.Println(lp.wc)

}

func main(){

    r := &ReadFromFile {

        path:"./acc.txt",

    }

    w := &WriteToInfluxDB{

        influxDBDsn:"username&password..",

    }

    lp:= &LogProcessOpt{

        rc: make(chan []byte),

        wc: make(chan string),

        read:r,

        write:w,

    }

    //(*lp).ReadFromFile , go 自动处理成下面这样

    go lp.read.Read(lp.rc)

    go lp.Process()

    go lp.write.Write(lp.wc)

    time.Sleep(30*time.Second)

}

代码写法照着视频写的，当新添加文本内容到txt文件中的时候不能打印出具体的字符串