message-io
message-io
is an asynchronous network message library for building clients and servers.
This library offers an event-based API over an abstraction network transport layer.
This library can be used but it is still growing, so if you see any bug or strange behaviour, please put an issue! Of course, any contribution is welcome!
For who is this project?
- People who want to make an application that needs to communicate over tcp/udp protocols.
- People who want to make a multiplayer game (server and/or client).
- People who don't want to deal with concurrence or socket connection problems.
- People who want to push the effort in the messages among the apps, not in how to transport them.
Features
- Asynchronous: internal poll event with non-blocking sockets.
- Really easy API:
- Abstraction from transport layer: Do not thinks about sockets, only thing about data messages.
- Only two main entities: an extensible event-queue to manage all events. and a network manager to manage the connections, and send/receive data.
- Forget concurrence problem: "One thread to rule them all",
- Significant performance: one thread for manage all internal conenctions over a OS poll, binary serialization, small overhead over OS sockets).
Getting started
Add to your Cargo.toml
message-io = "0.1"
Documentation
Example
The following example is simplest server that reads HelloServer
message
and responses with a HelloClient
message.
It is capable to manage several client connections and listen from 2 differents ports and interfaces.
use ;
use ;
use ;
Basic concepts
The library has two main pieces:
EventQueue
: Is a generic and synchronized queue where all the system events are sent. The user must be read these events in its main thread in order to dispatch actions.
NetworkManager
: It is an abstraction layer of the transport protocols that works over non-blocking sockets. It allows to create/remove connections, send and receive messages (defined by the user).
To manage the connections the NetworkManager
offers an Endpoint
that is an unique identifier of the connection
that can be used to remove, send or identify input messages.
The power comes when both pieces joins together, allowing to process all actions from one thread.
To reach this, the user have to connect the NetworkManager
to the EventQueue
sending NetEvent
produced by the first one.
Test yourself!
Clone the repository and test the basic
example that you can found in examples/basic
:
Run the server:
cargo run --example basic server [tcp/udp]
In other terminals, run one or more clients:
cargo run --example basic client [tcp/udp]
(By default, if no protocol is specified, tcp
is used)