diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index abdeb8435..c44f4a66d 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1972,20 +1972,23 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { // } // } //} - - server := "print.jxcs.net:8000" - tcpAddr, err := net.ResolveTCPAddr("tcp4", server) - if err != nil { - os.Exit(1) - return err + for i := 0; i < 2; i++ { + server := "print.jxcs.net:8000" + tcpAddr, err := net.ResolveTCPAddr("tcp4", server) + if err != nil { + os.Exit(1) + 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) - if err != nil { - return err - } - fmt.Println("result ,", connHandler(conn, "1e000f02000151323032313036313530303030313100000033")) + //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) - result = string(buf[:n]) + for { + n, _ := c.Read(buf) + result = string(buf[:n]) + if result != "" { + fmt.Println("msg result ", result) + break + } + } //服务器端回传的信息 return result }