我可以net.Conn用encoding/goben/decoder包裝 TCP 的末端并通過(guò)它成功地 en/decode 一個(gè)值,但是如果我在原始連接上Decode使用 a Read,它會(huì)掛在Read:package mainimport ( "encoding/gob" "net" "log" "sync")func main() { var wg sync.WaitGroup addr := &net.TCPAddr{IP: net.ParseIP("127.0.0.1"), Port: 9000} ready := make(chan struct{}) wg.Add(1) go func() { defer wg.Done() ln, err := net.ListenTCP("tcp4", addr) if err != nil { log.Fatal("ln: ", err) } defer ln.Close() close(ready) conn, err := ln.Accept() if err != nil { log.Fatal("conn: ", err) } defer conn.Close() var out string if err := gob.NewDecoder(conn).Decode(&out); err != nil { log.Fatal("error decoding: ", err) } if "hello" != out { log.Fatalf("1 expected '%s', got '%s'", "hello", out) } b := make([]byte, 1) log.Println("ready to read 1") if _, err := conn.Read(b); err != nil { log.Fatal("error reading: ", err) } log.Println("read 1") if b[0] != 1 { log.Fatalf("2 expected '%d', got '%d'", 1, b[0]) } if _, err := conn.Write([]byte{1}); err != nil { log.Fatal("err writing2: ", err) } log.Println("done 1") }() wg.Add(1) go func() { defer wg.Done() <-ready conn, err := net.DialTCP("tcp4", nil, addr) if err != nil { log.Fatal("conn2: ", err) }}輸出:2009/11/10 23:00:00 waiting2009/11/10 23:00:00 ready to read 22009/11/10 23:00:00 ready to read 1這會(huì)在 Go Playground 中導(dǎo)致死鎖恐慌并掛在我的本地機(jī)器上 ( go version go1.6.2 darwin/amd64),盡管代碼會(huì)間歇性地在本地執(zhí)行到完成。如果我使用 anet.PipeConn或者如果我Decode使用 aWrite來(lái)代替(即在 en/decode 之后交換Read/的順序),則不會(huì)發(fā)生這種情況Write。當(dāng)我刪除 en/decode 代碼時(shí),en/decode 之后的代碼也可以單獨(dú)工作。是什么導(dǎo)致了這個(gè)掛起?這感覺(jué)像是一個(gè)緩存問(wèn)題,但我不知道為什么Write不會(huì)刷新或?yàn)槭裁碦ead不會(huì)提取最新的可用數(shù)據(jù),或者為什么這個(gè)問(wèn)題只在gob涉及編碼/解碼時(shí)出現(xiàn)。
TCP `net.Conn.Read` 在使用`encoding/gob` 解碼器后掛起
慕尼黑8549860
2022-01-10 17:26:26