mqtt-service

此crate提供了对MQTT响应模式的便捷支持。它使用rumqttc库连接到MQTT代理。

如何使用

cargo add mqtt-service

let connection = mqtt_service::Connection::new("name-of-the-client", "localhost", 1883);
let r = connection.call_service("name/of/service" "Some data");
let res = futures::executor::block_on(r.unwrap());
println!("Result is '{res:?}'");