package mainimport ( "fmt" "net" "strings")func main() { listener, err := net.Listen("tcp", "127.0.0.1:8000") if err != nil { fmt.Println(err.Error()) return } defer listener.Close() //接收多个用户 for { conn, err := listener.Accept() if err != nil { fmt.Println(err.Error()) return } //处理用户的连接 go handleConn(conn) }} func handleConn(conn net.Conn){ defer conn.Close() buff := make([]byte, 1024) for { n, err := conn.Read(buff) if err != nil { fmt.Println(err) return } content := string(buff[:n]) fmt.Println("content=", string(buff[:n])) content = strings.ToUpper(content) conn.Write([]byte(content)) } }
go socket 服务端处理多用户
package mainimport ( "fmt" "net" "strings")func main() { listener, err := net.Listen("tcp", "127.0.0.1:8000") if err != nil { fmt.Println(err.Error()) return } defer listener.C
0
0
0
day27:下一篇
精彩评论