rust-utp

一个使用 Rust 实现的异步 Micro 传输协议 库。

API 文档

概述

Micro 传输协议是在 UDP 上构建的可靠传输协议。它的拥塞控制算法是 LEDBAT，它试图尽可能多地使用未使用的带宽，但会迅速向竞争流量让步，这使得它在不会在网络上引入拥塞的情况下适用于大量传输。

当前的实现尚不完整，缺乏完整的拥塞控制实现。然而，它支持丢包检测（除了超时之外），选择性确认扩展，处理无序和重复的包，并提供了流接口（UtpStream）。

稳定性

此 crate 是实验性的，并且包含许多错误。我们强烈建议不要在生产环境中使用它。欢迎贡献和修复 :)

用法

要使用 tokio-utp，请将以下内容添加到您的 Cargo.toml

[dependencies]
async-utp = "*"

示例

最简单的示例程序将是

use async_utp::UtpStream;
use tokio::task;
use std::io::Write;

fn main() {
    // Connect to an hypothetical local server running on port 8080
    let addr = "127.0.0.1:8080";
    let (mut stream, driver) = UtpStream::connect(addr).await.expect("Error connecting to remote peer");
    
    task::spawn(driver);

    // Send a string
    stream.write("Hi there!".as_bytes()).await.expect("Write failed");

    // Close the stream
    stream.close().await.expect("Error closing connection");
}

查看 "examples" 目录下的文件以获取更多示例程序，或使用以下命令运行它们：cargo run --example <example_name>.