#udt #transport-protocol #protocols #networking #udt4

bin+lib tokio-udt

An implementation of UDP-based Data Transfer Protocol (UDT) based on Tokio primitives

8 releases

0.1.0-alpha.8 Oct 14, 2022
0.1.0-alpha.7 Sep 27, 2022
0.1.0-alpha.6 Aug 8, 2022
0.1.0-alpha.4 Jul 20, 2022

#2 in #udt

31 downloads per month

AGPL-3.0

145KB
3.5K SLoC

tokio-udt

An implementation of UDP-based Data Transfer Protocol (UDT) based on Tokio primitives.

Crates.io Docs

What is UDT?

UDT is a high performance data transport protocol. It was designed specifically for data intensive applications over high speed wide area networks, to overcome the efficiency and fairness problems of TCP. As its names indicates, UDT is built on top of UDP and it provides both reliable data streaming and messaging services.

To learn more about UDT, see https://udt.sourceforge.io/

You can also find the reference C++ implementation on https://github.com/eminence/udt

Examples

UDT listener

use std::net::Ipv4Addr;
use tokio::io::{AsyncReadExt, Result};
use tokio_udt::UdtListener;

#[tokio::main]
async fn main() -> Result<()> {
    let port = 9000;
    let listener = UdtListener::bind((Ipv4Addr::UNSPECIFIED, port).into(), None).await?;

    println!("Waiting for connections...");

    loop {
        let (addr, mut connection) = listener.accept().await?;
        println!("Accepted connection from {}", addr);
        let mut buffer = Vec::with_capacity(1_000_000);
        tokio::task::spawn({
            async move {
                loop {
                    match connection.read_buf(&mut buffer).await {
                        Ok(_size) => {}
                        Err(e) => {
                            eprintln!("Connnection with {} failed: {}", addr, e);
                            break;
                        }
                    }
                }
            }
        });
    }
}

UDT client

use std::net::Ipv4Addr;
use tokio::io::{AsyncWriteExt, Result};
use tokio_udt::UdtConnection;

#[tokio::main]
async fn main() -> Result<()> {
    let port = 9000;
    let mut connection = UdtConnection::connect((Ipv4Addr::LOCALHOST, port), None).await?;
    loop {
        connection.write_all(b"Hello World!").await?;
    }
}

Dependencies

~5–18MB
~224K SLoC