修改目录处理逻辑

fsv2/discovery/discovery.go

@@ -37,10 +37,10 @@ func Listen() {
 		message := string(buf[:n])
 		// 对消息进行切割
 		parts := strings.Split(message, separator)
-		if len(parts) != 2 {
-			fmt.Printf("Received malformed message from %s: %s\n", remoteAddr, message)
-			continue
-		}
+		// if len(parts) != 2 {
+		// 	fmt.Printf("Received malformed message from %s: %s\n", remoteAddr, message)
+		// 	continue
+		// }
 
 		// 切割
 		msgtype := parts[0]
@@ -50,9 +50,13 @@ func Listen() {
 		if msgtype == "xdml" {
 			opdir := parts[1]
 			// 查找对应的文件目录
-			fmt.Print("opertation directory is :%v", opdir)
+			err := os.MkdirAll(opdir, os.ModePerm)
+			if err != nil {
+				fmt.Printf(" create osdir is error:%s\n", err)
+			}
+
 		}
-		fmt.Print("parts from udp read :%v", parts)
+		fmt.Println(" parts from udp read :", parts)
 	}
 }