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 是一个 MQTT 消息代理和物联网（IoT）消息服务器，旨在在发布者和订阅者之间路由数据。它作为一个中心化网络枢纽，实现了分布式传感器、控制器和其他物联网设备之间的轻量级通信。 该项目包含一个用于链接不同代理的 MQTT 桥接网关，允许流量在不同的网络位置或安全区域之间进行路由和同步。它还提供了一个用于连接并与代理交互的客户端实现。 该系统管理基于主题的消息路由和发布/订阅交换，并由代理访问控制和身份验证提供支持。它包括用于在重启后恢复状态的数据持久化功能，以及用于代理管理和监控的 Web 界面。

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 是一个自托管的推送通知服务，旨在向移动设备和物联网硬件发送即时警报。它作为一个中心化的后端，用于通过私有服务器管理和路由自定义通知。 该系统以其“无 App 推送”能力而著称，利用原生操作系统功能接收警报，无需在手机上安装专门的客户端应用程序。对于物联网集成，它作为使用 MQTT 协议的消息网关，向智能硬件发送实时文本和图像通知。 该平台包含一套全面的 API 密钥和设备注册令牌管理套件，以确保通知流水线的安全。它支持通过自定义 JSON 格式从第三方平台转发外部通知，并提供基于主题的路由，将特定内容类型定向到目标设备。硬件特定能力包括设备屏幕上的图像渲染、网络时间同步以及触发蜂鸣器等物理警报的能力。 后端以容器化环境提供，专为使用 Docker 和 Compose 进行部署而设计。

MQTTnet 是一个 .NET 库，提供了一个用于实现 MQTT 客户端和代理（broker）的框架。它包括一个用于托管中央消息枢纽的代理实现，用于在连接的客户端之间路由消息，以及一个用于发布和订阅消息的客户端库。 该项目支持 TCP 和 WebSocket 传输层，通过传输层安全（TLS）实现安全的数据传输。它允许开发自定义中间件，以在消息通过服务器时进行拦截、转换或验证。 能力领域包括分布式消息路由、具有服务质量（QoS）队列的持久连接管理，以及用于客户端凭据验证和主题订阅限制的安全原语。

Console 是一个基于 Web 的管理工具，用于监控和管理 Kafka 集群。它提供了一个图形界面，用于管理主题、消费者组和实时数据流。 该项目包含用于 Kafka Connect 和 Schema Registry 的专用管理器，允许部署数据连接器和管理数据模式。它具有一个集群仪表板，用于跟踪代理健康状况、存储使用情况和机架状态，以及一个用于基于角色的访问控制和审计日志检查的界面。 该平台涵盖数据浏览和过滤、消费者组协调以及数据流水线的构建。它还支持监控数据转换任务，并通过集中式策略引擎管理用户权限。

embedded-notes 是一系列专注于嵌入式 Linux、Linux 内核内部机制和 C 语言编程的技术学习指南和开发笔记。它既是嵌入式系统开发的参考资料，也是该领域技术面试的备考资源。 该项目提供了关于编写设备驱动程序、管理虚拟内存以及理解内核内部机制的详细文档。它还包括关于 MQTT 和 TCP/IP 等物联网网络协议的指南，并概述了芯片架构和硬件外设的架构细节。 这些资料涵盖了广泛的系统编程领域，包括手动内存管理、进程生命周期管理以及实时操作系统概念的实现。它还包括低级工具的参考资料，例如 ARM 交叉编译、二进制分析以及用于构建自动化的 Shell 脚本。

MQTT-Explorer 是一个用于 MQTT 代理的视觉化工具和调试器。它提供了一个基于 Web 的界面，用于通过分层浏览器检查实时消息流量并分析主题结构。 该工具将传入的消息组织成嵌套树结构，以简化对数据流和代理活动的观察。它包括一个移动友好的仪表板，具有针对触摸设备上的代理状态监控进行优化的布局和交互模式。 该应用程序支持物联网设备的调试和 MQTT 网络的管理。它提供流量可视化、代理监控和有效载荷检查功能。 该软件可用作浏览器可访问的 Web 服务或桌面应用程序。

该项目是一个跨平台 C 库，专为在应用中实现 MQTT 消息传递而设计。它作为一个异步网络工具包，使资源受限的系统和分布式组件能够与消息代理交换遥测数据和控制信号。 该库通过一个基于状态机的协议处理程序脱颖而出，该处理程序管理连接生命周期和持久会话状态，确保即使在间歇性网络连接期间也能实现可靠的消息传递。它利用后台线程管理网络操作，允许应用通过回调驱动的通知系统保持响应。此外，该库具有一个可插拔的传输抽象，通过统一的基于 URI 的连接接口支持多种通信通道，包括 TCP、TLS 和 WebSockets。 该软件提供了一套全面的消息传递功能，包括可配置的服务质量级别、基于主题的发布和订阅，以及将元数据附加到消息的能力。它还结合了诊断追踪和运行时执行日志记录，以协助监控网络活动和调试协议转换。

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

这是一个 Java 消息开发工具包，旨在促进应用与消息代理之间的实时数据交换。它作为一个 MQTT 客户端库，提供了在分布式系统和物联网环境中实现发布/订阅消息模式所需的工具。 该库通过专注于弹性网络连接和可靠的消息传递脱颖而出。它通过内部状态机管理持久连接，处理自动重连和心跳保活，确保在网络不稳定的环境中保持稳定性。应用可以配置特定的服务质量（QoS）级别以保证数据完整性，范围从“至多一次”到“恰好一次”传递，并利用“遗嘱”（Last Will and Testament）配置来管理意外的客户端断开连接。 该框架利用非阻塞异步通信原语支持高吞吐量数据处理。它使开发者能够通过基于主题的订阅（包括通配符模式）路由消息，并通过基于令牌的句柄跟踪单个操作的进度。该库作为标准的 Java 开发工具包分发，可集成到更广泛的消息传递和物联网基础设施中。