无法通过 net.Conn.Read 方法从 UNIX 套接字读取数据

使用 Go 与服务进行 UNIX 套接字通信时，net.Conn.Read 方法无法读取数据。尽管写入操作成功，但读取操作却是非阻塞的，并立即返回零长度。这与预期行为不符，读取操作应该被阻塞。

我正在尝试使用 go 与服务进行简单的 unix 套接字通信。为了进行测试，我创建了一个像这样的套接字：

$ nc -vlu /tmp/sock
bound on /tmp/sock
listening on /tmp/sock

在 go 中，我 net.dial 并尝试写一些东西，然后阅读。我在 nc 控制台中看到写入的数据，所以我知道这是有效的。但 net.conn.read 操作看起来是非阻塞的，并且会立即以零长度返回。从我读到的所有内容和我看到的示例来看，此操作应该被阻止。

buf := make([]byte, 0, 4096)
ctl, err := net.dial("unix", "/tmp/sock")
for {
    ctl.write([]byte("test write\n"))
    n, err := ctl.read(buf)
    fmt.printf("len:%v, data:%v, err:%v", n, buf, err)
}

我看到连接已建立并且数据已写入...

connection received on /tmp/sock
test write
test write
test write
test write
...

但是go控制台循环无阻塞，报告长度为零并且没有错误

Len:0, Data:[], err:<nil>
Len:0, Data:[], err:<nil>
Len:0, Data:[], err:<nil>
Len:0, Data:[], err:<nil>
...

当然，如果我在 nc 控制台中输入任何内容，go 程序输出中不会发生任何有趣的事情。

知道我做错了什么吗？

解决方案

简短回答

buf := make([]byte, 0, 4096)

此代码使用 len=0 创建缓冲区!!!

这样做

buf := make([]byte, 4096)

示例

这是我使用的一些示例，它们都有效。

实际上，套接字读写应该发生在两个goroutines中

package main

import (
    "bufio"
    "fmt"
    "io"
    "net"
    "time"
)

func main() {
    buf := make([]byte, 0, 4096)
    fmt.Println(buf)
    main03()
}

func main01() {
    // nc -vlU /tmp/sock0120
    ctl, err := net.Dial("unix", "/tmp/sock0120")
    if err != nil {
        fmt.Println(err)
        return
    }
    reader := bufio.NewReader(ctl)
    for {
        time.Sleep(time.Second)
        ctl.Write([]byte("test write\n"))
        msg, err := reader.ReadString('\n')
        fmt.Printf("Len:%v, Data:%v, err:%v\n", len(msg), msg, err)
    }
}

func main02() {
    // nc -vlU /tmp/sock0120
    buf := make([]byte, 4)
    ctl, err := net.Dial("unix", "/tmp/sock0120")
    if err != nil {
        fmt.Println(err)
        return
    }
    reader := bufio.NewReader(ctl)
    for {
        time.Sleep(time.Second)
        ctl.Write([]byte("test write\n"))
        n, err := io.ReadFull(reader, buf)
        fmt.Printf("Len:%v, Data:%v, err:%v\n", n, buf, err)
    }
}

func main03() {
    // nc -vlU /tmp/sock0120
    buf := make([]byte, 4)
    ctl, err := net.Dial("unix", "/tmp/sock0120")
    if err != nil {
        fmt.Println(err)
        return
    }
    for {
        time.Sleep(time.Second)
        ctl.Write([]byte("test write\n"))
        n, err := ctl.Read(buf)
        fmt.Printf("Len:%v, Data:%v, err:%v\n", n, buf, err)
    }
}

理论要掌握，实操不能落！以上关于《无法通过 net.Conn.Read 方法从 UNIX 套接字读取数据》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！