UdpClient.go 870 B

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. package main
  2. import (
  3. "./lib/com"
  4. "fmt"
  5. "net"
  6. "time"
  7. )
  8. func main() {
  9. // 远程服务器地址
  10. remoteAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8888")
  11. if err != nil {
  12. fmt.Println("Error resolving address:", err)
  13. return
  14. }
  15. // 创建UDP连接
  16. conn, err := net.DialUDP("udp", nil, remoteAddr)
  17. if err != nil {
  18. fmt.Println("Error creating UDP connection:", err)
  19. return
  20. }
  21. defer conn.Close()
  22. for {
  23. // 发送数据到服务器
  24. message := com.RandBytes(2000)
  25. _, err = conn.Write(message)
  26. if err != nil {
  27. fmt.Println("Error sending data:", err)
  28. return
  29. }
  30. // 接收服务器回复
  31. buffer := make([]byte, 1024)
  32. n, _, err := conn.ReadFromUDP(buffer)
  33. if err != nil {
  34. fmt.Println("Error receiving data:", err)
  35. return
  36. }
  37. fmt.Println("Received message from server:", string(buffer[:n]))
  38. time.Sleep(time.Second * 2)
  39. }
  40. }