我想弄清楚如何序列化一個結構并通過 UDP 將它發(fā)送到我的服務器。我設法實際發(fā)送了該結構，但在收到時我沒有任何值......除非我靜態(tài)添加一個數字。在下面的代碼中，我將一個 UDP 數據包發(fā)送到端口 8080，其中的序號是 0-9 中的數字。我給它加上 + 1 來表明我的觀點。我期望的是在接收端我應該在消息第 1-10 部分中收到。但我唯一收到的是數字 1，這意味著該變量應設置為 0。為了驗證我是否真的發(fā)送了 0，我打印了我收到的緩沖區(qū)的長度，它是它應該是的正確長度。所以我一定是在解碼方面做錯了什么。發(fā)送功能：func send_udp() { dst, _ := net.ResolveUDPAddr("udp", "localhost:8080") conn, _ := net.ListenPacket("udp", ":0") defer conn.Close() var buf bytes.Buffer encoder := gob.NewEncoder(&buf) for n := 0; n < 10; n++ { var msg int64 = int64(n) + 1 packet := &Packet{[]int{5}, msg} encoder.Encode(packet) conn.WriteTo(buf.Bytes(), dst) }}監(jiān)聽功能：func listen_udp() { dst, _ := net.ResolveUDPAddr("udp", "localhost:8080") conn, _ := net.ListenUDP("udp", dst) defer conn.Close() for { buf := make([]byte, 4096) n, _, _ := conn.ReadFromUDP(buf[:]) fmt.Println(n) dec := gob.NewDecoder(bytes.NewReader(buf[:n])) p := Packet{} dec.Decode(&p) if len(p.Parts) != 0 { fmt.Printf("Received: %+v\n", p) } }}我要發(fā)送的結構：type Packet struct { Parts []int Message int64 }
1 回答
湖上湖
TA貢獻2003條經驗 獲得超2個贊
在我的本地機器上實現(xiàn)了這個。是的，請檢查您的錯誤，但幸運的是，沒有返回任何內容。這是我為解決問題所做的工作。在send_udp初始化Buffer和EncoderINSIDE for 循環(huán)中。
func send_udp() error {
dst, err := net.ResolveUDPAddr("udp", "localhost:8080")
if err != nil {
return err
}
conn, err := net.ListenPacket("udp", ":0")
if err != nil {
return err
}
defer conn.Close()
for n := 0; n < 10; n++ {
// inside for loop
var buf bytes.Buffer
encoder := gob.NewEncoder(&buf)
var msg int64 = int64(n) + 1
packet := &Packet{[]int{5}, msg}
err = encoder.Encode(packet)
if err != nil {
return err
}
_, err = conn.WriteTo(buf.Bytes(), dst)
if err != nil {
return err
}
}
return nil
}
Buffer請注意，在for 循環(huán)外部聲明時，實際上Packet每次添加新循環(huán)時都會發(fā)送前一個循環(huán)，因此當您在函數中n打印返回值時會增加值，但每次都只解碼第一個循環(huán)。所以如果你打算一次發(fā)送它們，你將不得不在你的函數中循環(huán)。ReadFromUDPlisten_udpDecoderlisten_udp
- 1 回答
- 0 關注
- 157 瀏覽
添加回答
舉報
0/150
提交
取消