aa

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)
+			//cnt, err := c.Read(buf)
-			if err != nil {
+			//if err != nil {
-				fmt.Println("Read err:", err)
+			//	fmt.Println("Read err:", err)
-				return
+			//	return
-			}
+			//}
 			//服务器端回传的信息
-			fmt.Println("server response:", string(buf[0:cnt]))
+			//fmt.Println("server response:", string(buf[0:cnt]))
 		}
 	}()
 }