RustMQ

该仓库是专注于MQTT协议的crate集合。

Crates

• mqtt3 - MQTT协议读写器
• netopt - TCP/SSL连接
• mqttc - Rust MQTT客户端

Binaries

• mqttc - 控制台MQTT客户端

客户端

客户端具有以下功能

• QoS 0，QoS 1，QoS 2 发布/订阅
• 最后一条消息
• 自动Ping
• 自动重连
• 支持SSL（包括TLS v1.1，TLS v1.2）
• 模块化：mqtt3，netopt
• 日志记录

连接

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");

发布

client.publish("a/b/c", "hello", PubOpt.at_least_once()).unwrap();
while (client.await().unwrap().is_some()) {};

订阅

client.subscribe("a/b/c").unwrap();
loop {
    match client.await().unwrap() {
        Some(message) => {
            println!("{:?}", message);
        },
        None => {}
    }
}

命令行界面

MQTT客户端安装

git clone https://github.com/inre/rust-mq.git
cd rust-mq
make && make install

订阅所有主题

mqttc sub

或者尝试,

mqttc sub -a test.mosquitto.org
mqttc sub -a iot.eclipse.org
mqttc sub -a test.mosca.io
mqttc sub -a broker.hivemq.com

向主题发布

mqttc pub -t a/b/c -m "hello"

服务器

也许在将来