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)
	}
}