change server

cmd/client/client.go

@@ -9,8 +9,10 @@ import (
 )
 
 func main() {
+	//address := "106.15.152.33:27065"
 	address := "127.0.0.1:8080"
-	con, err := net.Dial("udp", address)
+	udpAddr, err := net.ResolveUDPAddr("udp", address)
+	con, err := net.DialUDP("udp", nil, udpAddr)
 	if err != nil {
 		logrus.Errorf("create udp client failure %s", err.Error())
 	}
@@ -19,8 +21,11 @@ func main() {
 		con.Write([]byte(fmt.Sprintf("hello word %d", n)))
 		n++
 		data := make([]byte, 1024)
-		con.Read(data)
-		fmt.Println(string(data))
-		time.Sleep(time.Second * 5)
+		n, _, err := con.ReadFromUDP(data)
+		if err != nil {
+			fmt.Println("failed read udp msg, error: " + err.Error())
+		}
+		fmt.Println(string(data[:n]))
+		time.Sleep(time.Second * 3)
 	}
 }

cmd/server/server.go

@@ -15,13 +15,13 @@ var limitChan = make(chan bool, 1000)
 func udpProcess(conn *net.UDPConn, index int) {
 	// 最大读取数据大小
 	data := make([]byte, 1024)
-	n, _, err := conn.ReadFromUDP(data)
+	n, rAddr, err := conn.ReadFromUDP(data)
 	if err != nil {
 		fmt.Println("failed read udp msg, error: " + err.Error())
 	}
 	str := string(data[:n])
 	fmt.Println("receive from client, data:" + str)
-	conn.Write([]byte(fmt.Sprintf("receive %d", index)))
+	conn.WriteToUDP([]byte(fmt.Sprintf("receive %d", index)), rAddr)
 	<-limitChan
 }