Golang中goroutine与UDP协议的使用问题求助

你的代码存在几个关键问题：

1. 通道未初始化：buf和addr通道声明后未使用make初始化
2. 通道关闭过早：在readudp函数中每次调用都关闭通道，导致后续读取失败
3. 并发逻辑错误：每次循环都创建新的goroutine和UDP连接
4. 文件操作问题：使用Open打开文件但需要写入权限

以下是修正后的代码：

package main

import (
    "fmt"
    "net"
    "os"
    "strconv"
    "sync"
)

func main() {
    file_name := "test.txt"
    number_of_data := 100
    
    // 初始化通道
    buf := make(chan []byte, number_of_data)
    addr := make(chan *net.UDPAddr, number_of_data)
    
    // 创建并打开文件（使用追加模式）
    file, err := os.OpenFile(file_name, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
    check_error(err)
    defer file.Close()
    
    var wg sync.WaitGroup
    
    // 启动单个UDP接收goroutine
    wg.Add(1)
    go func() {
        defer wg.Done()
        readudp(addr, buf)
    }()
    
    // 主循环处理接收到的数据
    for i := 0; i < number_of_data; i++ {
        select {
        case v1 := <-addr:
            v2 := <-buf
            // 正确格式化输出
            output := fmt.Sprintf("数据%d: IP=%s, Port=%d, 内容=%s\n", 
                i, v1.IP.String(), v1.Port, string(v2))
            
            _, err := file.WriteString(output)
            check_error(err)
            fmt.Print(output)
            fmt.Println("已写入文件")
        }
    }
    
    wg.Wait()
}

func readudp(addr chan *net.UDPAddr, buf chan []byte) {
    // 只创建一次UDP连接
    conn, err := net.ListenUDP("udp", &net.UDPAddr{
        IP:   net.IPv4(0, 0, 0, 0),
        Port: 5000,
    })
    check_error(err)
    defer conn.Close()
    
    for {
        buf1 := make([]byte, 1500)
        n, addr1, err := conn.ReadFromUDP(buf1)
        if err != nil {
            fmt.Printf("读取错误: %v\n", err)
            continue
        }
        
        fmt.Println("接收到数据")
        addr <- addr1
        buf <- buf1[:n]
    }
}

func check_error(err error) {
    if err != nil {
        fmt.Printf("错误: %v\n", err)
    }
}

或者使用更简洁的单goroutine版本：

package main

import (
    "fmt"
    "net"
    "os"
)

func main() {
    file, err := os.OpenFile("test.txt", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
    if err != nil {
        fmt.Printf("文件错误: %v\n", err)
        return
    }
    defer file.Close()
    
    conn, err := net.ListenUDP("udp", &net.UDPAddr{
        IP:   net.IPv4(0, 0, 0, 0),
        Port: 5000,
    })
    if err != nil {
        fmt.Printf("UDP错误: %v\n", err)
        return
    }
    defer conn.Close()
    
    for i := 0; i < 100; i++ {
        buf := make([]byte, 1500)
        n, addr, err := conn.ReadFromUDP(buf)
        if err != nil {
            fmt.Printf("读取错误: %v\n", err)
            continue
        }
        
        output := fmt.Sprintf("数据%d: IP=%s, Port=%d, 内容=%s\n",
            i, addr.IP.String(), addr.Port, string(buf[:n]))
        
        _, err = file.WriteString(output)
        if err != nil {
            fmt.Printf("写入错误: %v\n", err)
        }
        
        fmt.Print(output)
        fmt.Println("已写入文件")
    }
}

主要修改：

1. 使用make初始化通道
2. 将UDP连接创建移到循环外部
3. 使用OpenFile替代Create+Open
4. 修正字符串格式化方式
5. 移除过早的通道关闭操作