AckUDP

[实验性] 使用Rust编写的更可靠的UDP版本。

如何使用？

use std::{io, thread, time::Duration};

use ack_udp::AckUdp;

#[tokio::main]
fn main() -> io::Result<()> {
  // Creating sender and receiver sockets
  let mut sender = AckUdp::new("127.0.0.1:9023".parse().unwrap()).await?;
  let mut receiver = AckUdp::new("127.0.0.1:9024".parse().unwrap()).await?;

  let message = String::from("test").as_bytes().to_vec();
  
  let status = sender.send(&message, "127.0.0.1:9024".parse().unwrap())?;
  println!("{:?}", status); // Printing the status of the send

  thread::sleep(Duration::from_millis(5)); // Simulating the wait time

  // Receiving data
  let (_, datagram) = receiver.recv().unwrap(); 
  println!("{:?}, {:?}", datagram, status);

  Ok(())
}