現在のテールを中断して新しいものを開始する

Question

私はgolangにいくつかのログアナライザを作成しています。私が必要とするのは、新しく作成されたファイルのリアルタイムtail -fです。

私はfsnotifyパッケージと共にテールパッケージを使用していますが、私はチャネルやルーチンをあまりよく知らないので、何か助けが必要です。

現在、プログラムは次のようになります。

package main 

import(
    "fmt" 
    "github.com/hpcloud/tail" 
    "strings" 
    "log" 
    "net/smtp" 
    "time" 
    "github.com/fsnotify/fsnotify" 
) 

//this function needs to monitor for new files in directory 
func newFileCheck() (newFilename chan string, err error) { 
    watcher, err := fsnotify.NewWatcher() 
    if err != nil { 
     return 
    } 

    err = watcher.Add("myDir") 
    if err != nil { 
     return 
    } 

    newFilename = make(chan string) 

    // Process events 
    go func() { 
     for { 
      select { 
      case ev := <-watcher.Events: 
       log.Println("event:", ev) 
       newFilename <- ev.Name // Relative path to the file 
       //t.Stop() //if I pass reference to t THIS IS NOT HAPPENING ? 
      case err := <-watcher.Errors: 
       log.Println("error:", err) 
      } 
     } 
    }() 

    return 
} 

func main() { 
    newFileName = "mylog_0000.log.txt" 

    fmt.Println("Processing log: ",newFileName) 

    newFilenameChan, err := newFileCheck() 
    if err != nil { 
     fmt.Println("ERR: ",err) 
    } 

    t := tailLog(newFileName) 

    go func() { 
     for { 
      select { 
       case name := <-newFilenameChan: 
        fmt.Println("New file created: ",name) //this will be printed only once and then on new events nothing is printed ? 

       //NONE of the lines abowe doesn't work 
       t.Stop() 
       t.Dead() 
       t.Done() 

       t = tailLog(name) 
      } 
     } 
    }() 
} 

func tailLog(fileName string) *tail.Tail{ 
    var count = 0 
    // close the old one and read new file 
    t, err := tail.TailFile("/mydir/"+fileName, tail.Config{Follow: true, ReOpen: true}) 

    for line := range t.Lines { 
     //fmt.Println("Line is:", line.Text) 

     //check do we have what we need 
     if strings.Contains(strings.ToLower(line.Text), "mfc"){ 

      count++ 
      //do other stuff 
     } 
    } 

    fmt.Println(err) 

    return t 
} 

newFileCheck機能のみ拳時間のイベントを印刷し、そしてまた、私はアクティブな尾をキャンセルする方法を見つけ出すことができないんだけど、なぜだから私は把握することはできません新しいイベントが発生したら、そのイベントの後に再びテールを開始しますか？

Answer 1

はこのことを考えてみましょう：

すると機能の主が戻ると、プログラムが終了します。他の（メインではない）ゴルーチンが完了するまで、 を待つことはありません。

そして

あなたのコードのこのブロックを見て：

func main() { 
    newFileName = "mylog_0000.log.txt" 

    fmt.Println("Processing log: ",newFileName) 

    newFilenameChan, err := newFileCheck() 
    if err != nil { 
     fmt.Println("ERR: ",err) 
    } 

    t := tailLog(newFileName) 

    go func() { 
     for { 
      select { 
       case name := <-newFilenameChan: 
        fmt.Println("New file created: ",name) //this will be printed only once and then on new events nothing is printed ? 

       //NONE of the lines abowe doesn't work 
       t.Stop() 
       t.Dead() 
       t.Done() 

       t = tailLog(name) 
      } 
     } 
    }() 
} 

優雅で、このジョブを処理するために、あなたはGolangで並行処理についての詳細を学ぶ必要があります。チャンネルを使用して停止/開始/ etcなどのゴルーチンを制御し、タスクの実行/終了の順序に関心がある場合はWaitGroupを使用します。あなたのプログラムフローを制御できないとき、goroutineは自分の人生を生きることができ、それは悪い習慣です。