Rust语言从入门到精通系列 - 一文读懂MQTT的LWT特性

1
use paho_mqtt as mqtt;
2
use std::time::Duration;
3

4
fn main() {
5
    // 创建MQTT客户端
6
    let cli = mqtt::Client::new("tcp://localhost:1883").unwrap();
7

8
    // 设置LWT特征
9
    let lwt = mqtt::Message::new("lwt", "offline", 0);
10
    let conn_opts = mqtt::ConnectOptionsBuilder::new()
11
        .will_message(lwt)
12
        .clean_session(false)
13
        .connect_timeout(Duration::from_secs(5))
14
        .finalize();
15

16
    // 连接MQTT服务器
17
    let tok = cli.connect(conn_opts);
18
    tok.wait().unwrap();
19

20
    // 订阅主题
21
    let topic = "hello/world";
22
    let qos = 1;
23
    let tok = cli.subscribe(topic, qos);
24
    tok.wait().unwrap();
25

26
    // 发送消息
27
    let payload = "hello, world!";
28
    let msg = mqtt::Message::new(topic, payload, qos);
29
    let tok = cli.publish(msg);
30
    tok.wait().unwrap();
31

32
    // 接收消息
33
    for _ in 0..10 {
34
        let msg = cli.start_consuming().recv_timeout(Duration::from_secs(1)).unwrap();
35
        println!("Received message: {:?}", msg);
36
    }
37

38
    // 断开连接
39
    let tok = cli.disconnect(None);
40
    tok.wait().unwrap();
41
}