向多个不可达IP发送UDP时阻塞3秒的问题求助

核心原因 #

你遇到的3秒阻塞是ARP请求超时与UDP发送缓冲区耗尽共同作用的结果：

• 当UDP套接字向某个目标IP发送数据包时，如果本地ARP缓存中没有该IP对应的MAC地址，操作系统会自动发送ARP请求来获取MAC，这个过程默认是阻塞的，超时时间约3秒。
• 多目标IP+高频发送的场景下，多个目标的ARP请求会同时触发，加上你的代码无限制循环发送，很快会填满UDP发送缓冲区。后续的sendto调用会阻塞等待缓冲区空闲，而此时如果有ARP请求在等待响应，就会叠加出3秒左右的阻塞。
• 单目标场景不会出现该问题，是因为ARP请求完成后MAC地址会被缓存，后续发送直接复用缓存，不会触发阻塞；而多目标时，多个ARP请求的处理会抢占系统资源，导致缓冲区迅速耗尽，进而触发阻塞。

解决方法 #

1. 预填充ARP缓存 #

在开始高频发送UDP包之前，先对所有目标IP触发ARP请求，提前将MAC地址缓存到系统中，避免发送时触发阻塞的ARP查询：

• 系统命令方式：Linux用arping -c 1 <目标IP>，Windows用ping -n 1 <目标IP>（ping会自动触发ARP）。
• 代码方式：在循环发送前，先给每个目标IP发送一个小的UDP包，等待ARP缓存建立后再开始高频发送。比如在你的Rust代码中添加预发送逻辑：

// 预发送触发ARP
let targets = [
    "192.168.178.125:4243".parse::<SocketAddr>().unwrap(),
    "192.168.178.172:4243".parse::<SocketAddr>().unwrap(),
    "192.168.178.189:4243".parse::<SocketAddr>().unwrap(),
];
for target in &targets {
    sock.send_to(&buf, target).unwrap();
    // 短暂等待ARP缓存建立
    std::thread::sleep(Duration::from_millis(100));
}

2. 增大UDP发送缓冲区 #

通过调整套接字的发送缓冲区大小，减少因缓冲区满导致的阻塞：

// 设置发送缓冲区大小（示例为640KB，实际可根据系统上限调整）
sock.set_send_buffer_size(65536 * 10).unwrap();

注意：系统对套接字缓冲区有最大限制，可通过sysctl net.core.wmem_max（Linux）或注册表（Windows）查看/修改上限。

3. 限制发送速率 #

避免无限制高频发送，给系统留出发送和ARP处理的时间，比如在循环中添加微小延迟：

loop {
    // ... 原有发送逻辑 ...
    std::thread::sleep(Duration::from_millis(1));
    i += 1;
}

4. 使用非阻塞IO配合多路复用 #

即使设置了NON_BLOCKING，也要用多路复用机制（如Linux的epoll、Windows的IOCP）管理套接字，处理sendto返回的EAGAIN错误（表示缓冲区满），避免阻塞。Rust中可以用异步框架实现：

use tokio::net::UdpSocket;
use tokio::time::Duration;
use std::io::Write;

#[tokio::main]
async fn main() {
    let sock = UdpSocket::bind("0.0.0.0:4242").await.unwrap();
    sock.set_nonblocking(true).unwrap();
    let buf = [0u8; 10];
    let targets = [
        "192.168.178.125:4243".parse().unwrap(),
        "192.168.178.172:4243".parse().unwrap(),
        "192.168.178.189:4243".parse().unwrap(),
    ];
    let mut i = 0;
    loop {
        for target in &targets {
            match sock.send_to(&buf, target).await {
                Ok(_) => {},
                Err(e) if e.kind() == std::io::ErrorKind::WouldBlock => {
                    // 缓冲区满，等待后重试
                    tokio::time::sleep(Duration::from_millis(1)).await;
                },
                Err(e) => panic!("{}", e),
            }
        }
        print!("{i}\r");
        std::io::stdout().flush().unwrap();
        i += 1;
    }
}

5. 绑定到特定网卡 #

如果不需要使用所有网卡发送，可以将UDP套接字绑定到某个特定网卡的IP，这样系统只会使用该网卡的路由和ARP缓存，减少多网卡带来的ARP冲突：

// 绑定到指定网卡的IP（替换为你的网卡实际IP）
let sock = UdpSocket::bind("192.168.178.xxx:4242").unwrap();

内容的提问来源于stack exchange，提问作者Ferdinand S