server.go 718 B

12345678910111213141516171819202122232425262728293031323334353637
  1. package main
  2. import (
  3. "fmt"
  4. "net"
  5. )
  6. func main() {
  7. fmt.Println("Starting the server ...")
  8. // 创建 listener
  9. listener, err := net.Listen("tcp", "localhost:50000")
  10. if err != nil {
  11. fmt.Println("Error listening", err.Error())
  12. return //终止程序
  13. }
  14. // 监听并接受来自客户端的连接
  15. for {
  16. conn, err := listener.Accept()
  17. if err != nil {
  18. fmt.Println("Error accepting", err.Error())
  19. return // 终止程序
  20. }
  21. go doServerStuff(conn)
  22. }
  23. }
  24. func doServerStuff(conn net.Conn) {
  25. for {
  26. buf := make([]byte, 512)
  27. len, err := conn.Read(buf)
  28. if err != nil {
  29. fmt.Println("Error reading", err.Error())
  30. return //终止程序
  31. }
  32. fmt.Printf("Received data: %v", string(buf[:len]))
  33. }
  34. }