在 Go 中写入客户端 UDP 套接字

Question

我正在寻找一个很好的解决方案，用于使用 Go 语言的 UDP 套接字进行客户端/服务器通信。

我在网上找到的例子告诉我如何向服务器发送数据，但他们没有教如何将它们发送回客户端。

为了演示，我的程序执行以下操作：

我的客户端程序在 4444 端口上创建一个套接字，如下所示：

 con, err := net.Dial("udp", "127.0.0.1:4444")

我向服务器发送了一个字符串和本地地址，因此它可以打印该字符串并发送一条 OK 消息。我为此使用 gob：

 enc := gob.NewEncoder(con)
enc.Encode(Data{"test", con.LocalAddr().String()})

我的数据结构如下所示：

 type Data struct{
    Msg string
    Addr string
}

我的服务器侦听 4444 端口并正确解码 Gob，但我怎样才能发回 OK 消息？我正在使用客户端地址这样做（在服务器 .go 文件上）：

 con, err := net.Dial("udp", data.Addr)

然后，我得到一个错误代码：

 write udp 127.0.0.1:35290: connection refused

当客户端尝试连接到服务器的端口 4444 时，客户端会创建一个具有随机数（在本例中为 35290）的端口，以便它们可以进行通信。我知道我不应该将客户端的地址传递给服务器，但是 conn.RemoteAddress() 不起作用。发现客户地址的解决方案将不胜感激。

Obs.: 我知道有 ReadFromUDP，所以我可以读取包。我应该读取它，发现客户端的地址，并将数据发送给 Gob 以便它可以解码吗？

原文由 Aleksandrus 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

检查以下示例以了解通过 UDP 进行的客户端/服务器通信。 sendResponse 例程用于将响应发送回客户端。

udpclient.go

 package main
import (
    "fmt"
    "net"
    "bufio"
)

func main() {
    p :=  make([]byte, 2048)
    conn, err := net.Dial("udp", "127.0.0.1:1234")
    if err != nil {
        fmt.Printf("Some error %v", err)
        return
    }
    fmt.Fprintf(conn, "Hi UDP Server, How are you doing?")
    _, err = bufio.NewReader(conn).Read(p)
    if err == nil {
        fmt.Printf("%s\n", p)
    } else {
        fmt.Printf("Some error %v\n", err)
    }
    conn.Close()
}

udpserver.go

 package main
import (
    "fmt"
    "net"
)

func sendResponse(conn *net.UDPConn, addr *net.UDPAddr) {
    _,err := conn.WriteToUDP([]byte("From server: Hello I got your message "), addr)
    if err != nil {
        fmt.Printf("Couldn't send response %v", err)
    }
}

func main() {
    p := make([]byte, 2048)
    addr := net.UDPAddr{
        Port: 1234,
        IP: net.ParseIP("127.0.0.1"),
    }
    ser, err := net.ListenUDP("udp", &addr)
    if err != nil {
        fmt.Printf("Some error %v\n", err)
        return
    }
    for {
        _,remoteaddr,err := ser.ReadFromUDP(p)
        fmt.Printf("Read a message from %v %s \n", remoteaddr, p)
        if err !=  nil {
            fmt.Printf("Some error  %v", err)
            continue
        }
        go sendResponse(ser, remoteaddr)
    }
}

原文由 Nipun Talukdar 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 2

你好_echo.go

  package main

 import (
     "bufio"
     "fmt"
     "net"
     "time"
 )

 const proto, addr = "udp", ":8888"

 func main() {

     go func() {
         conn, _ := net.ListenPacket(proto, addr)
         buf := make([]byte, 1024)
         n, dst, _ := conn.ReadFrom(buf)
         fmt.Println("serv recv", string(buf[:n]))
         conn.WriteTo(buf, dst)
     }()

     time.Sleep(1 * time.Second)

     conn, _ := net.Dial(proto, addr)
     conn.Write([]byte("hello\n"))
     buf, _, _ := bufio.NewReader(conn).ReadLine()
     fmt.Println("clnt recv", string(buf))
 }

原文由 sof 发布，翻译遵循 CC BY-SA 4.0 许可协议