EMQX

EMQX
Name	EMQX
Developer	EMQ Technologies
Initial release	2017
Programming language	Erlang
Operating system	Linux, Windows, macOS
License	Apache License 2.0 (Community), Commercial (Enterprise)

EMQX is a high-performance, distributed message broker implementing the MQTT protocol designed for large-scale Internet of Things deployments. It provides pub/sub messaging, clustering, persistence, and protocol bridging to support integration with diverse platforms, products, and services. EMQX targets telecommunication, automotive, industrial automation, and cloud-native environments with features for reliability, observability, and extensibility.

Overview

EMQX was developed by EMQ Technologies and competes with brokers and platforms such as Eclipse Mosquitto, HiveMQ, RabbitMQ, Apache Kafka, and VerneMQ in IoT messaging and real-time streaming domains. It supports standards and protocols including MQTT, MQTT-SN, CoAP, and WebSocket, enabling interoperability with devices and gateways from vendors like Cisco Systems, Siemens, Bosch, Honeywell International', and Schneider Electric. Deployments often integrate with cloud providers and services from Amazon Web Services, Microsoft Azure, Google Cloud Platform, Alibaba Cloud, and IBM Cloud as well as monitoring and analytics stacks like Prometheus, Grafana, Elastic Stack, and Datadog.

Architecture

EMQX is implemented primarily in Erlang and builds on actor-model and distributed-system principles inspired by projects such as RabbitMQ and Riak. The broker uses a clustered architecture that employs consensus and partitioning patterns similar to Apache ZooKeeper and etcd for metadata and coordination in some deployments. Persistence backends and storage engines can integrate with RocksDB, LevelDB, MySQL, PostgreSQL, and Redis for session and message state. For service mesh and routing, EMQX often interoperates with Istio, Linkerd, Kubernetes, and Docker Swarm in containerized environments. Observability components connect to Jaeger, OpenTelemetry, and Fluentd for tracing and logging.

Features

Key capabilities include support for MQTT v3.1, v3.1.1, v5.0 and advanced features such as retained messages, last will and testament, persistent sessions, shared subscriptions, and topic aliasing used by vendors like Toyota, Ford Motor Company, General Motors, and Volvo. EMQX provides plugin and rule engines to route messages to systems like Apache Kafka, Apache Pulsar, InfluxDB, ClickHouse, TimescaleDB, and MongoDB. Security features implement TLS/SSL with certificates from authorities such as Let's Encrypt, DigiCert, GlobalSign, and Entrust, and support authorization backends using OAuth 2.0, LDAP, Active Directory, and Keycloak.

Deployment and Scalability

EMQX is designed for horizontal scaling with clustering topologies used by organizations including Huawei, Xiaomi, Tencent, and Samsung in large IoT fleets. It integrates with orchestration platforms such as Kubernetes, OpenShift, Amazon EKS, Google Kubernetes Engine, and Azure Kubernetes Service for automated scaling, rolling updates, and service discovery. High-availability patterns mirror approaches from Netflix and LinkedIn for distributed message processing, while load testing and benchmarking often reference tools like Apache JMeter, Locust, and Gatling. Storage and throughput optimizations draw on research and practices from Google Bigtable, Amazon DynamoDB, and Cassandra deployments.

Security and Authentication

Authentication and authorization mechanisms support JWTs issued by providers such as Auth0, Okta, Firebase Authentication, and proprietary identity providers like Oracle Identity Management. EMQX supports mutual TLS, role-based access control, and integration with secrets management systems like HashiCorp Vault and AWS Secrets Manager. Conformance testing and vulnerability management practices reference standards and bodies such as OWASP, CVE, NIST, and CIS benchmarks to harden deployments and ensure compliance for customers in regulated sectors including Boeing, Airbus, Siemens Healthineers, and Philips.

Use Cases and Integrations

Common applications include telematics and connected vehicles for companies like Volvo Cars, Tesla, BMW, and Daimler AG; industrial IoT use cases in factories operated by Siemens, General Electric, and ABB; smart city projects with municipalities collaborating with Siemens Mobility, Schneider Electric, and Honeywell. EMQX bridges to analytics and stream processing systems such as Apache Spark, Apache Flink, Flink SQL, and FlinkCEP and integrates with message buses and workflows from Apache NiFi, Camunda, Confluent Platform, and Google Pub/Sub.

Development and Community

EMQ Technologies maintains repositories and issue tracking practices similar to large open source projects such as Linux Kernel, Kubernetes, Apache Software Foundation projects, and Eclipse Foundation initiatives. Community contributions, commercial partnerships, and certification programs involve organizations like Linux Foundation, Cloud Native Computing Foundation, Open Source Initiative, and regional developer groups around Silicon Valley, Shenzhen, Bengaluru, and Berlin. Educational and ecosystem resources include collaborations with universities like Massachusetts Institute of Technology, Tsinghua University, Stanford University, and ETH Zurich and participation in industry events such as Mobile World Congress, AWS re:Invent, KubeCon, and IoT World Congress.

Category:Message brokers