处理xmdl的协议的

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)
 	}
 }