From a062f6a173152e92ce826abc34eb69711d035ec6 Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Thu, 24 Jun 2021 11:00:32 +0800 Subject: [PATCH] aa --- main.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/main.go b/main.go index 8dd88d681..509c06bdd 100644 --- a/main.go +++ b/main.go @@ -1,7 +1,6 @@ package main import ( - "bufio" "flag" "fmt" "io" @@ -158,7 +157,6 @@ func main() { fmt.Println("accept error:", err) break } - globals.SugarLogger.Debugf("tcp socket: %v", utils.Format4Output(c, true)) go handleConn(c) } } @@ -172,10 +170,12 @@ func handleConn(c net.Conn) { return } defer c.Close() - reader := bufio.NewReader(c) + //reader := bufio.NewReader(c) + buffer := make([]byte, 1024) for { + n, err := c.Read(buffer) //ReadString阻塞,直到读到\n - msg, err := reader.ReadString('\n') + //msg, err := reader.ReadString('\n') if err != nil { if err == io.EOF { fmt.Println("connection close") @@ -184,7 +184,7 @@ func handleConn(c net.Conn) { } return } - fmt.Println("read data:", msg) + fmt.Println("read data:", string(buffer[:n])) b := []byte("ok") c.Write(b) }