如何使用Golang进行多连接网络通信

package main
<p>import (
"bufio"
"fmt"
"log"
"net"
")</p><p>func handleConnection(conn net.Conn) {
defer conn.Close()
reader := bufio.NewReader(conn)
for {
message, err := reader.ReadString('\n')
if err != nil {
log.Printf("客户端断开: %v", err)
return
}
fmt.Print("收到: ", message)
// 回显消息
conn.Write([]byte("echo: " + message))
}
}</p><p>func main() {
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal("监听失败:", err)
}
defer listener.Close()
fmt.Println("服务端启动，监听 :8080")</p><pre class='brush:php;toolbar:false;'>for {
    conn, err := listener.Accept()
    if err != nil {
        log.Printf("接受连接失败: %v", err)
        continue
    }
    // 每个连接启动一个goroutine
    go handleConnection(conn)
}

package main
<p>import (
"fmt"
"log"
"net"
")</p><p>func main() {
addr, err := net.ResolveUDPAddr("udp", ":8080")
if err != nil {
log.Fatal(err)
}</p><pre class='brush:php;toolbar:false;'>conn, err := net.ListenUDP("udp", addr)
if err != nil {
    log.Fatal(err)
}
defer conn.Close()

buf := make([]byte, 1024)
for {
    n, clientAddr, err := conn.ReadFromUDP(buf)
    if err != nil {
        log.Printf("读取失败: %v", err)
        continue
    }

    fmt.Printf("来自 %s: %s\n", clientAddr, string(buf[:n]))

    // 回复客户端
    response := "received: " + string(buf[:n])
    conn.WriteToUDP([]byte(response), clientAddr)
}

conn.SetReadDeadline(time.Now().Add(30 * time.Second))