Awesome GitHub RepositoriesMQTT Message Brokers

RocketMQ is a cloud-native distributed messaging platform and streaming engine. It functions as a distributed transactional queue that ensures atomicity between local transactions and message delivery, and serves as an MQTT IoT message broker to bridge lightweight device traffic into high-performance data streams. The system is distinguished by a Kubernetes-native architecture that decouples compute from storage to allow independent scaling of traffic and data retention. It utilizes a tiered storage model to offload older data to remote storage and employs quorum-based replication and automat

RocketMQ is a distributed messaging and streaming platform designed for building event-driven applications. It serves as middleware to decouple services using publish-subscribe and request-reply patterns, and functions as a transactional messaging system that ensures atomicity by linking message delivery to local transaction outcomes. The platform includes specialized capabilities as a Kubernetes-native message broker for container orchestration environments and an MQTT broker for ingesting event data from mobile applications and hardware terminals. The system covers high-throughput data str

Mosquitto este un broker de mesaje MQTT și un server de mesagerie IoT conceput pentru a ruta datele între publisheri și subscriberi. Acesta funcționează ca un hub de rețea centralizat care permite comunicarea ușoară între senzori distribuiți, controllere și alte dispozitive internet-of-things. Proiectul include un gateway de bridging MQTT utilizat pentru a conecta brokeri separați, permițând rutarea și sincronizarea traficului între diferite locații de rețea sau zone de securitate. De asemenea, oferă o implementare de client pentru conectarea și interacțiunea cu brokerul. Sistemul gestionează rutarea mesajelor bazată pe topicuri și schimburile de tip pub/sub, susținute de controlul accesului și autentificarea brokerului. Include capabilități pentru persistența datelor pentru a recupera starea după restarturi și o interfață web pentru administrarea și monitorizarea brokerului.

TeslaMate este un sistem self-hosted pentru înregistrarea și arhivarea telemetriei de la vehiculele Tesla într-o bază de date locală. Funcționează ca un logger de date auto și dashboard de telemetrie conceput pentru a menține local un istoric complet al condusului și al datelor de stare ale vehiculului. Sistemul include un tracker al costurilor de încărcare a vehiculului pentru a monitoriza costul financiar al sesiunilor de încărcare pe baza consumului de energie și a tarifelor la electricitate. De asemenea, dispune de un manager de locații cu geofencing pentru definirea unor limite geografice personalizate pentru a eticheta automat locațiile vizitate și un broker de date pentru automatizarea locuinței care publică starea vehiculului în timp real către un broker local. Proiectul oferă capabilități pentru analiza sănătății bateriei, monitorizarea consumului de energie și vizualizarea metricilor vehiculului. Suportă, de asemenea, importul de date istorice, gestionarea locațiilor personalizate și integrarea cu instrumente externe de smart home.

ejabberd is a multi-protocol communication gateway and scalable server that implements XMPP for instant messaging and presence. It serves as a federated messaging platform, enabling interoperable communication and user discovery between different remote servers. The project functions as an MQTT message broker for lightweight IoT device communication and a SIP signaling server for managing voice and multimedia signaling traffic. It allows for the hosting of multiple domains on a single instance using virtual hosting to isolate configurations and prevent username conflicts. The system provides

DietPi is an ultra-lightweight Debian distribution and software platform purpose-built for single-board computers. It provides a minimal operating system that strips away unnecessary services to reduce CPU and RAM usage, and includes a curated software catalogue of pre-optimised applications that can be installed with a single command. The system reads a plain-text configuration file before first boot to perform unattended OS and software installation, and offers a web interface for remote system administration. What distinguishes DietPi is its comprehensive, integrated approach to turning a

GreptimeDB is a distributed, open-source time-series database built for unified observability. It stores and queries metrics, logs, and traces together in a single columnar engine, supporting both SQL and PromQL for analysis. The database is designed as a Kubernetes-native operator with a decoupled compute and storage architecture, enabling horizontal scaling and multi-region deployment. What distinguishes GreptimeDB is its role as a multi-protocol ingestion gateway, accepting data through OpenTelemetry, Prometheus Remote Write, InfluxDB, Loki, Elasticsearch, Kafka, and MQTT protocols without

Easegress is a cloud-native traffic orchestration platform that functions as a multi-protocol API gateway and service mesh proxy. It routes, transforms, and orchestrates HTTP and MQTT traffic through configurable filter chains, providing high availability, security controls, and resilience for backend services. The platform integrates with service discovery systems like Kubernetes, Consul, and Eureka to dynamically route traffic to discovered services with automatic failover and health monitoring. The system distinguishes itself through a pipeline-based filter chain architecture where request

Acest proiect este site-ul oficial de documentație și portalul standard de comunicare pentru protocolul de mesagerie MQTT. Servește ca un hub central pentru specificații tehnice și ghiduri de implementare concepute pentru mesageria lightweight în mediile internet-of-things. Site-ul este implementat ca un site web static, utilizând generarea de site-uri statice și autorizarea conținutului bazată pe markdown pentru a distribui specificațiile protocolului și standardele tehnice. Resursele acoperă o gamă largă de capabilități de mesagerie industrială și conectivitate, inclusiv rutarea publish-subscribe, garanții de livrare quality-of-service și persistența stării bazată pe sesiune. De asemenea, oferă documentație privind transportul securizat al datelor folosind criptarea TLS și strategii pentru gestionarea scalării masive a dispozitivelor și a hardware-ului cu resurse limitate.

