4 releases
Uses old Rust 2015
0.1.3 | Jun 2, 2016 |
---|---|
0.1.2 | Apr 18, 2016 |
0.1.1 | Apr 17, 2016 |
0.1.0 | Mar 21, 2016 |
#21 in #mqtt-client
109 downloads per month
Used in 2 crates
62KB
2K
SLoC
RustMQ
This repository is the bundle of crates devoted to the MQTT protocol.
Crates
- mqtt3 - MQTT protocol reader/writer
- netopt - TCP/SSL connection
- mqttc - Rust MQTT client
Binaries
- mqttc - Console MQTT client
Client
The client has the following functionality:
- QoS 0, QoS 1, QoS 2 publish/subscribe
- Last Will message
- Auto-Ping
- Auto-Reconnect
- SSL supported (include TLS v1.1, TLS v1.2)
- Modular: mqtt3, netopt
- Logging
Connect
let netopt = NetworkOptions::new();
let mut opts = ClientOptions::new();
opts.set_reconnect(ReconnectMethod::ReconnectAfter(Duration::from_secs(1)));
let mut client = opts.connect("127.0.0.1:1883", netopt).expect("Can't connect to server");
Publish
client.publish("a/b/c", "hello", PubOpt.at_least_once()).unwrap();
while (client.await().unwrap().is_some()) {};
Subscribe
client.subscribe("a/b/c").unwrap();
loop {
match client.await().unwrap() {
Some(message) => {
println!("{:?}", message);
},
None => {}
}
}
Command line interface
MQTT Client installation:
git clone https://github.com/inre/rust-mq.git
cd rust-mq
make && make install
Subscribe to all topics:
mqttc sub
Or try,
mqttc sub -a test.mosquitto.org
mqttc sub -a iot.eclipse.org
mqttc sub -a test.mosca.io
mqttc sub -a broker.hivemq.com
Publish to the topic:
mqttc pub -t a/b/c -m "hello"
Server
Maybe in future
Dependencies
~0.2–1.7MB
~39K SLoC