Awesome GitHub RepositoriesTopic-Based Messaging

uWebSockets is a C++ networking framework that serves as a high-performance WebSocket server library, HTTP web server, and pub-sub messaging system. It provides the infrastructure necessary to handle standard web requests and maintain low-latency, bidirectional connections between clients and servers. The framework is distinguished by its use of template meta-programming for compile-time optimization and zero-copy buffer management to minimize memory latency. It utilizes a backend-agnostic event loop and static route resolution to process network traffic with minimal runtime overhead. The pr

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

ipfs-desktop is a graphical application for managing a local IPFS node, hosting content, and interacting with the peer-to-peer network. It serves as a desktop client that provides a visual interface for content-addressed storage management, peer-to-peer file sharing, and the administration of the node lifecycle. The project differentiates itself by providing a comprehensive suite of controllers for node health, gateway routing, and static site hosting. It includes a dedicated content-addressed storage browser for importing and organizing files, a gateway controller to route network content th

This project provides a technical specification and reference manual for the MQTT 3.1.1 standard, serving as a translated Chinese guide for implementing this lightweight IoT messaging protocol in resource-constrained device networks. The documentation covers the fundamental mechanisms of the publish-subscribe model, including topic-based routing with wildcard filtering, retained message storage, and the configuration of last will and testament messages. It details the protocol's approach to reliability through various quality of service levels, ranging from single-level acknowledgments to exa

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.

Console est un outil de gestion basé sur le web pour surveiller et administrer les clusters Kafka. Il fournit une interface graphique pour gérer les topics, les groupes de consommateurs et les flux de données en temps réel. Le projet inclut des gestionnaires dédiés pour Kafka Connect et le Schema Registry, permettant le déploiement de connecteurs de données et la gouvernance des schémas de données. Il dispose d'un tableau de bord de cluster pour suivre la santé des brokers, l'utilisation du stockage et l'état des racks, ainsi qu'une interface pour le contrôle d'accès basé sur les rôles et l'inspection des journaux d'audit. La plateforme couvre la navigation et le filtrage des données, la coordination des groupes de consommateurs et la construction de pipelines de données. Elle prend également en charge la surveillance des tâches de transformation de données et la gestion des autorisations des utilisateurs via un moteur de politique centralisé.

embedded-notes is a collection of technical study guides and development notes focused on embedded Linux, Linux kernel internals, and C programming. It serves as a reference for embedded systems development and a preparation resource for technical interviews in the field. The project provides detailed documentation on writing device drivers, managing virtual memory, and understanding kernel internals. It also includes guides on IoT network protocols, such as MQTT and TCP/IP, and outlines the architectural details of chip architectures and hardware peripherals. The material covers a broad sur

MQTT-Explorer is a visualization tool and debugger for MQTT brokers. It provides a web-based interface for inspecting real-time message traffic and analyzing topic structures through a hierarchical browser. The tool organizes incoming messages into a nested tree structure to simplify the observation of data flows and broker activity. It includes a mobile-friendly dashboard with optimized layouts and interaction patterns for monitoring broker state on touch devices. The application supports the debugging of internet-of-things devices and the administration of MQTT networks. It provides capabi

This project is a cross-platform C library designed for implementing MQTT messaging in applications. It serves as an asynchronous networking toolkit that enables resource-constrained systems and distributed components to exchange telemetry data and control signals with messaging brokers. The library distinguishes itself through a state-machine-based protocol handler that manages connection lifecycles and persistent session states, ensuring reliable message delivery even during intermittent network connectivity. It utilizes a background thread to manage network operations, allowing application

Js-csp is a concurrency library that implements communicating sequential processes with channels and generator-based routines for asynchronous programming in JavaScript. It provides a framework for building data processing pipelines and managing concurrent workflows, bringing Go-style channels and process coordination primitives to applications. The library coordinates message passing through buffered channels, stream mixing, multi-channel selection, and pub-sub broadcasting. Communication pathways support unbuffered rendezvous, fixed buffers, sliding windows, and dropping overflow. Operation

This project is a Java messaging software development kit designed to facilitate real-time data exchange between applications and message brokers. It functions as an MQTT client library, providing the necessary tools to implement publish-and-subscribe messaging patterns within distributed systems and internet-connected device environments. The library distinguishes itself through its focus on resilient network connectivity and reliable message delivery. It manages persistent connections through internal state machines that handle automatic reconnection and keep-alive heartbeats, ensuring stab