Rust与Node.js Unix Socket通信出现EBADF错误求助

EBADF错误本质是操作了无效的文件描述符（FD），结合你提到的C++同逻辑可正常运行的情况，问题大概率出在Rust端的FD生命周期管理、传递协议实现细节上，以下是具体排查方向：

1. 检查Rust端FD的生命周期 #

Rust的所有权机制会自动回收资源，如果待传递的FD对应的TcpStream/UnixStream在pass_fd执行完成前被drop（比如超出作用域、被move），传到Node.js的就是无效FD：

• 确认要传递的FD对应的原对象（如UnixStream）在pass_fd整个执行周期内保持有效，比如将其放入全局变量，或用std::mem::ManuallyDrop临时禁用自动销毁逻辑。
• 用std::os::unix::io::AsRawFd获取FD后，不要立即丢弃原对象，需等FD传递完成后再释放。

2. 验证FD传递的控制消息格式 #

Unix域套接字传递FD必须依赖SCM_RIGHTS控制消息，Rust端的实现细节可能和C++不一致，导致Node.js收到无效FD：

• 确保使用libc::cmsghdr结构时：
  • cmsg_level设为libc::SOL_SOCKET，cmsg_type设为libc::SCM_RIGHTS。
  • cmsg_len用libc::CMSG_LEN(std::mem::size_of::<i32>() as _)计算，包含头部和FD数组的长度。
• 必须用sendmsg而非普通send发送，确保控制消息和普通数据一起传递。

3. 核对Node.js端接收逻辑 #

日志显示触发wait_for_fd时出错，需检查Node.js侧usocket库的接收逻辑：

• 确认wait_for_fd监听的是正确的套接字，且接收代码正确解析了SCM_RIGHTS类型的辅助数据。
• 对比C++的接收逻辑，检查Node.js是否遗漏了辅助数据的读取步骤（比如未正确处理msg_control字段）。

4. 排查系统权限与FD有效性 #

虽然概率较低，但仍需确认：

• Rust进程和Node.js进程的用户权限一致，可访问目标Unix域套接字文件。
• 用lsof命令在Rust发送FD前后，查看对应FD是否存在，确认传递前FD处于有效状态。

参考Rust端FD传递示例代码 #

use std::os::unix::io::{AsRawFd, RawFd};
use libc;

fn pass_fd(sock: RawFd, fd_to_pass: RawFd) -> std::io::Result<()> {
    // 构造普通数据段（需至少1字节触发sendmsg）
    let mut iov = libc::iovec {
        iov_base: [0u8; 1].as_mut_ptr() as *mut libc::c_void,
        iov_len: 1,
    };

    // 构造FD缓冲区与控制消息
    let mut fd_buf = [fd_to_pass];
    let cmsg_len = libc::CMSG_LEN(std::mem::size_of::<RawFd>() as libc::size_t);
    let mut cmsg_buf = vec![0u8; cmsg_len];
    
    let cmsg_hdr = unsafe {
        libc::CMSG_FIRSTHDR(&mut libc::msghdr {
            msg_name: std::ptr::null_mut(),
            msg_namelen: 0,
            msg_iov: &mut iov,
            msg_iovlen: 1,
            msg_control: cmsg_buf.as_mut_ptr() as *mut libc::c_void,
            msg_controllen: cmsg_len,
            msg_flags: 0,
        })
    }.ok_or_else(|| std::io::Error::new(std::io::ErrorKind::Other, "Failed to get cmsg header"))?;

    cmsg_hdr.cmsg_level = libc::SOL_SOCKET;
    cmsg_hdr.cmsg_type = libc::SCM_RIGHTS;
    cmsg_hdr.cmsg_len = cmsg_len;

    // 复制FD到控制消息数据区
    unsafe {
        std::ptr::copy_nonoverlapping(
            fd_buf.as_ptr(),
            libc::CMSG_DATA(cmsg_hdr) as *mut RawFd,
            1,
        );
    }

    eprintln!("fn pass_fd()6666666");

    // 发送消息
    let res = unsafe {
        libc::sendmsg(
            sock,
            &mut libc::msghdr {
                msg_name: std::ptr::null_mut(),
                msg_namelen: 0,
                msg_iov: &mut iov,
                msg_iovlen: 1,
                msg_control: cmsg_buf.as_mut_ptr() as *mut libc::c_void,
                msg_controllen: cmsg_len,
                msg_flags: 0,
            },
            0,
        )
    };

    if res == -1 {
        return Err(std::io::Error::last_os_error());
    }

    Ok(())
}

内容的提问来源于stack exchange，提问作者tuhin panda