通过 unix 域套接字请求 http 服务时出现损坏的管道

Question

# go version
go version go1.13.9 linux/amd64

# uname -a
Linux iZ8vbaym9jmge8qd5hlcpiZ 4.15.0-111-generic #112-Ubuntu SMP Thu Jul 9 20:32:34 UTC 2020 x86_64 x86_64 x86_64 GNU/Linux

http服务器如下：

package main

import (
    "fmt"
    "log"
    "net/http"
    "os"
    "os/signal"
    "syscall"
    "time"
  _ "net/http/pprof"
)

func main() {

    h2 := func(w http.ResponseWriter, _ *http.Request) {
        time.Sleep(2 * time.Second)
        fmt.Println("555555")
        if _, err := w.Write(make([]byte, 9999)); err != nil {
            fmt.Println("---=====: ", err.Error(), syscall.EPIPE == err)
            return
        }
    }
  go func() {
      log.Println(http.ListenAndServe(":6060", nil))
  }()
    http.HandleFunc("/endpoint", h2)
    sigs := make(chan os.Signal, 1)
    signal.Notify(sigs, syscall.SIGPIPE)
    go func() {
        sig := <-sigs
    fmt.Println("6666666666", sig.String())
        fmt.Println(sig)
    }()
    log.Fatal(http.ListenAndServe(":8888", nil))
}

1、通过unix域套接字

卷曲请求 curl 127.0.0.1:8888/endpoint -m 0.2 结果：

555555
---=====:  write tcp 127.0.0.1:8888->127.0.0.1:33794: write: broken pipe false
6666666666 broken pipe
broken pipe

2、通过tcp套接字

卷曲请求： curl 47.92.3.20:8888/endpoint -m 0.2 得到结果：555555

go 的 netpoll 是否以不同的方式处理 unix domain socket 和 tcp socket？我看不出 netpoll 代码有什么不同。

Answer 1

您在连接处理中找不到任何区别，因为这两种情况的处理方式相同。这一点对 Go 来说并不特别，在 unix 套接字中，连接的写入端可以在连接关闭时立即检测到。

在 TCP 套接字中，无法立即检测到已关闭的连接。您可以等待 recv 调用返回 0（或在 go 中返回 io.EOF），这在某些情况下会发生并且是如何取消 Request.Context，但它不能立即涵盖连接断开的情况。当远程主机在发送数据时离开时，您所能做的就是继续写入，直到 TCP 堆栈收到指示连接不再可用的 RST 或 ICMP 消息。一旦发生这种情况，在大多数类 unix 系统上，您都会从系统中收到相同的 broken pipe 错误。