From c246a943653fd07510f700c4394f27056dd78f98 Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Thu, 24 Jun 2021 09:21:06 +0800 Subject: [PATCH] aa --- business/jxstore/cms/temp.go | 29 +++++++++++++++++++---------- 1 file changed, 19 insertions(+), 10 deletions(-) diff --git a/business/jxstore/cms/temp.go b/business/jxstore/cms/temp.go index 8684f5257..f436f3e94 100644 --- a/business/jxstore/cms/temp.go +++ b/business/jxstore/cms/temp.go @@ -2,11 +2,20 @@ package cms import ( "fmt" + "git.rosy.net.cn/baseapi/utils" "net" + "os" ) func TestTemp() { - conn, err := net.Dial("tcp", ":8000") + server := "127.0.0.1:8000" + tcpAddr, err := net.ResolveTCPAddr("tcp4", server) + if err != nil { + fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error()) + os.Exit(1) + } + fmt.Println("tcpaddr", utils.Format4Output(tcpAddr, true)) + conn, err := net.DialTCP("tcp", nil, tcpAddr) if err != nil { fmt.Println("Dial err:", err) return @@ -18,10 +27,10 @@ func connHandler(c net.Conn) { //接收终端输入 //reader := bufio.NewReader(os.Stdin) //缓冲 - buf := make([]byte, 1024) + //buf := make([]byte, 1024) fmt.Println("Please input data...") go func() { - for { + for i := 0; i <= 10; i++ { //读取终端输入直到读取到\n //input, err := reader.ReadString('\n') //if err != nil { @@ -29,19 +38,19 @@ func connHandler(c net.Conn) { // return //} //写入数据 - n, err := c.Write([]byte("input 1111111111")) + n, err := c.Write([]byte(fmt.Sprintf("input 1111111111 %d", i))) if err != nil { fmt.Println("Write err:", err, n) return } //服务器端返回的数据写入buf - cnt, err := c.Read(buf) - if err != nil { - fmt.Println("Read err:", err) - return - } + //cnt, err := c.Read(buf) + //if err != nil { + // fmt.Println("Read err:", err) + // return + //} //服务器端回传的信息 - fmt.Println("server response:", string(buf[0:cnt])) + //fmt.Println("server response:", string(buf[0:cnt])) } }() }