Expand description
一个Rust实现的mqtt协议解析库
use bytes::Bytes;
use walle_mqtt_protocol::{MqttVersion, QoS};
use walle_mqtt_protocol::v4::builder::MqttMessageBuilder;
let connect = MqttMessageBuilder::connect()
.client_id("client_01")
.keep_alive(10)
.clean_session(true)
.username("rump")
.password("mq")
.protocol_level(MqttVersion::V4)
.retain(false)
.will_qos(QoS::AtLeastOnce)
.will_topic("/a")
.will_message(Bytes::from_static(b"offline"))
.build().unwrap();
Modules§
Structs§
- Topic
- topic,客户端与服务端做信息交互的时候给消息做的标签
Enums§
- Message
Type - 数据类型
- Mqtt
Version - mqtt协议不同的版本,这里取最常用的两个版本
- QoS
- mqtt协议中对消息质量的定义 mqtt消息质量分为三种:
Constants§
- PROTOCOL_
NAME - MQTT报文中protocol name字段