Terry-Mao/goim
Goim
goim
Features
- 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.
- Asynchronous Queue Deliveries - Queues outgoing messages through Kafka so the sender does not block on delivery.
- Connection Keepalives - Maintains persistent connections through application-level heartbeats and TCP keepalives.
- Websocket Connection Managers - Handles WebSocket lifecycle including upgrade, read, and write operations for real-time communication.
- Scalable - Manages persistent WebSocket and TCP connections at scale with heartbeat monitoring and horizontal scaling.
- Redis-Based Node Registries - Tracks alive cluster nodes in Redis, removes dead nodes automatically, and routes messages by region or weight.
- Multi-User Message Deliveries - Pushes messages to single users, multiple users, or all connected clients in a single operation across the cluster.
- Protocol-Agnostic Transport Layers - Provides a unified internal interface accepting connections over both WebSocket and raw TCP.
- Room-Based Pub-Sub Broadcasting - Broadcasts a single message to all members of a chat room simultaneously.
- 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.
- Horizontal Scaling Deployments - Adds or removes server modules without downtime to handle more connections.
- Dynamic Module Scaling - Scales message processing horizontally by adding or removing dynamic job and logic modules.
- Regional Routing - Directs messages to nodes in a specific geographic region to reduce latency and comply with data locality rules.
- Message Aggregations - Aggregates multiple messages for the same room into a single batched delivery to reduce overhead.
- Device-Specific Deliveries - Delivers push notifications to specific devices identified by unique device identifiers.
- Cluster-Wide Broadcasting - Delivers a message to every connected user across the entire server cluster in a single operation.
- Weighted Hash Rings - Distributes connections across nodes using a weighted consistent hash ring for balanced load.
- Fan-Out Patterns - Delivers a single message to multiple subscribers up to a configurable maximum count.
- Room Message Aggregations - Aggregates multiple messages for the same room into a single delivery to reduce network overhead.
- Weighted Load Balancing - Distributes connections across nodes proportionally to their configured weight to balance load.
- Subscriber Authentications - Rejects subscription requests from unauthenticated users, allowing only verified clients to receive messages.
- Communication and Messaging - Distributed IM and push service.
- Communication and Real-time - A high-concurrency IM and real-time push service.
