Crates.io | nng-c |
lib.rs | nng-c |
version | 1.8.0-beta.3 |
source | src |
created_at | 2024-05-31 13:08:12.177686 |
updated_at | 2024-06-01 04:58:30.645702 |
description | High level bindings nng C library |
homepage | |
repository | https://github.com/DoumanAsh/nng-c |
max_upload_size | |
id | 1258008 |
size | 90,353 |
High level bindings to nng.
Version corresponds to C library
http
- Enables http transporttls
- Enables TLS transportwebsocket
- Enables websocket transport. Implies http
feature.log
- Enables logging via log crateBasic example of client and server communication
use nng_c::{options, Socket, Message, ErrorCode};
use core::time;
//Feel free to append zero char to avoid unnecessary allocations
const ADDR: &str = "ipc://nng-c-example\0";
const REQ_TIMEOUT: options::Req = options::Req {
resend_time: Some(time::Duration::from_millis(50)),
resend_tick: Some(time::Duration::from_millis(1)),
};
fn server() -> Result<(), ErrorCode> {
let server = Socket::rep0()?;
server.listen(ADDR.into()).expect("listen");
loop {
let msg = server.recv_msg()?;
let body = msg.body();
let msg = core::str::from_utf8(body).expect("utf-8 bytes");
match msg {
"quit" => break Ok(()),
other => {
println!("Received bytes(len={})={:?}", other.len(), other);
}
}
}
}
let server = std::thread::spawn(server);
//Wait for thread to spin
std::thread::sleep(time::Duration::from_millis(10));
let client = Socket::req0().expect("Create client");
client.set_opt(REQ_TIMEOUT).expect("Set options");
client.connect(ADDR.into()).expect("connect");
let mut msg = Message::new().expect("create message");
msg.append("ping".as_bytes()).expect("Input bytes");
client.send_msg(msg).expect("send message");
let mut msg = Message::new().expect("create message");
msg.append("quit".as_bytes()).expect("Input bytes");
client.send_msg(msg).expect("send quit");
server.join().expect("Finish server successfully");