Golang中P2P UDP套接字通信报错EHOSTUNREACH(65)求助

错误原因 #

1. 本地地址绑定逻辑错误
   你调用ListenUDP时直接绑定了PeerAddrList[Id]，如果这个地址并非当前节点本地网卡配置的IP（比如是其他节点的地址，或是未在本地启用的IP），套接字绑定后将无法正常发送数据。系统尝试通过该绑定IP发送UDP包时，找不到对应网络接口，就会返回EHOSTUNREACH错误。

2. 忽略关键错误处理
   代码中用_直接忽略了net.ResolveUDPAddr的错误，如果PeerAddrList里的地址格式无效（比如端口非数字），会导致radddr是无效的空地址，进而触发发送错误。

3. 并发时序逻辑不稳定
   发送逻辑用goroutine异步执行，但接收是同步固定次数循环，可能出现接收先于发送完成的情况，导致测试逻辑异常，但这并非EHOSTUNREACH的直接诱因。

修复方案 #

1. 正确绑定本地地址 #

UDP套接字监听时，应绑定到当前节点的本地IP（或0.0.0.0监听所有接口）加对应端口。如果PeerAddrList[Id]是当前节点对外地址，需确保本地网卡已配置该IP；否则拆分地址中的端口，绑定到0.0.0.0:port或":"+port。

2. 完善错误处理 #

不要忽略ResolveUDPAddr和ListenUDP的错误，及时排查地址解析或绑定失败的问题。

3. 优化并发逻辑 #

使用sync.WaitGroup等待所有发送goroutine完成，避免接收逻辑提前退出或遗漏数据；同时改用计数循环接收，适配UDP不可靠特性（避免丢包导致程序panic）。

修复后的示例代码 #

import (
    "encoding/binary"
    "log"
    "net"
    "sync"
)

// 假设变量已正确初始化
var (
    Id           uint32        // 节点唯一标识
    PeerAddrList []string      // 所有节点地址切片（addr:port）
    N            int           // 节点数量
)

func main() {
    // 解析本地地址，提取端口用于绑定所有接口
    localAddrStr := PeerAddrList[Id]
    udpAddr, err := net.ResolveUDPAddr("udp", localAddrStr)
    if err != nil {
        panic(err)
    }
    // 绑定到0.0.0.0+原端口，监听所有本地接口
    bindAddr := &net.UDPAddr{IP: net.IPv4zero, Port: udpAddr.Port}
    UDPC, err := net.ListenUDP("udp", bindAddr)
    if err != nil {
        panic(err)
    }
    defer UDPC.Close()

    var wg sync.WaitGroup
    for i := 0; i < N; i++ {
        if i == int(Id) {
            continue
        }
        wg.Add(1)
        go func(idx int) {
            defer wg.Done()
            var b [4]byte
            bs := b[:4]
            binary.LittleEndian.PutUint32(bs, Id)
            radddr, err := net.ResolveUDPAddr("udp", PeerAddrList[idx])
            if err != nil {
                log.Printf("解析地址 %s 失败: %v", PeerAddrList[idx], err)
                return
            }
            if _, err := UDPC.WriteToUDP(bs, radddr); err != nil {
                log.Printf("发送到 %s 失败: %v", radddr.String(), err)
                return
            }
        }(i)
    }

    // 等待所有发送任务完成
    wg.Wait()

    // 循环接收消息，直到收齐所有节点的消息
    receivedCount := 0
    targetCount := N - 1
    for receivedCount < targetCount {
        var b [4]byte
        bs := b[:4]
        _, raddr, err := UDPC.ReadFromUDP(bs)
        if err != nil {
            log.Printf("接收消息失败: %v", err)
            continue
        }
        id := int32(binary.LittleEndian.Uint32(bs))
        log.Printf("收到来自 %s 的节点ID: %d", raddr.String(), id)
        receivedCount++
    }
}

额外说明 #

• net.IPv4zero即0.0.0.0，表示监听所有本地网络接口，发送时系统会自动选择合适的出口IP，避免绑定错误IP导致的发送失败。
• 增加WaitGroup确保所有发送逻辑执行完毕，避免接收提前终止。
• 计数接收替代固定次数循环，适配UDP不可靠特性，避免因丢包触发panic。

内容的提问来源于stack exchange，提问作者Michael Davis