Pushdeer este un serviciu de notificări push self-hosted conceput pentru a livra alerte instantanee către dispozitive mobile și hardware IoT. Funcționează ca un backend centralizat pentru gestionarea și rutarea notificărilor personalizate printr-un server privat. Sistemul se distinge prin capabilitatea de notificare push fără aplicație (appless), care utilizează funcțiile native ale sistemului de operare pentru a primi alerte fără a necesita o aplicație client dedicată instalată pe telefon. Pentru integrarea IoT, operează ca un gateway de mesagerie folosind protocolul MQTT pentru a trimite notificări text și imagine în timp real către hardware-ul inteligent. Platforma include o suită completă de gestionare pentru cheile API și token-urile de înregistrare a dispozitivelor pentru a securiza pipeline-ul de notificări. Suportă redirecționarea notificărilor externe de la platforme terțe prin formate JSON personalizate și oferă rutare bazată pe topicuri pentru a direcționa tipuri specifice de conținut către dispozitive țintă. Capabilitățile specifice hardware-ului includ randarea imaginilor pe ecranele dispozitivelor, sincronizarea timpului de rețea și capacitatea de a declanșa alerte fizice, cum ar fi buzzerele. Backend-ul este furnizat ca un mediu containerizat conceput pentru implementare folosind Docker și Compose.

MQTTnet este o bibliotecă .NET care oferă un framework pentru implementarea clienților și brokerilor MQTT. Include o implementare de broker pentru găzduirea unui hub central de mesaje care rutează mesajele între clienții conectați și o bibliotecă client pentru publicarea și abonarea la mesaje. Proiectul suportă atât straturi de transport TCP, cât și WebSocket, permițând traficul de date securizat prin transport layer security (TLS). Permite dezvoltarea de middleware personalizat pentru a intercepta, transforma sau valida mesajele pe măsură ce trec printr-un server. Zonele de capabilitate includ rutarea distribuită a mesajelor, gestionarea conexiunilor persistente cu cozi de calitate a serviciului (QoS) și primitive de securitate pentru validarea acreditărilor clienților și restricționarea abonamentelor la topicuri.

MQTTnet is a comprehensive MQTT library for .NET that supports both client and broker roles in a single codebase. It provides a full-featured broker implementation capable of hosting a server with access control, message interception, session persistence, and support for mixed MQTT protocol versions. The client side offers robust publish-subscribe communication with automatic reconnection that preserves quality-of-service guarantees, ensuring reliable message delivery across network interruptions. The library distinguishes itself with a plugin-based authentication pipeline for validating clie

JimsGarage is a collection of shell scripts and automation tools designed to help individuals deploy and manage a wide range of self-hosted services on their own hardware. It provides a structured approach to setting up containerized applications, from media servers and document management systems to VPNs and monitoring stacks, all through automated Docker-based configurations. The project distinguishes itself by offering a comprehensive library of deployment recipes that cover the full lifecycle of a home server environment. This includes not just the services themselves, but also the suppor

blinker-js este un framework de comunicare IoT și o bibliotecă Node.js concepută pentru a gestiona schimbul bidirecțional de date între hardware-ul embedded și serverele la distanță sau rețelele locale. Funcționează ca un instrument de integrare hardware MQTT care leagă computerele single-board de cloud-urile IoT pentru gestionare și control de la distanță. Proiectul oferă un manager de widget-uri pentru dispozitive virtuale, pentru a sincroniza starea hardware-ului cu componentele interfeței utilizator bazate pe cloud. Acest sistem permite maparea identificatorilor UI de la distanță către logica software internă, permițând controlul IoT de la distanță prin butoane virtuale și câmpuri de introducere a datelor. Framework-ul suportă atât comunicarea bazată pe cloud prin protocolul MQTT, cât și comunicarea directă între dispozitive în rețeaua locală prin conexiuni wireless partajate. Include capabilități pentru ascultarea evenimentelor dispozitivului și gestionarea fluxurilor de date bidirecționale pentru a declanșa acțiuni hardware.

Emitter is a distributed pub-sub platform and message brokering system that decouples senders and receivers through topic-based routing. It functions as an MQTT message broker and WebSocket communication server, enabling real-time data exchange between hardware devices and web-based clients. The system acts as a secure channel orchestrator and message persistence engine. It ensures delivery through a storage system that buffers historical messages and queues data for offline subscribers. Access to these data streams is managed via time-limited permission keys that enforce granular read and wr

Blynk este un framework pentru dispozitive embedded și bibliotecă de conectivitate IoT cloud, concepută pentru a stabili o comunicare securizată, bidirecțională, între microcontrolere și o platformă de management la distanță. Oferă identitatea de bază a unui instrument de gestionare a dispozitivelor IoT, permițând sincronizarea stărilor dispozitivelor, controlul hardware-ului la distanță și maparea datelor hardware către interfețe bazate pe cloud. Proiectul se distinge printr-un sistem de pini virtuali care decuplează comunicarea cloud de pinii fizici, permițând schimbul de date independent de hardware. De asemenea, suportă offloading arhitectural avansat, unde comunicarea în rețea poate fi delegată unui co-procesor dedicat pentru a suporta microcontrolere neconectate. Biblioteca acoperă o gamă largă de capabilități, inclusiv provizionarea automată a dispozitivelor, actualizări de firmware over-the-air și o structură organizațională multi-tenant pentru gestionarea flotei. Integrează diverse protocoale de comunicare, cum ar fi MQTT și HTTPS, și oferă instrumente pentru automatizare bazată pe logică, stocarea datelor de tip time-series și construirea de dashboard-uri mobile și web pentru monitorizare în timp real. Proiectul este implementat în C++.