rmqtt-net 0.1.0

Basic Implementation of MQTT Server

The basic implementation of MQTT proxy, supporting v3.1.1 and v5.0 protocols, with TLS and WebSocket functionality.

Basic Usage

use rmqtt_net::{Builder, ListenerType};
use std::net::SocketAddr;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let builder = Builder::new()
        .name("MyBroker")
        .laddr("127.0.0.1:1883".parse()?);

    let listener = builder.bind()?;
    loop {
        let acceptor = listener.accept().await?;
        let dispatcher = acceptor.tcp()?;
        // Handle connection...
    }
    Ok(())
}