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 is an MQTT message broker and IoT messaging server designed to route data between publishers and subscribers. It functions as a centralized network hub that enables lightweight communication between distributed sensors, controllers, and other internet-of-things devices. The project includes an MQTT bridging gateway used to link separate brokers, allowing traffic to be routed and synchronized across different network locations or security zones. It also provides a client implementation for connecting to and interacting with the broker. The system manages topic-based message routing

TeslaMate est un système auto-hébergé pour enregistrer et archiver la télémétrie des véhicules Tesla dans une base de données locale. Il fonctionne comme un enregistreur de données de véhicule et un tableau de bord de télémétrie conçu pour maintenir un historique complet des données de conduite et de l'état du véhicule localement. Le système inclut un tracker de coût de charge de véhicule pour surveiller le coût financier des sessions de charge basé sur l'utilisation d'énergie et les tarifs d'électricité. Il dispose également d'un gestionnaire de localisation par geofencing pour définir des limites géographiques personnalisées afin d'étiqueter automatiquement les lieux visités, et un courtier de données domotiques qui publie l'état du véhicule en temps réel vers un courtier local. Le projet fournit des capacités pour l'analyse de la santé de la batterie, la surveillance de la consommation d'énergie et la visualisation des métriques du véhicule. Il prend en charge l'importation de données historiques, la gestion de lieux personnalisés et l'intégration avec des outils de maison intelligente externes.

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

Ce projet est le site de documentation officiel et le portail de standard de communication pour le protocole de messagerie MQTT. Il sert de hub central pour les spécifications techniques et les directives d'implémentation conçues pour la messagerie légère dans les environnements internet-des-objets. Le site est implémenté en tant que site web statique, utilisant la génération de site statique et la création de contenu basée sur markdown pour distribuer les spécifications de protocole et les normes techniques. Les ressources couvrent un large éventail de capacités de messagerie et connectivité industrielles, incluant le routage publish-subscribe, les garanties de livraison de qualité de service et la persistance d'état basée sur session. Il fournit également de la documentation sur le transport de données sécurisé utilisant le chiffrement TLS et des stratégies pour gérer le passage à l'échelle massif des appareils et le matériel aux ressources limitées.

Pushdeer est un service de notification push auto-hébergé conçu pour envoyer des alertes instantanées vers des appareils mobiles et du matériel IoT. Il fonctionne comme un backend centralisé pour gérer et router des notifications personnalisées via un serveur privé. Le système se distingue par sa capacité de notification push sans application dédiée, qui exploite les fonctionnalités natives du système d'exploitation pour recevoir des alertes sans nécessiter d'application cliente installée sur le combiné. Pour l'intégration IoT, il fonctionne comme une passerelle de messagerie utilisant le protocole MQTT pour envoyer des notifications texte et image en temps réel vers du matériel intelligent. La plateforme inclut une suite de gestion complète pour les clés API et les jetons d'enregistrement d'appareils afin de sécuriser le pipeline de notification. Elle prend en charge le transfert de notifications externes depuis des plateformes tierces via des formats JSON personnalisés et fournit un routage basé sur les sujets pour diriger des types de contenu spécifiques vers des appareils ciblés. Les capacités spécifiques au matériel incluent le rendu d'images sur les écrans des appareils, la synchronisation de l'heure réseau et la capacité de déclencher des alertes physiques comme des buzzers. Le backend est fourni sous forme d'environnement conteneurisé conçu pour un déploiement utilisant Docker et Compose.

MQTTnet est une bibliothèque .NET fournissant un framework pour implémenter des clients et des brokers MQTT. Elle inclut une implémentation de broker pour héberger un hub de messages central qui route les messages entre les clients connectés, ainsi qu'une bibliothèque client pour publier et s'abonner aux messages. Le projet prend en charge les couches de transport TCP et WebSocket, permettant un trafic de données sécurisé via le protocole TLS (Transport Layer Security). Il permet le développement de middleware personnalisé pour intercepter, transformer ou valider les messages au fur et à mesure qu'ils transitent par un serveur. Les domaines de capacité incluent le routage de messages distribués, la gestion des connexions persistantes avec mise en file d'attente de qualité de service (QoS), et des primitives de sécurité pour la validation des identifiants clients et les restrictions d'abonnement aux sujets.

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 est un framework de communication pour appareils IoT et une bibliothèque Node.js conçue pour gérer l'échange de données bidirectionnel entre le matériel embarqué et des serveurs distants ou des réseaux locaux. Il fonctionne comme un outil d'intégration matérielle MQTT qui relie les ordinateurs monocartes aux clouds IoT pour la gestion et le contrôle à distance. Le projet fournit un gestionnaire de widgets pour appareils virtuels afin de synchroniser l'état du matériel avec les composants d'interface utilisateur basés sur le cloud. Ce système permet de mapper des identifiants d'interface utilisateur distants à la logique logicielle interne, permettant un contrôle IoT à distance via des boutons virtuels et des champs de saisie. Le framework prend en charge à la fois la communication basée sur le cloud via le protocole MQTT et la communication directe entre appareils sur le réseau local via des connexions sans fil partagées. Il inclut des capacités pour écouter les événements des appareils et gérer des flux de données bidirectionnels pour déclencher des actions matérielles.

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 est un framework de périphérique embarqué et une bibliothèque de connectivité cloud IoT conçue pour établir une communication sécurisée et bidirectionnelle entre des microcontrôleurs et une plateforme de gestion distante. Il fournit l'identité fondamentale d'un outil de gestion de périphérique IoT, permettant la synchronisation des états des périphériques, le contrôle matériel distant et le mappage des données matérielles vers des interfaces basées sur le cloud. Le projet se distingue par un système de broches virtuelles qui découple la communication cloud des broches physiques, permettant un échange de données indépendant du matériel. Il prend également en charge le déchargement architectural avancé, où la communication réseau peut être déléguée à un co-processeur dédié pour prendre en charge des microcontrôleurs non connectés. La bibliothèque couvre un large éventail de capacités, incluant le provisionnement automatisé des périphériques, les mises à jour de firmware over-the-air et une structure organisationnelle multi-tenant pour la gestion de flotte. Elle intègre divers protocoles de communication tels que MQTT et HTTPS, et fournit des outils pour l'automatisation basée sur la logique, le stockage de données de séries temporelles et la construction de tableaux de bord mobiles et web pour la surveillance en temps réel. Le projet est implémenté en C++.