emqx/emqx

Features

• Message Brokers - Handles millions of concurrent device connections and real-time data streaming across distributed systems.
• Message Broker Infrastructure - Manages high-concurrency messaging and real-time data routing for millions of connected devices using standard protocols.
• Connection Managers - Maintains high-concurrency messaging across distributed clusters to support millions of simultaneous device connections.
• Pub-Sub Messaging - Decouples message producers and consumers through a hierarchical topic tree that supports pattern matching and efficient distribution.
• Stream Processing - Enables real-time data transformation, filtering, and routing by executing declarative SQL queries against incoming message streams.
• IoT Platforms - Provides scalable infrastructure for ingesting, processing, and routing telemetry data from connected devices.
• Authentication and Authorization - Provides robust authentication and authorization mechanisms to secure device connections and manage granular access permissions across the platform.
• Actor-Based Concurrency - Uses a lightweight actor-based process model to manage millions of concurrent connections and isolate state.
• Edge Inference Engines - Triggers local machine learning models based on real-time data streams to enable low-latency decision-making at the edge.
• Data Processing - Filters, aggregates, and transforms data streams locally to reduce bandwidth consumption and enable low-latency responses.
• Data Stream Processors - Filters, aggregates, and transforms data streams using SQL-based rules before forwarding them to external systems.
• High Availability Clusters - Synchronizes session data and subscription states across multiple nodes to ensure high availability and seamless failover.
• Industrial IoT Platforms - Collects and normalizes data from legacy machinery and industrial equipment to bridge operational technology with modern data platforms.
• Connectivity Hubs - Bridges legacy industrial protocols and modern IoT standards to enable interoperability in operational technology environments.
• Industrial Data Standardization - Implements unified namespaces and interoperability specifications to create a single source of truth for industrial environments.
• Protocol Translators - Translates diverse messaging and industrial protocols into a unified format for seamless communication.
• Multi-Tenancy Security - Enables secure data and resource isolation between independent tenants within a single deployment to ensure independent operation.
• End-to-End Encryption - Enforces end-to-end encryption, granular access control, and multi-tenant isolation to secure sensitive data communications.
• Connection Health Monitors - Protects system resources by identifying and mitigating unstable or malicious client connections through automated detection and blacklisting.
• AI Service Integrations - Streams real-time device data directly into artificial intelligence models and large language services for intelligent processing.
• Messaging Systems - Scalable MQTT message broker for IoT and 5G.
• MQTT Libraries and Brokers - Scalable MQTT broker for high-throughput IoT clusters.
• Internet Of Things - Listed in the “Internet Of Things” section of the Awesome Selfhosted awesome list.
• Edge Computing - Processes and filters data streams locally at the network edge to enable low-latency decision-making.
• Edge Infrastructure Management - Provides a comprehensive interface to automate configuration, monitoring, and scaling of edge nodes.
• Device Management - Manages autonomous navigation, task planning, and remote operations for groups of connected devices.
• Messaging Reliability - Controls message delivery through persistent queues and retained messages to ensure reliable data transmission.
• Message Delivery Guarantees - Ensures zero data loss and guaranteed delivery for messages even when subscribers are temporarily offline.
• Network Encryption - Secures data in transit using encryption and supports private network connectivity to protect sensitive communications.
• Multi-tenant Isolation Policies - Segregates data streams and configuration settings to allow multiple independent users to share the same infrastructure securely.
• Infrastructure Monitoring - Provides unified monitoring, alerting, and operational control across edge, enterprise, and cloud deployment tiers.
• Data Persistence and Storage - Writes incoming device telemetry and state information directly into relational, NoSQL, or time-series databases for long-term storage.
• Time Series Data Storage - Persists device data into an optimized storage layer supporting automated retention policies and efficient querying.
• Device Specifications - Standardizes device properties, commands, and events into a unified specification to enable consistent interaction.
• Agent Communication Protocols - Provides bidirectional messaging and service discovery for distributed agents to ensure interoperability across edge systems.
• Batch Publishing - Minimizes network overhead and increases system throughput by grouping individual messages into single transmissions for high-volume data scenarios.
• Messaging Adapters - Supports diverse messaging standards by translating heterogeneous wire formats into a unified internal representation.
• Topic Routing Patterns - Applies advanced subscription patterns including wildcards and load-balanced consumption to manage complex data flows.
• Streaming Data Integrations - Connects real-time sensor data streams to artificial intelligence models to facilitate intelligent processing.
• Metric and Performance Monitors - Provides built-in dashboards, log access, and metric exports to external observability tools for real-time system health tracking.
• Cloud Storage Offloaders - Offloads device data and logs to cloud-based object storage services for cost-effective long-term retention.
• Cloud Infrastructure Providers - Provides flexible hosting options including serverless, dedicated clusters, and customer-managed cloud environments.
• Connection Handshake Protocols - Utilizes optimized transport protocols with rapid handshake capabilities to maintain reliable connections in unstable network environments.
• Message Stream Replayers - Maintains durable logs of message traffic directly within the broker to allow for historical stream playback.
• Data Schema Validation - Enforces data quality by checking message formats against predefined schemas during the ingestion process.

Star history