13 releases

0.1.13 May 22, 2024
0.1.11 Jan 10, 2024
0.1.10 Dec 12, 2023
0.1.9 Jul 8, 2023
0.1.5 Apr 27, 2023

#394 in Network programming

Download history 20/week @ 2024-03-13 13/week @ 2024-03-27 28/week @ 2024-04-03 94/week @ 2024-04-17 47/week @ 2024-04-24 128/week @ 2024-05-22

873 downloads per month

Apache-2.0

130KB
3K SLoC

walle_mqtt_protocol

快速开始

一个Rust实现的mqtt协议解析库

let connect = MqttMessageBuilder::connect()
        .client_id("client_01")
        .keep_alive(10)
        .clean_session(true)
        .username("rump")
        .password("mq")
        .protocol_level(crate::MqttVersion::V4)
        .retain(false)
        .will_qos(crate::QoS::AtLeastOnce)
        .will_topic("/a")
        .will_message(Bytes::from_static(b"offline"))
        .build().unwarp();

MqttMessageBuilder: 是MQTT报文的构建器,提供了多种MQTT报文的构建方式。 MqttMessageBuilder并没有具体的属性,MqttMessageBuilder提供了其他具体Builder的方法,例如:

pub fn connect() -> ConnectBuilder {
    ConnectBuilder::new()
}

Encoder和Decoder

/// 编码
pub trait Encoder: Sync + Send + 'static {
    fn encode(&self, buffer: &mut BytesMut) -> Result<usize, ProtoError>;
}

/// 解码
pub trait Decoder: Sync + Send + 'static {
    // 定义的返回类型
    type Item;
    type Error;
    // 将bytes解析为对应的报文
    fn decode(bytes: Bytes) -> Result<Self::Item, Self::Error>;
}

Encoder和Decoder实现了Bytes和Mqtt报文的相互转换,每种MQTT报文类型都实现了Encoder和Decoder,以Connect报文为例:

fn encode_and_decode_for_connect_should_be_work() {
    let connect = build_connect().unwrap();
    println!("原始connect = {:?}", connect);
    let mut bytes = BytesMut::new();
    let mut bytes1 = BytesMut::new();
    // encoder
    connect.encode(&mut bytes).unwrap();
    println!("bytes = {:?}", bytes);
    let connect1 = Connect::decode(bytes.freeze());
    match connect1 {
        Ok(connect) => {
            println!("connect1 = {:?}", connect);
            connect.encode(&mut bytes1).unwrap();
            println!(
                "encode_and_decode_for_connect_shoud_be_work bytes1  = {:?}",
                bytes1
            );
            // decoder
            let connect2 = Connect::decode(bytes1into()).unwrap();
            println!("connect2 = {:?}", connect2);
        }
        Err(err) => println!("编解码出错"),
    }
}

Dependencies

~1–1.7MB
~34K SLoC