在 Go 并发中处理 TCP 接受：使用专用 Goroutine 是最好的方法吗？

TCP Accept and Go 并发模型

Go 并发模型强调使用通道在 goroutine 之间进行通信。然而，当在 Go 中使用 TCP 侦听器时，net.TCPListener.Accept() 方法会阻塞当前 goroutine，直到接受连接为止，这似乎与 Go 并发范例相矛盾。

缺乏正确的选择和阻塞选项

与系统接受调用不同，Accept() 缺乏适当的选择支持和为服务器套接字设置阻塞选项的能力。这迫使开发人员采取以下解决方法：

<code class="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, .... }
  }
}()</code>

此模式允许使用 select 将 Accept() 与其他通道复用，但它为每个正在侦听的套接字引入了一个单独的 goroutine。

这是正确的习惯用法吗？

这种方法确实有效并且遵循 Go 并发模型。 Goroutines 是轻量级且廉价的，因此创建多个 goroutine 来进行套接字监听通常是可以接受的。

替代方法

对于更复杂的需求，例如实现带有超时的 select ，可以将新连接推送到通道并使用计时器对其进行复用：

<code class="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
            newConns <- nil
            return
        }
        newConns <- c
    }
}(listener)

for {
    select {
    case c := <-newConns:
        // new connection or nil if acceptor is down
    case <-time.After(time.Minute):
        // timeout branch
    }
}</code>

这种方法可以更好地控制选择和超时行为。

总之，虽然 Accept () 方法块，它仍然适合 Go 并发模型。方法的选择取决于应用程序的具体要求和性能考虑。

以上是在 Go 并发中处理 TCP 接受：使用专用 Goroutine 是最好的方法吗？的详细内容。更多信息请关注PHP中文网其他相关文章！