异步 MQTT 客户端

此包实现了一个使用 libmosquitto 的异步 MQTT 客户端。

use mosquitto_rs::*;

fn main() -> Result<(), Error> {
    smol::block_on(async {
        let mut mosq = Client::with_auto_id()?;
        let rc = mosq.connect("localhost", 1883, std::time::Duration::from_secs(5), None).await?;
        println!("connect: {}", rc);

        let subscriptions = mosq.subscriber().unwrap();

        mosq.subscribe("test", QoS::AtMostOnce).await?;
        println!("subscribed");

        mosq.publish("test", b"woot", QoS::AtMostOnce, false)
            .await?;
        println!("published");

        if let Ok(msg) = subscriptions.recv().await {
            println!("msg: {:?}", msg);
        }

        Ok(())
    })
}

lib.rs:

此包实现了一个使用 libmosquitto 的异步 MQTT 客户端。

use mosquitto_rs::*;

fn main() -> Result<(), Error> {
    smol::block_on(async {
        let mut client = Client::with_auto_id()?;
        let rc = client.connect(
                       "localhost", 1883,
                       std::time::Duration::from_secs(5), None).await?;
        println!("connect: {}", rc);

        let subscriptions = client.subscriber().unwrap();

        client.subscribe("test", QoS::AtMostOnce).await?;
        println!("subscribed");

        client.publish("test", b"woot", QoS::AtMostOnce, false)
            .await?;
        println!("published");

        if let Ok(msg) = subscriptions.recv().await {
            println!("msg: {:?}", msg);
        }

        Ok(())
    })
}

功能

以下功能标志可用

• router - 包含路由模块和 MqttRouter 类型。默认启用。
• vendored-mosquitto - 使用打包的 libmosquitto 2.4 库。默认启用。
• vendored-mosquitto-tls - 在打包的 libmosquitto 中启用 TLS 支持。默认启用。
• vendored-openssl - 从源代码构建 openssl，而不是使用系统库。推荐 macOS 和 Windows 用户启用此功能。