如何中断执行 (*TCPListener) Accept 的 goroutine？

Question

我最近在玩 go 并尝试创建一些服务器来响应 tcp 连接上的客户端。

我的问题是我如何干净地关闭服务器并中断当前在以下调用中“阻塞”的 go-routine

func (*TCPListener) 接受？

根据documentation of Accept

Accept 在 Listener 接口中实现 Accept 方法；它等待下一次调用并返回一个通用的 Conn。

这些错误也很少被记录。

Answer 1

这就是我想要的。也许将来会帮助某人。 注意使用 select 和 "c" 通道将它与退出通道结合起来

    ln, err := net.Listen("tcp", ":8080")
    if err != nil {
        // handle error
    }
    defer ln.Close()
    for {
        type accepted struct {
            conn net.Conn
            err  error
        }
        c := make(chan accepted, 1)
        go func() {
            conn, err := ln.Accept()
            c <- accepted{conn, err}
        }()
        select {
        case a := <-c:
            if a.err != nil {
                // handle error
                continue
            }
            go handleConnection(a.conn)
        case e := <-ev:
            // handle event
            return
        }
    }

Answer 2

TCPListener 截止日期

您不一定需要额外的 go 例程（不断接受），只需指定 Deadline。

for 示例：

for {

    // Check if someone wants to interrupt accepting
    select {
    case <- someoneWantsToEndMe: 
        return // runs into "defer listener.Close()"
    default: // nothing to do
    }

    // Accept with Deadline
    listener.SetDeadline(time.Now().Add(1 * time.Second)
    conn, err := listener.Accept()
    if err != nil {
        // TODO: Could do some err checking (to be sure it is a timeout), but for brevity
        continue
    }

    go handleConnection(conn)
}

Answer 3

只需 Close() 和从 net.Listen(...) 调用中获得的 net.Listener 并从正在执行的 goroutine 返回。