Implementazione di un broker MQTT

Question

Sto cercando di implementare un broker Java MQTT su Google Compute Engine. Il mio broker verrà utilizzato per gestire un numero molto elevato di messaggi SUBSCRIBE e PUBLISH dai dispositivi IoT. Quindi, sto pensando di utilizzare la funzione di scalabilità automatica per soddisfare le mie esigenze di carico.

Non sono sicuro di quale broker MQTT basato su Java Open Source debba utilizzare per avviare la mia implementazione. Speravo di poter ottenere alcuni suggerimenti. Sto cercando specificamente un broker open source che supporti funzionalità come abbonati durevoli, messaggi conservati, caratteri jolly ecc.

Inoltre, poiché MQTT è basato su TCP, potrei semplicemente creare da zero il mio broker che utilizza socket Java e ascolta su un porto? Sto assumendo che la risposta per questo è no, ma mi piacerebbe chiarirlo.

Answer 1

C'è una lista di implementazioni di broker disponibili qui:

https://github.com/mqtt/mqtt.github.io/wiki/servers

dovrebbe essere abbastanza aggiornato, ma non possono comprendere assolutamente tutte le implementazioni. Alcuni dei broker basati su Java sono:

• HiveMQ
• Moquette
• ActiveMQ

Non sono tutti opensource, ma ci sono diversi

Non ci dovrebbe essere alcun motivo per cui si couldn implementare il proprio broker, le specifiche del protocollo sono qui:

http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html

Answer 2

Considerare anche un broker Mqtt come modulo vert.x come this.

Per la seconda domanda, la risposta è sì, shure.

Ma perché reinventare la ruota?