Noxious：高性能、可扩展的Rust网络编程库与工具集

简介

Noxious是一个专注于高性能网络编程的Rust库，提供了可扩展的插件系统和丰富的工具集，适用于构建各种网络应用和服务。

主要特性

• 高性能网络协议实现：基于Rust的异步运行时优化
• 模块化插件系统：可轻松扩展功能
• 内置多种网络工具：简化常见网络编程任务
• 类型安全API：充分利用Rust的所有权系统

安装

在Cargo.toml中添加依赖：

[dependencies]
noxious = "0.5"  # 请检查最新版本

基本使用示例

1. 创建TCP服务器

use noxious::server::{TcpServer, TcpServerConfig};
use noxious::handler::EchoHandler;
use tokio::runtime::Runtime;

fn main() {
    let config = TcpServerConfig {
        address: "127.0.0.1:8080".parse().unwrap(),
        max_connections: 100,
    };
    
    let handler = EchoHandler::new();
    let server = TcpServer::new(config, handler);
    
    Runtime::new().unwrap().block_on(async {
        server.run().await.unwrap();
    });
}

2. 使用插件系统

use noxious::plugin::{Plugin, PluginContext};
use noxious::message::NetworkMessage;

struct LoggingPlugin;

impl Plugin for LoggingPlugin {
    fn on_message(&self, ctx: &mut PluginContext, msg: &NetworkMessage) {
        println!("Received message: {:?}", msg);
        ctx.next(msg); // 传递给下一个插件
    }
}

// 注册插件
let mut server = TcpServer::new(config, handler);
server.add_plugin(Box::new(LoggingPlugin));

3. 内置工具使用

use noxious::tools::PortScanner;

async fn scan_ports() {
    let scanner = PortScanner::new("127.0.0.1".to_string(), 1..1024);
    let open_ports = scanner.scan().await;
    println!("Open ports: {:?}", open_ports);
}

高级功能

自定义协议处理器

use noxious::handler::{ProtocolHandler, HandlerResult};
use noxious::message::NetworkMessage;

struct CustomHandler;

#[async_trait::async_trait]
impl ProtocolHandler for CustomHandler {
    async fn handle(&self, msg: NetworkMessage) -> HandlerResult<NetworkMessage> {
        // 自定义处理逻辑
        Ok(msg)
    }
}

性能调优

let config = TcpServerConfig {
    address: "127.0.0.1:8080".parse().unwrap(),
    max_connections: 1000,
    worker_threads: 4,  // 根据CPU核心数调整
    buffer_size: 8192,  // 调整缓冲区大小
};

插件开发

创建自定义插件：

use noxious::plugin::{Plugin, PluginContext};
use noxious::message::NetworkMessage;

pub struct RateLimiter {
    max_requests: usize,
}

impl Plugin for RateLimiter {
    fn on_message(&self, ctx: &mut PluginContext, msg: &NetworkMessage) {
        // 实现限流逻辑
        if ctx.request_count() < self.max_requests {
            ctx.next(msg);
        } else {
            ctx.drop_message();
        }
    }
}

完整示例demo

下面是一个结合了TCP服务器、插件系统和自定义处理器的完整示例：

use noxious::{
    server::{TcpServer, TcpServerConfig},
    handler::{ProtocolHandler, HandlerResult, EchoHandler},
    plugin::{Plugin, PluginContext},
    message::NetworkMessage,
};
use tokio::runtime::Runtime;
use async_trait::async_trait;

// 自定义处理器
struct CustomHandler;

#[async_trait]
impl ProtocolHandler for CustomHandler {
    async fn handle(&self, msg: NetworkMessage) -> HandlerResult<NetworkMessage> {
        println!("Processing message in custom handler");
        // 在这里可以添加自定义处理逻辑
        Ok(msg)
    }
}

// 自定义插件
struct RequestLogger;

impl Plugin for RequestLogger {
    fn on_message(&self, ctx: &mut PluginContext, msg: &NetworkMessage) {
        println!("[LOG] Request from: {:?}", msg.source());
        ctx.next(msg);
    }
}

fn main() {
    // 配置TCP服务器
    let config = TcpServerConfig {
        address: "127.0.0.1:8080".parse().unwrap(),
        max_connections: 100,
        worker_threads: 2,
        buffer_size: 4096,
    };
    
    // 创建处理器和服务器实例
    let handler = CustomHandler;
    let mut server = TcpServer::new(config, handler);
    
    // 添加插件
    server.add_plugin(Box::new(RequestLogger));
    
    // 启动服务器
    Runtime::new().unwrap().block_on(async {
        println!("Server starting on 127.0.0.1:8080");
        server.run().await.unwrap();
    });
}

总结

Noxious为Rust网络编程提供了强大而灵活的工具集，特别适合需要高性能和可扩展性的应用场景。通过其插件系统，开发者可以轻松扩展功能而不需要修改核心代码库。