Golang如何实现TCP高并发连接

listener, err := net.Listen("tcp", ":8080")
if err != nil {
    log.Fatal(err)
}
defer listener.Close()
for {
conn, err := listener.Accept()
if err != nil {
log.Println("Accept error:", err)
continue
}
go handleConnection(conn) // 每个连接启动一个goroutine
}

semaphore := make(chan struct{}, 1000)
for {
conn, err := listener.Accept()
if err != nil {
log.Println(err)
continue
}
semaphore <- struct{}{} // 占用一个槽位
go func(c net.Conn) {
defer c.Close()
defer func() { <-semaphore }() // 释放槽位
handleConnection(c)
}(conn)
}

var bufferPool = sync.Pool{
    New: func() interface{} {
        return make([]byte, 1024)
    },
}
func handleConnection(conn net.Conn) {
buf := bufferPool.Get().([]byte)
defer bufferPool.Put(buf)
for {
    n, err := conn.Read(buf)
    if err != nil {
        break
    }
    // 处理数据 buf[:n]
}
}

ctx, cancel := context.WithCancel(context.Background())
go func() {
sig := <-signalChan
log.Println("received signal:", sig)
cancel() // 触发关闭
}()
for {
conn, err := listener.Accept()
if err != nil {
if ctx.Err() == context.Canceled {
break // 正常退出循环
}
continue
}
go handleWithCtx(ctx, conn)
}