kcpserver

最好用的RUST KCP 服务器框架

Examples Echo

```rust use kcpserver::prelude::{ kcp_module::{KcpConfig, KcpNoDelayConfig}, *, }; use tokio::io::AsyncReadExt; use log::LevelFilter;

[tokio::main]

async fn main() -> anyhow::Result<()> { envlogger::Builder::new() .filterlevel(LevelFilter::Debug) .init();

let mut config = KcpConfig::default();
config.nodelay = Some(KcpNoDelayConfig::fastest());
let kcp_server = KcpListener::new("0.0.0.0:5555", config, 1, |peer| async move {
    log::debug!("create kcp peer:{}", peer.to_string());
    let mut buf = [0; 1024];
    let mut reader = peer.get_reader();
    let mut writer = peer.get_writer();
    while let Ok(size) = reader.read(&mut buf).await {
        log::debug!("read peer:{} buff:{}", peer, size);          
        writer.write_all(&buf[..size]).await?;
        writer.flush().await?;
    }
    writer.shutdown().await?;
    Ok(())
})?;
kcp_server.start().await?;
Ok(())

}

```