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

我在Internet上找到的示例向我展示了如何将数据发送到服务器,但它们并没有教我如何将数据发送回客户端.

为了演示,我的程序执行以下操作:

我的客户端程序在4444端口上创建套接字,如下所示:

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

我向服务器发送了一个字符串和本地地址,这样它就可以打印字符串并发送OK消息.我使用gob来实现以下目的:

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

我的数据 struct 如下所示:

type Data struct{
    Msg string
    Addr string
}

我的服务器监听4444端口并正确解码Gob,但我如何才能将OK消息发送回?我正在使用客户端地址(在server.go文件上)执行此操作:

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

然后,我得到一个错误代码:

write udp 127.0.0.1:35290: connection refused

当客户端try 连接到服务器的端口4444时,客户端会创建一个具有随机数(在本例中为35290)的端口,以便它们可以通信.我知道我不应该将客户机的地址传递给服务器,但是cont.RemoteAddress()不起作用.如果能找到客户端地址的解决方案,我们将不胜感激.

我知道有ReadFromUDP,所以我可以看Package.我应该读取它,发现客户端的地址,然后将数据发送到Gob,以便它可以解码吗?

推荐答案

判断以下示例,了解UDP上的客户机/服务器通信.sendResponse routine 用于将响应发送回客户端.

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

Go相关问答推荐

如何模拟嵌入. FS?

Golang测试容器,无法使网络正常工作

切换选项卡时,Goland IDE中的光标自动转移

无法在32位计算机上运行Golang应用程序

使用 Golang 获取目录磁盘使用情况

无法从主域访问子域:无Access-Control-Allow-Origin

使用 os/exec 和在命令行执行之间的结果莫名其妙地不同

无法使用 gocsv 读取引用字段

如何确定作为函数参数传递的指针是否正在被修改或副本是否正在被修改?

如何使用 fyne Go 使用 canvas.NewText() 使文本可滚动

如何将文件上传到 Google Drive,并与使用服务帐户和 Golang 的任何人共享

为什么 Go 被认为是部分抢占式的?

此代码如何生成内存对齐切片?

Golang泛型在用作 map 元素时不起作用

gorm 获取列名

如何优雅地映射到 Go 中返回可变长度数组的方法?

什么是无效字符实体 &ccb

如何从字符串中删除多个换行符`\n`但只保留一个?

Dynamodb.ScanInput - 不能使用expr.Names()(类型 map[string]*string)作为类型 map[string]string

如何在 Gorm 中获得特定日期的最大值?