为什么我的 Go Unix Socket 连接是单向的，如何修复？

Go 中的 Unix 套接字：单向连接问题

在 Go 中使用 Unix 套接字时的一个常见挑战是连接有时可能会变成单向。虽然一方可以接收数据，但发回数据会导致无响应。

让我们分析一下论坛帖子中提供的代码示例来找出原因：

服务器代码：

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

客户端代码：

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

查看代码后，我们注意到客户端没有读取服务器发送的响应。这导致客户端不断向服务器发送数据但从未收到响应的问题。

解决方案：

要解决此问题，我们需要添加客户端中的 goroutine 处理从服务器读取响应。进行此修改后，代码将按预期运行：

修订的服务器代码：

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

修订的客户端代码：

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

通过这些更改，服务器可以从客户端接收数据并发回响应，从而产生双向通信通道。

以上是为什么我的 Go Unix Socket 连接是单向的，如何修复？的详细内容。更多信息请关注PHP中文网其他相关文章！