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 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.

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 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.

Console is a web-based management tool for monitoring and administering Kafka clusters. It provides a graphical interface for managing topics, consumer groups, and real-time data flows. The project includes dedicated managers for Kafka Connect and the Schema Registry, allowing for the deployment of data connectors and the governance of data schemas. It features a cluster dashboard for tracking broker health, storage usage, and rack status, alongside an interface for role-based access control and audit log inspection. The platform covers data browsing and filtering, consumer group coordinatio

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 este un instrument de vizualizare și debugger pentru brokerii MQTT. Acesta oferă o interfață bazată pe web pentru inspectarea traficului de mesaje în timp real și analizarea structurilor de topicuri printr-un browser ierarhic. Instrumentul organizează mesajele primite într-o structură de arbore imbricată pentru a simplifica observarea fluxurilor de date și a activității brokerului. Include un dashboard prietenos pentru mobil, cu layout-uri optimizate și modele de interacțiune pentru monitorizarea stării brokerului pe dispozitive tactile. Aplicația suportă depanarea dispozitivelor internet-of-things și administrarea rețelelor MQTT. Oferă capacități pentru vizualizarea traficului, monitorizarea brokerului și inspecția payload-ului. Software-ul poate fi utilizat ca serviciu web accesibil prin browser sau ca aplicație desktop.

Acest proiect este o bibliotecă C cross-platform concepută pentru implementarea mesageriei MQTT în aplicații. Servește drept toolkit de rețelistică asincronă care permite sistemelor cu resurse limitate și componentelor distribuite să schimbe date de telemetrie și semnale de control cu brokeri de mesagerie. Biblioteca se distinge printr-un handler de protocol bazat pe mașină de stări care gestionează ciclurile de viață ale conexiunii și stările persistente ale sesiunii, asigurând livrarea fiabilă a mesajelor chiar și în timpul conectivității intermitente la rețea. Utilizează un thread de fundal pentru a gestiona operațiunile de rețea, permițând aplicațiilor să mențină receptivitatea printr-un sistem de notificare bazat pe callback-uri. Mai mult, biblioteca dispune de o abstractizare de transport „pluggable” care susține diverse canale de comunicare, inclusiv TCP, TLS și WebSockets, printr-o interfață de conexiune unificată bazată pe URI. Software-ul oferă o suită cuprinzătoare de capabilități de mesagerie, inclusiv niveluri configurabile de calitate a serviciului (QoS), publicare și abonare bazată pe subiecte și capacitatea de a atașa metadate mesajelor. De asemenea, încorporează trasarea diagnostică și logarea execuției la runtime pentru a asista la monitorizarea activității rețelei și depanarea tranzițiilor de protocol.

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

Acest proiect este un SDK de mesagerie Java conceput pentru a facilita schimbul de date în timp real între aplicații și brokeri de mesagerie. Funcționează ca o bibliotecă de client MQTT, oferind instrumentele necesare pentru a implementa tipare de mesagerie de tip „publish-and-subscribe” în sisteme distribuite și medii de dispozitive conectate la internet. Biblioteca se distinge prin accentul pus pe conectivitatea rezilientă la rețea și livrarea fiabilă a mesajelor. Gestionează conexiunile persistente prin mașini de stări interne care se ocupă de reconectarea automată și „keep-alive heartbeats”, asigurând stabilitatea în medii cu acces intermitent la rețea. Aplicațiile pot configura niveluri specifice de calitate a serviciului (QoS) pentru a garanta integritatea datelor, variind de la „fire-and-forget” la livrarea „exactly-once”, și pot utiliza configurații „last-will-and-testament” pentru a gestiona deconectările neașteptate ale clienților. Framework-ul susține procesarea datelor de mare volum prin utilizarea unor primitive de comunicare asincrone, non-blocking. Permite dezvoltatorilor să ruteze mesajele prin abonamente bazate pe subiecte, inclusiv suport pentru tipare wildcard, în timp ce urmăresc progresul operațiunilor individuale prin handle-uri bazate pe token-uri. Biblioteca este distribuită ca un kit de dezvoltare Java standard pentru integrarea în infrastructura mai largă de mesagerie și IoT.