mqtt-server

MqttServer

[!WARNING] 🚧 This repository is for understanding the handling of MQTT and tokio, and experimental. It is a work in progress.

architecture

graph LR
    client["mqtt client"] <-- MQTT --> MQTTServer
    User <-- gRPC Publish/Streaming --> MQTTServer
    subgraph server
        direction BT 
        MQTTServer --> DB[(Database)]
    end

• The user can communicate with the server via gRPC and publish packets to the devices.

• The user can receive packets published by the devices through gRPC server streaming via the server.

• Pub/Sub communication between devices and the server via MQTT.

• The server utilizes tokio’s green threads to concurrently handle communication with multiple devices.

• I am currently only implementing QoS0 / MQTTv3.1

build

cargo build

Payload Storage

If you specify the address of Cassandra, you can save the latest published payload to Cassandra.

Usage

USAGE:
    mqtt-server [FLAGS] [OPTIONS]

FLAGS:
    -h, --help          Prints help information
    -n, --non-broker    server start in a mode where communication with clients occurs exclusively via gRPC, not through
                        an MQTT broker, and direct communication between clients is not possible.
        --non-tls       non tls mode
    -V, --version       Prints version information

OPTIONS:
    -a, --addr <IPADDR>                 server's address consist of port [default: 127.0.0.1:8883]
    -d, --db_addr <CASSANDRA IPADDR>    This is the port for Cassandra used to store the latest topics. If not
                                        specified, Cassandra will not be used. [default: ]
    -c, --cert <FILEPATH>               server cert @ pem format [default: server.crt]
    -k, --key <FILEPATH>                server key @ pem format [default: private.key]

Performance

@ MacBook Pro (Retina, 15-inch, Mid 2015)

tool: https://github.com/inovex/mqtt-stresser

./mqtt-stresser -broker tcp://localhost:8883 -num-clients 1 -num-messages 50000 -rampup-delay 1s -rampup-size 10 -global-timeout 180s -timeout 20s -publisher-qos 0

``` [~/mqtt-stresser]$./mqtt-stresser -broker tcp://localhost:8883 -num-clients 1 -num-messages 50000 -rampup-delay 1s -rampup-size 10 -global-timeout 180s -timeout 20s -publisher-qos 0 1 worker started # Configuration Concurrent Clients: 1 Messages / Client: 50000 # Results Published Messages: 50000 (100%) Received Messages: 50000 (100%) Completed: 1 (100%) Errors: 0 (0%) # Publishing Throughput Fastest: 74755 msg/sec Slowest: 74755 msg/sec Median: 74755 msg/sec < 74755 msg/sec 100% # Receiving Througput Fastest: 119381 msg/sec Slowest: 119381 msg/sec Median: 119381 msg/sec < 119381 msg/sec 100% ```

./mqtt-stresser -broker tcp://localhost:8883 -num-clients 10 -num-messages 50000 -rampup-size 10 -global-timeout 180s -timeout 20s -publisher-qos 0

``` $ ./mqtt-stresser -broker tcp://localhost:8883 -num-clients 10 -num-messages 50000 -rampup-size 10 -global-timeout 180s -timeout 20s -publisher-qos 0 10 worker started # Configuration Concurrent Clients: 10 Messages / Client: 500000 # Results Published Messages: 500000 (100%) Received Messages: 500000 (100%) Completed: 10 (100%) Errors: 0 (0%) # Publishing Throughput Fastest: 30030 msg/sec Slowest: 28068 msg/sec Median: 29399 msg/sec < 28265 msg/sec 10% < 29246 msg/sec 30% < 29442 msg/sec 50% < 29638 msg/sec 80% < 30030 msg/sec 90% < 30227 msg/sec 100% # Receiving Througput Fastest: 54237 msg/sec Slowest: 45185 msg/sec Median: 46254 msg/sec < 46090 msg/sec 40% < 46995 msg/sec 60% < 48806 msg/sec 80% < 53332 msg/sec 90% < 55142 msg/sec 100% ```

./mqtt-stresser -broker tcp://localhost:8883 -num-clients 100 -num-messages 5000 -rampup-size 10 -global-timeout 180s -timeout 20s -publisher-qos 0

``` $ ./mqtt-stresser -broker tcp://localhost:8883 -num-clients 100 -num-messages 5000 -rampup-size 10 -global-timeout 180s -timeout 20s -publisher-qos 0 # Configuration Concurrent Clients: 100 Messages / Client: 500000 # Results Published Messages: 500000 (100%) Received Messages: 500000 (100%) Completed: 100 (100%) Errors: 0 (0%) # Publishing Throughput Fastest: 26726 msg/sec Slowest: 12670 msg/sec Median: 16706 msg/sec < 14076 msg/sec 6% < 15481 msg/sec 19% < 16887 msg/sec 51% < 18292 msg/sec 73% < 19698 msg/sec 83% < 21103 msg/sec 89% < 22509 msg/sec 94% < 23915 msg/sec 96% < 25320 msg/sec 99% < 28131 msg/sec 100% # Receiving Througput Fastest: 50636 msg/sec Slowest: 1030 msg/sec Median: 1788 msg/sec < 5991 msg/sec 60% < 10951 msg/sec 70% < 15912 msg/sec 77% < 20873 msg/sec 80% < 25833 msg/sec 81% < 30794 msg/sec 84% < 35754 msg/sec 92% < 40715 msg/sec 93% < 45676 msg/sec 98% < 50636 msg/sec 99% < 55597 msg/sec 100% ```

This site is open source. Improve this page.