Go语言中UDP连接的并发读写：解决数据竞争问题

import "net"

// originalAddr 是从 ReadFromUDP 返回的 *net.UDPAddr
// 在将其传递给其他goroutine之前，进行深度拷贝
newAddr := &net.UDPAddr{}
*newAddr = *originalAddr // 复制结构体的所有值字段

// 深度拷贝IP地址切片
if originalAddr.IP != nil {
    newAddr.IP = make(net.IP, len(originalAddr.IP))
    copy(newAddr.IP, originalAddr.IP)
}
// Port字段是值类型，已通过 *newAddr = *originalAddr 复制

package main

import (
    "fmt"
    "log"
    "net"
    "time"
)

const UDP_PACKET_SIZE = 1024 // UDP数据包最大尺寸
const CHAN_BUF_SIZE = 100    // Channel缓冲区大小

// Packet 结构体用于在goroutine之间传递UDP数据包信息
type Packet struct {
    Addr *net.UDPAddr // 远程UDP地址
    Data []byte       // 数据内容
}

// newSafeUDPConnection 创建一个UDP连接，并启动独立的goroutine处理读写。
// 返回入站和出站数据包的channel，以及底层UDPConn对象，以便外部进行管理。
func newSafeUDPConnection(port int) (inbound, outbound chan Packet, conn *net.UDPConn, err error) {
    inbound = make(chan Packet, CHAN_BUF_SIZE)
    outbound = make(chan Packet, CHAN_BUF_SIZE)

    // 监听UDP端口
    conn, err = net.ListenUDP("udp4", &net.UDPAddr{Port: port})
    if err != nil {
        return nil, nil, nil, fmt.Errorf("failed to listen UDP on port %d: %w", port, err)
    }
    log.Printf("UDP connection listening on :%d", port)

    // 启动一个goroutine专门负责读取UDP数据包
    go func() {
        defer func() {
            close(inbound) // 读取器退出时关闭入站channel
            log.Printf("UDP reader goroutine for port %d stopped.", port)
        }()

        buf := make([]byte, UDP_PACKET_SIZE)
        for {
            n, addr, err := conn.ReadFromUDP(buf)
            if err != nil {
                // 检查是否是连接关闭引起的错误
                if opErr, ok := err.(*net.OpError); ok && opErr.Err.Error() == "use of closed network connection" {
                    log.Printf("UDP connection on port %d closed