write channel打印在輸出控制臺沒有具體的字符串
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文件中的時候不能打印出具體的字符串
