aa

business/jxstore/cms/temp.go

@@ -1,8 +1,10 @@
 package cms
 
 import (
+	"bufio"
 	"fmt"
 	"net"
+	"os"
 )
 
 func TestTemp() {
@@ -16,26 +18,26 @@ func TestTemp() {
 
 func connHandler(c net.Conn) {
 	//接收终端输入
-	//reader := bufio.NewReader(os.Stdin)
+	reader := bufio.NewReader(os.Stdin)
 	//缓冲
 	buf := make([]byte, 1024)
 	fmt.Println("Please input data...")
-	//for {
+	for {
-	//读取终端输入直到读取到\n
+		//读取终端输入直到读取到\n
-	//input, err := reader.ReadString('\n')
+		input, err := reader.ReadString('\n')
-	//if err != nil {
+		if err != nil {
-	//	fmt.Println("ReadString err:", err)
+			fmt.Println("ReadString err:", err)
-	//	return
+			return
-	//}
+		}
-	//写入数据
+		//写入数据
-	c.Write([]byte("aaaaaaaaaaaaaa"))
+		c.Write([]byte(input))
-	//服务器端返回的数据写入buf
+		//服务器端返回的数据写入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]))
-	//}
 }