emitter-io/emitter
Emitter
Emitter is a distributed pub-sub platform and message brokering system that decouples senders and receivers through topic-based routing. It functions as an MQTT message broker and WebSocket communication server, enabling real-time data exchange between hardware devices and web-based clients.
The system acts as a secure channel orchestrator and message persistence engine. It ensures delivery through a storage system that buffers historical messages and queues data for offline subscribers. Access to these data streams is managed via time-limited permission keys that enforce granular read and write controls.
The platform supports high-availability deployments through synchronized broker clusters and provides hierarchical channel organization with wildcard filtering for precise data capture. It handles binary payloads across multi-party communication patterns and includes network traffic encryption and system performance monitoring.
Features
- MQTT Message Brokers - Functions as a distributed MQTT message broker for exchanging binary data and managing IoT sensor telemetry.
- Topic-Based Pub/Sub - Implements a core messaging pattern where producers and consumers are decoupled through topic-based distribution.
- Real-Time WebSocket Servers - Provides a server that pushes live updates to browser clients using persistent bidirectional WebSocket connections.
- High Availability Cluster Deployments - Supports deploying synchronized node networks to increase throughput and ensure continuous service availability.
- Message Broker Clustering - Implements a distributed architecture to scale messaging workloads and ensure high availability across server nodes.
- Offline Client Queuing - Buffers messages for disconnected subscribers and automatically delivers them upon session restoration.
- WebSocket Servers - Enables bidirectional real-time data streams for web-based clients using the WebSocket protocol.
- Hierarchical Channel Organization - Supports structuring data into multi-level paths using slashes to enable granular message targeting and logical organization.
- Message Brokers - Routes real-time data between publishers and subscribers across a cluster to decouple system components.
- Message Persistence Systems - Provides a storage system that buffers historical messages and queues data for offline subscribers.
- Pub-Sub Subscriptions - Provides mechanisms for clients to subscribe to real-time message channels and retrieve historical data upon connection.
- Wildcard Hierarchy Filtering - Enables precise data capture by allowing subscribers to use wildcards to target specific levels of a channel hierarchy.
- Protocol-Based Routing - Routes binary payloads between publishers and subscribers using MQTT over TCP or WebSockets.
- Hierarchical Routing - Organizes data streams into multi-level paths to enable granular subscription and wildcard filtering.
- High Availability Implementations - Deploys synchronized broker nodes in a distributed cluster to ensure system resilience and continuous delivery.
- Real-Time Message Streaming - Delivers high-throughput, low-latency data streams across distributed clusters to support millions of messages per second.
- Key-Level Access Controls - Enforces granular read and write permissions for data streams using time-limited security keys.
- Secure Channel Orchestration - Manages encrypted data streams using time-limited permission keys to enforce granular access control.
- Message History Playback - Persists historical messages in a database to allow subscribers to retrieve missed data after disconnection.
- Binary Channel Publishing - Supports publishing binary data payloads to channels with configurable retention for persistence.
- Many-to-Many Multicast - Facilitates many-to-many communication patterns where multiple publishers and subscribers exchange data across numerous channels.
- Protocol-Agnostic Message Routing - Translates and routes binary payloads between different standards like MQTT and WebSockets.
- Traffic Filters - Routes binary messages to specific devices or sensors using protocol-based filtering criteria.
- Network Traffic Encryptions - Secures data transmission between clients and servers using industry-standard encryption protocols.
- Environment-Driven Feature Configurations - Provides a system for managing operational parameters through external configuration files and environment variables.
- Externalized Configurations - Allows overriding system settings via external files, environment variables, or secure vault services.
- Databases - Distributed pub/sub database for real-time IoT and messaging.
- Distributed Systems - Distributed, low-latency publish-subscribe platform.
- Distributed Systems - High-performance distributed pub-sub platform.
Star history
How this analysis was created: This summary and feature list were written by an AI model that read the project's README and public documentation pages. Each feature links to the documentation it came from; stars, license and language come straight from the GitHub API. The model does not read the source code, and the analysis is refreshed when the project is re-analysed. Learn more on our About page.
