以下是基于提供内容整理的 Rust FAX 插件库完整示例：

完整示例：TCP 客户端与 WebSocket 服务器综合应用

use fax::{
    net::TcpClient,
    ws::WebSocketServer,
    compression,
    plugin::{ProtocolPlugin, PluginContext},
    config::PerformanceConfig,
    pool::ConnectionPool,
    error::FaxError
};
use std::net::SocketAddr;
use tokio::time::{sleep, Duration};

// 自定义协议插件实现
struct CustomProtocol;

impl ProtocolPlugin for CustomProtocol {
    fn name(&self) -> &str {
        "custom-protocol"
    }
    
    fn process(&self, ctx: &mut PluginContext) -> Result<(), Box<dyn std::error::Error>> {
        // 示例处理逻辑：将数据转为大写
        let data = ctx.read_data()?;
        let processed = data.to_ascii_uppercase();
        ctx.write_data(&processed)?;
        Ok(())
    }
}

// WebSocket 服务器处理函数
async fn handle_ws_message(message: String) -> String {
    format!("Server processed: {}", message)
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 启动 WebSocket 服务器
    let ws_addr: SocketAddr = "127.0.0.1:9001".parse()?;
    let ws_server = WebSocketServer::new(ws_addr);
    tokio::spawn(async move {
        ws_server.run(handle_ws_message).await.unwrap();
    });
    
    // 等待服务器启动
    sleep(Duration::from_millis(100)).await;

    // 配置 TCP 客户端性能参数
    let tcp_config = PerformanceConfig {
        buffer_size: 8192,
        max_connections: 10,
        timeout_ms: 3000,
        compression_level: 4,
    };

    // 创建带自定义插件的 TCP 客户端连接池
    let pool = ConnectionPool::new(5, || {
        TcpClient::with_config_and_plugins(
            "127.0.0.1:8080",
            tcp_config.clone(),
            vec![Box::new(CustomProtocol)]
        )
    }).await?;

    // 从连接池获取客户端
    let mut client = pool.get().await?;

    // 数据压缩示例
    let raw_data = b"Hello, FAX with compression!";
    let compressed = compression::compress(raw_data)?;
    client.send(&compressed).await?;

    // 错误处理示例
    match client.receive().await {
        Ok(data) => {
            let decompressed = compression::decompress(&data)?;
            println!("Received decompressed data: {:?}", decompressed);
            
            // 打印统计信息
            let stats = client.statistics();
            println!("Transfer stats: Sent {} bytes, Received {} bytes",
                stats.bytes_sent, stats.bytes_received);
        }
        Err(FaxError::ConnectionLost) => {
            eprintln!("Connection lost, attempting reconnect...");
            client.reconnect().await?;
        }
        Err(e) => return Err(e.into()),
    }

    Ok(())
}

关键代码说明：

1. 自定义协议插件：

   struct CustomProtocol;
   impl ProtocolPlugin for CustomProtocol {
       fn process(&self, ctx: &mut PluginContext) -> Result<(), Box<dyn std::error::Error>> {
           let data = ctx.read_data()?;
           let processed = data.to_ascii_uppercase(); // 示例处理逻辑
           ctx.write_data(&processed)?;
           Ok(())
       }
   }
   

2. WebSocket 服务器：

   let ws_server = WebSocketServer::new(ws_addr);
   ws_server.run(|msg| async move {
       format!("Processed: {}", msg)
   }).await?;
   

3. 带性能配置的连接池：

   let pool = ConnectionPool::new(5, || {
       TcpClient::with_config_and_plugins(
           "127.0.0.1:8080",
           tcp_config,
           vec![Box::new(CustomProtocol)]
       )
   }).await?;
   

4. 压缩与错误处理：

   let compressed = compression::compress(raw_data)?;
   match client.send(&compressed).await {
       // ... 错误处理逻辑
   }
   

该示例展示了：

• TCP 客户端与 WebSocket 服务器的协同工作
• 自定义协议插件的实现与使用
• 连接池管理的最佳实践
• 数据压缩传输完整流程
• 完善的错误处理机制
• 性能统计监控功能