TCP接受和Go并发模型

Question

查看net.TCPListener。考虑到 Go 并发范式，人们会期望将此系统功能实现为通道，以便您从 Listen() 函数中获得 chan *net.Conn，或类似的东西。

但似乎 Accept() 是一种方式，它只是阻塞，就像系统接受一样。除了它是残废的，因为：

• 没有合适的 select() 可以用于它，因为 go 更喜欢频道
• 无法为服务器套接字设置阻塞选项。

所以我正在做类似的事情：

    acceptChannel = make(chan *Connection)
    go func() {
      for {
       rw, err := listener.Accept()
       if err != nil { ... handle error ... close(acceptChannel) ... return }
       s.acceptChannel <-&Connection{tcpConn: rw, .... }
      }
    }()

这样我就可以在一个选择中使用多个服务器套接字，或者将 Accept() 上的等待与其他通道多路复用。我错过了什么吗？我是 Go 新手，所以我可能会忽略一些事情——但 Go 真的没有用自己的并发范式实现自己的阻塞系统功能吗？我真的需要为每个我想听的套接字（可能数百或数千个）单独的 goroutine 吗？这是要使用的正确成语，还是有更好的方法？

Answer 1

您的代码很好。你甚至可以更进一步替换：

s.acceptChannel <-&Connection{tcpConn: rw, .... }

与：

go handleConnection(&Connection{tcpConn: rw, .... })

正如 cmets 中提到的，例程不是系统线程，它们是由 Go 运行时管理的轻量级线程。当您为每个连接创建例程时，您可以轻松使用更容易实现的阻塞操作。然后，Go 运行时为您选择例程，因此您正在寻找的行为只是隐藏在语言中的其他地方。你看不到它，但它无处不在。

现在，如果您需要更复杂的东西，并且根据我们的对话，实现类似于选择超时的东西，您将完全按照您的建议进行操作：将所有新连接推送到通道并使用计时器多路复用.这似乎是 Go 的方式。

请注意，如果 一个 接收器失败，因为另一个接收器会在写入时出现恐慌，您无法关闭接收通道。

我的（更完整的）示例：

newConns := make(chan net.Conn)

// For every listener spawn the following routine
go func(l net.Listener) {
    for {
        c, err := l.Accept()
        if err != nil {
            // handle error (and then for example indicate acceptor is down)
            newConns <- nil
            return
        }
        newConns <- c
    }
}(listener)

for {
    select {
    case c := <-newConns:
        // new connection or nil if acceptor is down, in which case we should
        // do something (respawn, stop when everyone is down or just explode)
    case <-time.After(time.Minute):
        // timeout branch, no connection for a minute
    }
}