12345678910111213141516171819202122232425262728293031323334353637383940414243444546 |
- package main
- import (
- "./lib/com"
- "fmt"
- "net"
- "time"
- )
- func main() {
- // 远程服务器地址
- remoteAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8888")
- if err != nil {
- fmt.Println("Error resolving address:", err)
- return
- }
- // 创建UDP连接
- conn, err := net.DialUDP("udp", nil, remoteAddr)
- if err != nil {
- fmt.Println("Error creating UDP connection:", err)
- return
- }
- defer conn.Close()
- for {
- // 发送数据到服务器
- message := com.RandBytes(2000)
- _, err = conn.Write(message)
- if err != nil {
- fmt.Println("Error sending data:", err)
- return
- }
- // 接收服务器回复
- buffer := make([]byte, 1024)
- n, _, err := conn.ReadFromUDP(buffer)
- if err != nil {
- fmt.Println("Error receiving data:", err)
- return
- }
- fmt.Println("Received message from server:", string(buffer[:n]))
- time.Sleep(time.Second * 2)
- }
- }
|