8 unstable releases (3 breaking)

✓ Uses Rust 2018 edition

0.3.2 Sep 24, 2019
0.3.1 Sep 16, 2019
0.3.0 Jun 29, 2019
0.2.3 Jun 13, 2019
0.0.0 Oct 2, 2018

#2 in Game development

Download history 1117/week @ 2019-06-11 844/week @ 2019-06-18 891/week @ 2019-06-25 784/week @ 2019-07-02 599/week @ 2019-07-09 761/week @ 2019-07-16 677/week @ 2019-07-23 586/week @ 2019-07-30 562/week @ 2019-08-06 494/week @ 2019-08-13 451/week @ 2019-08-20 422/week @ 2019-08-27 549/week @ 2019-09-03 488/week @ 2019-09-10 657/week @ 2019-09-17

2,584 downloads per month
Used in 10 crates (3 directly)

MIT/Apache

245KB
4.5K SLoC

Laminar

Build Status Latest Version docs.rs Join us on Discord MIT/Apache Lines of Code Coverage

Laminar is a semi-reliable UDP-based protocol for multiplayer games. This library implements wrappers around the UDP-protocol, and provides a lightweight, message-based interface which provides certain guarantees like reliability and ordering.

Laminar was designed to be used within the Amethyst game engine but is usable without it.

If you are new to laminar or networking in general, We strongly recommend taking a look at the laminar book

Concepts

This library is loosely based off of Gaffer on Games and shares features similar as RakNet, Steam Socket, netcode.io. The idea is to provide an in rust written, low-level UDP-protocol which supports the use of cases of video games that require multiplayer features. The library itself provides a few low-level types of packets that provide different types of guarantees. The most basic are unreliable and reliable packets. Also ordering, sequencing can be done on multiple streams. For more information, read the projects README.md, book, docs or examples.

Table of contents:

Features

These are the features this crate provides:

  • Fragmentation
  • Unreliable packets
  • Unreliable sequenced packets
  • Reliable unordered packets
  • Reliable ordered packets
  • Reliable sequenced packets
  • Fragmentation
  • Rtt estimations
  • Protocol version monitoring
  • Basic connection management
  • Heartbeat
  • Basic DoS mitigation
  • High Timing control
  • Protocol Versioning
  • Well-tested by integration and unit tests
  • Can be used by multiple threads (Sender, Receiver)

Planned

  • Handshake Protocol
  • Advanced Connection Management
  • Cryptography
  • Congestion Control

Getting Stated

Add the laminar package to your Cargo.toml file.

[dependencies]
laminar = "0.3"

Useful Links

Examples

Please check out our examples for more information.

UDP API | see more

This is an example of how to use the UDP API.

Send packets

use laminar::{Socket, Packet};

// create the socket
let mut socket = Socket::bind("127.0.0.1:12345")?;
let packet_sender = socket.get_packet_sender();
// this will start the socket, which will start a poll mechanism to receive and send messages.
let _thread = thread::spawn(move || socket.start_polling());

// 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();

Receive Packets

use laminar::{SocketEvent, Socket};

// create the socket
let socket = Socket::bind("127.0.0.1:12346")?;
let event_receiver = socket.get_event_receiver();
// this will start the socket, which will start a poll mechanism to receive and send messages.
let _thread = thread::spawn(move || socket.start_polling());

// wait until a socket event occurs
let result = event_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);
    }
}

Authors

Note

This library is not fully stable yet, and there may be breaking changes to the API. For more advanced examples of using laminar, you can check out the Amethyst-Network crate.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

License

Licensed under either of

Dependencies

~0.8–1.4MB
~26K SLoC