Kafka-Driven Message Queue Servers - Provides a Kafka-driven message queue server for asynchronous, non-blocking fan-out delivery to subscribers.
Push Notification Servers - Delivers push notifications to single users, multiple users, rooms, or all clients in a scalable cluster.
Node Registries - Uses Redis as a node registry to track live cluster membership and route messages.
Binary Protocols - Implements a compact binary wire protocol for efficient message encoding and decoding.
Kafka - Queues outgoing messages through Kafka for non-blocking delivery, fan-out, and aggregated room delivery.
Kafka Message Queues - Queues outgoing messages through Kafka for asynchronous, non-blocking fan-out delivery.
Scalable Push Notification Platforms - Broadcasts messages to single users, multiple users, rooms, or all connected clients across a horizontally scalable cluster.
Real-Time Message Push - Delivers push notifications and messages to millions of concurrent users over WebSocket and TCP connections.
Multi-User Message Pushes - Sends the same message to multiple users simultaneously across the server cluster.
Single-User Message Pushes - Delivers a message to one specific user by routing through the cluster to the correct connection.
Heartbeat Frames - Ships application-level heartbeat frames over TCP and WebSocket to maintain persistent connections.
WebSocket and TCP Messaging Gateways - Maintains persistent connections over WebSocket and raw TCP with heartbeat monitoring and automatic dead connection cleanup.
Multi-Protocol Transports - Accepts client connections over both WebSocket and raw TCP through a unified interface.
Connection Heartbeats - Keeps persistent connections alive by exchanging periodic heartbeat signals over TCP, WebSocket, or HTTP.
Connection Health Monitors - Detects and drops dead connections using application-level heartbeats and TCP keepalives.
Node Health Tracking - Tracks node health via Redis heartbeats and removes dead nodes from the routing table automatically.
