【Rust日报】 2019-04-14

Mike Tang 发表于 2019-04-14 12:23

Tags：rust

如何为TiKV做贡献

laminar - 面向多玩家游戏的半可靠 UDP 协议

这是 amethyst 项目下的底层网络库，可以独立使用。提供了可靠传输与不可靠传输的选择。

发包

use laminar::{Socket, Packet};

// create the socket
let (mut socket, packet_sender, _) = Socket::bind("127.0.0.1:12345")?;

// our data
let bytes = vec![...];

// You can create packets with different reliabilities
let unreliable = Packet::unreliable(destination, bytes);
let reliable = Packet::reliable_unordered(destination, bytes);

// We can specify on which stream and how to order our packets, checkout our book and documentation for more information
let unreliable = Packet::unreliable_sequenced(destination, bytes, Some(1));
let reliable_sequenced = Packet::reliable_sequenced(destination, bytes, Some(2));
let reliable_ordered = Packet::reliable_ordered(destination, bytes, Some(3));

// send the created packets
packet_sender.send(unreliable_sequenced).unwrap();
packet_sender.send(reliable).unwrap();
packet_sender.send(unreliable_sequenced).unwrap();
packet_sender.send(reliable_sequenced).unwrap();
packet_sender.send(reliable_ordered).unwrap();

收包

use laminar::{SocketEvent, Socket};

// create the socket
let (mut socket, _, packet_receiver) = Socket::bind("127.0.0.1:12346")?;

// wait until a socket event occurs
let result = packet_receiver.recv();

match result {
    Ok(socket_event) => {
        match  socket_event {
            SocketEvent::Packet(packet) => {
                let endpoint: SocketAddr = packet.addr();
                let received_data: &[u8] = packet.payload();
            },
            SocketEvent::Connect(connect_event) => { /* a client connected */ },
            SocketEvent::Timeout(timeout_event) => { /* a client timed out */},
        }
    }
    Err(e) => {
        println!("Something went wrong when receiving, error: {:?}", e);
    }
}