aa

business/jxstore/tempop/tempop.go

@@ -1972,20 +1972,23 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	//		}
 	//	}
 	//}
-
+	for i := 0; i < 2; i++ {
-	server := "print.jxcs.net:8000"
+		server := "print.jxcs.net:8000"
-	tcpAddr, err := net.ResolveTCPAddr("tcp4", server)
+		tcpAddr, err := net.ResolveTCPAddr("tcp4", server)
-	if err != nil {
+		if err != nil {
-		os.Exit(1)
+			os.Exit(1)
-		return err
+			return err
+		}
+		conn, err := net.DialTCP("tcp", nil, tcpAddr)
+		if err != nil {
+			return err
+		}
+		go connHandler(conn, "1e000f02000151323032313036313530303030313"+utils.Int2Str(i)+"00000033")
 	}
-	conn, err := net.DialTCP("tcp", nil, tcpAddr)
+	//fmt.Println("result ,", connHandler(conn, "1e000f02000151323032313036313530303030313100000033"))
-	if err != nil {
-		return err
-	}
-	fmt.Println("result ,", connHandler(conn, "1e000f02000151323032313036313530303030313100000033"))
 	return err
 }
+
 func connHandler(c net.Conn, msg string) (result string) {
 	defer c.Close()
 	//缓冲
@@ -1993,8 +1996,14 @@ func connHandler(c net.Conn, msg string) (result string) {
 	//写入数据
 	c.Write([]byte(msg))
 	//服务器端返回的数据写入buf
-	n, _ := c.Read(buf)
+	for {
-	result = string(buf[:n])
+		n, _ := c.Read(buf)
+		result = string(buf[:n])
+		if result != "" {
+			fmt.Println("msg result ", result)
+			break
+		}
+	}
 	//服务器端回传的信息
 	return result
 }