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%