Rust网络框架库network-framework-sys的使用，提供跨平台底层网络功能与系统接口绑定

安装

在项目目录中运行以下Cargo命令：

cargo add network-framework-sys

或者在Cargo.toml中添加以下行：

network-framework-sys = "0.1.0"

基本信息

• 版本: 0.1.0
• 发布时间: 约5年前 (2018年)
• 许可证: MIT
• 大小: 6.67 KiB

使用示例

以下是一个使用network-framework-sys创建简单TCP服务器的完整示例：

// 导入必要的模块
use network_framework_sys::{socket, bind, listen, accept, sockaddr_in, htons};
use std::mem;
use std::os::unix::io::RawFd;

fn main() {
    // 创建TCP套接字
    let sockfd = unsafe { socket(libc::AF_INET, libc::SOCK_STREAM, 0) };
    if sockfd < 0 {
        eprintln!("Failed to create socket");
        return;
    }

    // 设置服务器地址
    let mut server_addr: sockaddr_in = unsafe { mem::zeroed() };
    server_addr.sin_family = libc::AF_INET as u16;
    server_addr.sin_addr.s_addr = libc::INADDR_ANY;
    server_addr.sin_port = unsafe { htons(8080) };

    // 绑定套接字
    if unsafe { bind(sockfd, &server_addr as *const _ as *const _, mem::size_of_val(&server_addr) as u32) } < 0 {
        eprintln!("Failed to bind socket");
        unsafe { libc::close(sockfd) };
        return;
    }

    // 开始监听
    if unsafe { listen(sockfd, 5) } < 0 {
        eprintln!("Failed to listen on socket");
        unsafe { libc::close(sockfd) };
        return;
    }

    println!("Server listening on port 8080...");

    // 接受客户端连接
    loop {
        let mut client_addr: sockaddr_in = unsafe { mem::zeroed() };
        let mut addr_len = mem::size_of_val(&client_addr) as u32;
        
        let client_sockfd = unsafe { 
            accept(sockfd, 
                  &mut client_addr as *mut _ as *mut _, 
                  &mut addr_len as *mut u32) 
        };
        
        if client_sockfd < 0 {
            eprintln!("Failed to accept client connection");
            continue;
        }

        println!("Accepted new connection");
        
        // 这里可以添加处理客户端连接的代码
        
        unsafe { libc::close(client_sockfd) };
    }
}

完整示例代码

下面是一个更完整的TCP服务器实现，包含基本的客户端连接处理功能：

use network_framework_sys::{socket, bind, listen, accept, recv, send, sockaddr_in, htons, inet_ntop};
use std::mem;
use std::os::unix::io::RawFd;
use std::ffi::CStr;

fn main() {
    // 创建TCP套接字
    let sockfd = unsafe { socket(libc::AF_INET, libc::SOCK_STREAM, 0) };
    if sockfd < 0 {
        eprintln!("Failed to create socket");
        return;
    }

    // 设置服务器地址
    let mut server_addr: sockaddr_in = unsafe { mem::zeroed() };
    server_addr.sin_family = libc::AF_INET as u16;
    server_addr.sin_addr.s_addr = libc::INADDR_ANY;
    server_addr.sin_port = unsafe { htons(8080) };

    // 绑定套接字
    if unsafe { bind(sockfd, &server_addr as *const _ as *const _, mem::size_of_val(&server_addr) as u32) } < 0 {
        eprintln!("Failed to bind socket");
        unsafe { libc::close(sockfd) };
        return;
    }

    // 开始监听
    if unsafe { listen(sockfd, 5) } < 0 {
        eprintln!("Failed to listen on socket");
        unsafe { libc::close(sockfd) };
        return;
    }

    println!("Server listening on port 8080...");

    // 接受客户端连接
    loop {
        let mut client_addr: sockaddr_in = unsafe { mem::zeroed() };
        let mut addr_len = mem::size_of_val(&client_addr) as u32;
        
        let client_sockfd = unsafe { 
            accept(sockfd, 
                  &mut client_addr as *mut _ as *mut _, 
                  &mut addr_len as *mut u32) 
        };
        
        if client_sockfd < 0 {
            eprintln!("Failed to accept client connection");
            continue;
        }

        // 获取客户端IP地址
        let mut ip_str = [0u8; 16];
        unsafe {
            inet_ntop(
                libc::AF_INET,
                &client_addr.sin_addr as *const _ as *const _,
                ip_str.as_mut_ptr() as *mut _,
                ip_str.len() as u32
            );
        }
        let client_ip = unsafe { CStr::from_ptr(ip_str.as_ptr() as *const _) };
        
        println!("Accepted new connection from: {:?}", client_ip);

        // 处理客户端请求
        handle_client(client_sockfd);
        
        unsafe { libc::close(client_sockfd) };
    }
}

fn handle_client(sockfd: RawFd) {
    let mut buffer = [0u8; 1024];
    
    loop {
        // 接收客户端数据
        let bytes_received = unsafe { recv(sockfd, buffer.as_mut_ptr() as *mut _, buffer.len(), 0) };
        if bytes_received <= 0 {
            if bytes_received < 0 {
                eprintln!("Error receiving data from client");
            }
            break;
        }

        // 打印接收到的消息
        let msg = &buffer[..bytes_received as usize];
        println!("Received: {:?}", msg);

        // 发送响应
        let response = b"Hello from server!\n";
        let bytes_sent = unsafe { send(sockfd, response.as_ptr() as *const _, response.len(), 0) };
        if bytes_sent < 0 {
            eprintln!("Failed to send response to client");
            break;
        }
    }
}

所有者

• 宁靜 (LuoZijun) - 主要维护者

请注意，这个库是一个系统绑定库，提供了与底层网络功能的接口。在实际使用时，你可能需要结合其他更高级的网络库来构建完整的网络应用程序。