liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
suyl
2021-06-24 10:15:14 +08:00
parent dc2ef79fc0
commit e72e5ad83f
1 changed files with 29 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
main.go
View File

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