diff --git a/main.go b/main.go index ef5724ac2..8dfeea279 100644 --- a/main.go +++ b/main.go @@ -1,7 +1,6 @@ package main import ( - "bufio" "flag" "fmt" "io" @@ -172,10 +171,10 @@ func handleConn(c net.Conn) { return } defer c.Close() - reader := bufio.NewReader(c) + //reader := bufio.NewReader(c) + buffer := make([]byte, 1024) for { - //ReadString阻塞,直到读到\n - msg, err := reader.ReadString('\n') + n, err := c.Read(buffer) if err != nil { if err == io.EOF { fmt.Println("connection close") @@ -184,7 +183,7 @@ func handleConn(c net.Conn) { } return } - fmt.Println("read data:", msg) + fmt.Println("read data:", buffer[:n]) b := []byte("ok") c.Write(b) }