Skip to content

Latest commit

 

History

History
61 lines (51 loc) · 2.03 KB

README.md

File metadata and controls

61 lines (51 loc) · 2.03 KB
Raw

vertx-mqtt-broker-mod

MQTT broker implementation as Vert.x module.

Credits:
Moquette https://github.com/andsel/moquette for coder and decoder implementation of MQTT messages.

Quick Start

Requires Vert.x 3.0.0 and Maven 3+

git clone https://github.com/giovibal/vertx-mqtt-broker-mod.git
cd vertx-mqtt-broker-mod
mvn clean install

use vertx command to start the service ...

vertx run maven:io.github.giovibal.mqtt:vertx-mqtt-broker-mod:2.0-SNAPSHOT::mqtt-broker -conf config.json
vertx run maven:io.github.giovibal.mqtt:vertx-mqtt-broker-mod:2.0-SNAPSHOT::mqtt-broker -Dvertx.metrics.options.jmxEnabled=true -conf config.json

vertx run io.github.giovibal.mqtt.MQTTBroker -cp target/vertx-mqtt-broker-mod-2.0-SNAPSHOT-fat.jar -conf conf.json

or uber jar ...

java -jar target/vertx-mqtt-broker-mod-2.0-SNAPSHOT-fat.jar -conf config.json
java -Dvertx.metrics.options.jmxEnabled=true -jar target/vertx-mqtt-broker-mod-2.0-SNAPSHOT-fat.jar -conf config.json

cluster ...

vertx run maven:io.github.giovibal.mqtt:vertx-mqtt-broker-mod:2.0-SNAPSHOT::mqtt-broker -conf config.json -cluster -cluster-host <IP>
vertx run io.github.giovibal.mqtt.MQTTBroker -cp target/vertx-mqtt-broker-mod-2.0-SNAPSHOT-fat.jar -conf config1.json -cluster -cluster-host <IP>

Features

  • Suport both QoS 0, 1 and 2 messages
  • Persistence and session management (cleanSession=false)
  • Multi-tenancy: isolation of topics and storage, just use username@tenant as username
  • MQTT over WebSocket
  • Retain flag
  • Oauth2 authentication integrated with WSO2 Identity Server
  • TLS support over TCP and Websocket
  • Multiple endpoint configuration in the same broker instance

Work in progress

  • Refactoring, new architecture
  • Clustering and Hign Availability

Roadmap

  • Pluggable persistence
  • Implement some out-of-the-box persistence managers: RAM, Cassandra, HBase, MongoDB
  • Implement will message support