#noise #tokio #tcp #ssl #snow

tokio-noise

在tokio流之上的Noise协议加密层

4个版本

0.0.4 2024年6月20日
0.0.3 2024年4月12日
0.0.2 2024年4月12日
0.0.1 2024年4月10日

#624 in 网络编程


hyper-noise中使用

无许可证

57KB
1K SLoC

tokio-noise

tokio流之上的认证加密层,由Noise协议框架驱动。

此库由DLC.Link赞助。

用法

use tokio::net::{TcpListener, TcpStream};
use tokio_noise::{NoiseError, NoiseTcpStream};

const PSK: [u8; 32] = [0xFF; 32];

async fn run_noise_server(tcp_stream: TcpStream) -> Result<(), NoiseError> {
    let mut noise_stream = NoiseTcpStream::handshake_responder_psk0(tcp_stream, &PSK).await?;
    let mut buf = [0u8; 1024];
    let n = noise_stream.recv(&mut buf).await?;
    assert_eq!(&buf[..n], b"hello world");
    Ok(())
}

#[tokio::main]
async fn main() -> Result<(), NoiseError> {
    let listener = TcpListener::bind("127.0.0.1:0").await?;
    let addr = listener.local_addr()?;

    let srv = tokio::task::spawn(async move {
        let (tcp_stream, _) = listener.accept().await?;
        run_noise_server(tcp_stream).await
    });

    // Client
    let tcp_stream = TcpStream::connect(&addr).await?;
    let mut noise_stream = NoiseTcpStream::handshake_initiator_psk0(tcp_stream, &PSK).await?;
    noise_stream.send(b"hello world").await?;

    // Wait for server to finish
    srv.await.unwrap()?;

    Ok(())
}

依赖项

~3–12MB
~102K SLoC