Terry-Mao/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.

Star history