aaa

business/jxstore/cms/temp.go

@@ -7,6 +7,10 @@ import (
 	"os"
 )
 
+var (
+	textChan chan string
+)
+
 func TestTemp() {
 	server := "127.0.0.1:8000"
 	tcpAddr, err := net.ResolveTCPAddr("tcp4", server)
@@ -23,6 +27,10 @@ func TestTemp() {
 	connHandler(conn)
 }
 
+func TestTemp2(data string) {
+	textChan <- data
+}
+
 func connHandler(c net.Conn) {
 	//接收终端输入
 	//reader := bufio.NewReader(os.Stdin)
@@ -30,15 +38,16 @@ func connHandler(c net.Conn) {
 	//buf := make([]byte, 1024)
 	fmt.Println("Please input data...")
 	go func() {
-		for i := 0; i <= 10; i++ {
+		for {
 			//读取终端输入直到读取到\n
 			//input, err := reader.ReadString('\n')
 			//if err != nil {
 			//	fmt.Println("ReadString err:", err)
 			//	return
 			//}
+			s := <-textChan
 			//写入数据
-			n, err := c.Write([]byte(fmt.Sprintf("input 1111111111 %d", i)))
+			n, err := c.Write([]byte(s))
 			if err != nil {
 				fmt.Println("Write err:", err, n)
 				return