Mengapa Sambungan Soket Go Unix saya Sehala, dan Bagaimana Saya Boleh Membetulkannya?

Soket Unix dalam Go: Isu Sambungan Satu Arah

Satu cabaran biasa apabila bekerja dengan soket Unix dalam Go ialah sambungan kadangkala menjadi satu arah. Walaupun data boleh diterima oleh satu pihak, penghantaran balik data tidak menghasilkan balasan.

Mari kita analisa contoh kod yang disediakan dalam urutan forum untuk mengenal pasti punca:

Kod Pelayan:

func echoServer(c net.Conn) {
    for {
        buf := make([]byte, 512)
        nr, err := c.Read(buf)
        if err != nil {
            return
        }

        data := buf[0:nr]
        fmt.Printf("Received: %v", string(data))
        _, err = c.Write(data)
        if err != nil {
            panic("Write: " + err.String())
        }
    }
}

Pelanggan Kod:

func main() {
    c,err := net.Dial("unix","", "/tmp/echo.sock")
    if err != nil {
        panic(err.String())
    }
    for {
        _,err := c.Write([]byte("hi\n"))
        if err != nil {
            println(err.String())
        }
        time.Sleep(1e9)
    }
}

Setelah menyemak kod, kami mendapati pelanggan tidak membaca respons yang dihantar oleh pelayan. Ini menyebabkan masalah di mana pelanggan terus menghantar data ke pelayan tetapi tidak pernah menerima respons.

Penyelesaian:

Untuk menyelesaikan isu ini, kami perlu menambah goroutine dalam klien untuk mengendalikan membaca respons daripada pelayan. Selepas membuat pengubahsuaian ini, kod akan beroperasi seperti yang dimaksudkan:

Kod Pelayan yang Disemak:

func echoServer(c net.Conn) {
    for {
        buf := make([]byte, 512)
        nr, err := c.Read(buf)
        if err != nil {
            return
        }

        data := buf[0:nr]
        println("Server got:", string(data))
        _, err = c.Write(data)
        if err != nil {
            log.Fatal("Write: ", err)
        }
    }
}

Kod Pelanggan yang Disemak:

func reader(r io.Reader) {
    buf := make([]byte, 1024)
    for {
        n, err := r.Read(buf[:])
        if err != nil {
            return
        }
        println("Client got:", string(buf[0:n]))
    }
}

func main() {
    c, err := net.Dial("unix", "/tmp/echo.sock")
    if err != nil {
        panic(err)
    }
    defer c.Close()

    go reader(c)
    for {
        _, err := c.Write([]byte("hi"))
        if err != nil {
            log.Fatal("write error:", err)
            break
        }
        time.Sleep(1e9)
    }
}

Dengan perubahan ini, pelayan boleh menerima data daripada klien dan juga menghantar respons kembali, mengakibatkan saluran komunikasi dua hala.

Atas ialah kandungan terperinci Mengapa Sambungan Soket Go Unix saya Sehala, dan Bagaimana Saya Boleh Membetulkannya?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!