diff --git a/fsv2/discovery/discovery.go b/fsv2/discovery/discovery.go index 5815f9e..e4551f5 100644 --- a/fsv2/discovery/discovery.go +++ b/fsv2/discovery/discovery.go @@ -13,10 +13,10 @@ const separator = "|" func Listen() { // 创建udp - addr, err := net.ResolveUDPAddr("udp", config.G.LocalIP) + addr, err := net.ResolveUDPAddr("udp", config.G.LocalIP+":"+config.G.Port) ChkError(err) // - conn, err := net.ListenUDP("updp", addr) + conn, err := net.ListenUDP("udp", addr) ChkError(err) // 延迟关闭 defer conn.Close() @@ -33,7 +33,9 @@ func Listen() { continue } + // 处理接收到的信息 message := string(buf[:n]) + // 对消息进行切割 parts := strings.Split(message, separator) if len(parts) != 2 { fmt.Printf("Received malformed message from %s: %s\n", remoteAddr, message) @@ -41,13 +43,22 @@ func Listen() { } // 切割 + msgtype := parts[0] + // 有这个的话就进行操作 + // 告知后面的程序执行下面的目录 + + if msgtype == "xdml" { + opdir := parts[1] + // 查找对应的文件目录 + fmt.Print("opertation directory is :%v", opdir) + } fmt.Print("parts from udp read :%v", parts) } } func ChkError(err error) { if err != nil { - fmt.Fprint(os.Stderr, "Faltat error", err.Error()) + fmt.Fprintln(os.Stderr, "Faltat error:", err.Error()) os.Exit(1) } }