高并发网络编程：使用Go WaitGroup实现并发服务器

以下是使用Go的WaitGroup实现高并发服务器的示例代码：

package main import ( "fmt" "net" "sync" ) func handleRequest(conn net.Conn) { defer conn.Close() // 处理请求的逻辑，这里只是简单地回复一个消息 message := "Hello from server" conn.Write([]byte(message)) } func main() { // 创建一个WaitGroup来等待所有goroutine完成 var wg sync.WaitGroup // 启动并发服务器监听端口 ln, err := net.Listen("tcp", ":8080") if err != nil { fmt.Println("Failed to listen:", err) return } fmt.Println("Server listening on port 8080") // 接受并处理客户端连接 for { conn, err := ln.Accept() if err != nil { fmt.Println("Failed to accept connection:", err) continue } // 每个连接启动一个goroutine来处理请求 wg.Add(1) go func() { handleRequest(conn) wg.Done() }() } // 等待所有goroutine完成 wg.Wait() } 

在上面的代码中，我们首先创建了一个sync.WaitGroup来等待所有的goroutine完成。然后，我们启动一个并发服务器监听端口，并在接受到客户端连接时，为每个连接创建一个goroutine来处理请求。在处理请求的goroutine中，我们调用wg.Add(1)来表示一个新的goroutine开始，并在请求处理完成时调用wg.Done()来表示该goroutine结束。最后，我们在主函数中调用wg.Wait()来等待所有的goroutine完成。

请注意，上面的示例代码仅涵盖了基本的并发服务器实现，实际情况中可能需要更复杂的逻辑来处理并发请求。此外，还应该考虑资源管理、错误处理等方面的问题。