From 1d574ae659d977ec0f228579a7f887dac4a5823c Mon Sep 17 00:00:00 2001 From: barnettZQG Date: Mon, 15 Mar 2021 19:50:36 +0800 Subject: [PATCH] change server --- cmd/client/client.go | 13 +++++++++---- cmd/server/server.go | 4 ++-- 2 files changed, 11 insertions(+), 6 deletions(-) diff --git a/cmd/client/client.go b/cmd/client/client.go index 7048d26..a8631f9 100644 --- a/cmd/client/client.go +++ b/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) } } diff --git a/cmd/server/server.go b/cmd/server/server.go index aaf4056..47bfc96 100644 --- a/cmd/server/server.go +++ b/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 } -- 2.21.0