【原创】一个go语言小项目实例：通过select监控channel并阻塞

package main



import (

"fmt"

"time"

) 



func generateString(strings chan string) {

    time.Sleep(3*time.Second)

    strings <- "Monday"

    time.Sleep(5*time.Second)

    strings <- "Tuesday"

    time.Sleep(3*time.Second)

    strings <- "Wednesday"

    time.Sleep(5*time.Second)

    strings <- "Thursday"

    strings <- "Friday"

    strings <- "Saturday"

    strings <- "Sunday"

    close(strings)

}





func monitor(cancel chan string) {



    var stop bool = false

        for {

            time.Sleep(1*time.Second)

            fmt.Println("i am alive!")

            select {

                case can := <- cancel:

                    if can == "cancel" {

                        fmt.Println("break!")

                        stop = true

                        break

                    }

                    

            }



            if stop {

                break

            }

        }





    fmt.Println("good bye!")

}



func main() {

    //strings := make(chan string) // 无缓冲channel

    cancel_sig := make(chan string)



    //go generateString(strings)



    //for s := range strings {

    //    fmt.Println(s)

    //}



    go monitor(cancel_sig)



    time.Sleep(10*time.Second)



    cancel_sig <- "cancel"



    for {

        time.Sleep(5*time.Second)

        fmt.Println("go away!")

        break

    }

}

package notify;

 

import (

    "github.com/fsnotify/fsnotify"

    "github.com/smtp-http/filemonitor_macmini/conn"

    "github.com/smtp-http/filemonitor_macmini/config"

    "log"

    "fmt"

    "path/filepath"

    "path"

    "io/ioutil"

    "sync"

)



type FileMonitor struct {

    m_tcpserver *conn.TcpServer

}



var instance *FileMonitor

var once sync.Once

 

func GetFileMonitorInstance() *FileMonitor {

    once.Do(func() {

        instance = &FileMonitor{}

    })

    return instance

}



func (f *FileMonitor)SetTcpserver(server *conn.TcpServer) {

    f.m_tcpserver = server

}

 

func (f *FileMonitor)Monitor(cancel chan string) {



    var stop bool = false



    //创建一个监控对象

    watch, err := fsnotify.NewWatcher();

    if err != nil {

        log.Fatal(err);

    }

    defer watch.Close();

    //

    err = watch.Add(config.GetConfig().Path);

    if err != nil {

        log.Fatal(err);

    }

    //我们另启一个goroutine来处理监控对象的事件



    for {

        fmt.Println("--- 1")

        if stop {

            break

        }

        select {

            case ev := <-watch.Events:

                {

                    //判断事件发生的类型，如下5种

                    // Create 创建

                    // Write 写入

                    // Remove 删除

                    // Rename 重命名

                    // Chmod 修改权限

                    if ev.Op&fsnotify.Create == fsnotify.Create {

                        fmt.Println("创建文件 : ", ev.Name);

                    }

                    if ev.Op&fsnotify.Write == fsnotify.Write {

                        fmt.Println("写入文件 : ", ev.Name);

                        paths, fileName := filepath.Split(ev.Name) 

                        fmt.Println(paths, fileName) //获取路径中的目录及文件名 E:\data\ test.txt 

                        fmt.Println(filepath.Base(ev.Name)) //获取路径中的文件名test.txt 

                        



                        if path.Ext(ev.Name) == config.GetConfig().FileExtension {

                            fmt.Println(path.Ext(ev.Name)) //获取路径中的文件的后缀 .txt

                            b, err := ioutil.ReadFile(ev.Name) 

                            if err != nil { 

                                fmt.Print(err) 

                            } 

                            fmt.Println(b) 

                            //str := string(b) 

                        

                            f.m_tcpserver.Notify(b)

                            configure := config.GetConfig()

                            if configure.HttpEnable == true {

                                httpClient := conn.GetHttpClientInstance()

                                httpClient.HttpPost(b)

                            }



                        }



                        

                    }



                    if ev.Op&fsnotify.Remove == fsnotify.Remove {

                        fmt.Println("删除文件 : ", ev.Name);

                    }



                    if ev.Op&fsnotify.Rename == fsnotify.Rename {

                        fmt.Println("重命名文件 : ", ev.Name);

                    }

                    

                    if ev.Op&fsnotify.Chmod == fsnotify.Chmod {

                        fmt.Println("修改权限 : ", ev.Name);

                    }

                }



            case can := <- cancel:

                if can == "cancel" {

                    fmt.Println("break!")

                    stop = true

                    break

                }

            case err := <-watch.Errors:

                {

                    log.Println("error : ", err);

                    return;

                }

        }

    }



    fmt.Println("good bye!")

}