MsgTrans是一个可同时监听多协议的网络框架，消息头采用二进制协议，兼容 Rust / D语言 / Typescript / C++ / Java 等语言，业务逻辑层只需要编写一套即可。
服务端示例代码
let mut server = MessageTransportServer::new();
// Add TCP channel
server.add_channel(TcpServerChannel::new("0.0.0.0", 9001)).await;
// Add WebSocket channel
server.add_channel(WebSocketServerChannel::new("0.0.0.0", 9002, "/ws")).await;
// Add QUIC channel
server.add_channel(QuicServerChannel::new(
"0.0.0.0",
9003,
"certs/cert.pem",
"certs/key.pem",
)).await;
// set some callback handler for server
server.start().await;
运行示例代码
cargo run --example server
客户端示例代码
# for tcp
cargo run --example client_tcp
# for websocket
cargo run --example client_websocket
# for quic
cargo run --example client_quic
生成秘钥
openssl req -x509 -newkey rsa:4096 -keyout key.pem -out cert.pem -days 365000 -nodes -subj "/CN=localhost"
消息包xie'y
+--------------------------------+
| Packet Header |
| +--------------------------+ |
| | Message ID (4 bytes) | |
| +--------------------------+ |
| | Message Length (4 bytes)| |
| +--------------------------+ |
| | Compression Type (1 byte)| |
| +--------------------------+ |
| | Extend Length (4 bytes) | |
| +--------------------------+ |
| | Reserved (3 bytes) | |
| +--------------------------+ |
+--------------------------------+
|
v
+--------------------------------+
| Extended Header Content |
| (variable length, Extend |
| Length specifies size) |
+--------------------------------+
|
v
+--------------------------------+
| Payload Content |
| (variable length, Message |
| Length specifies size) |
+--------------------------------+
协议结构说明：
- Header Content: Contains fixed-length header information, including Message ID, Message Length, Compression Type, and Extend Length.
- Extended Header Content: Variable-length extended header content, with its size specified by the Extend Length field.
- Payload Content: Variable-length payload content, with its size specified by the Message Length field.
评论