centrifugal/centrifugo
Centrifugo
Centrifugo is a self-hosted real-time messaging server that provides infrastructure for scalable notifications, a publish-subscribe message broker, and a language-agnostic WebSocket gateway. It allows for the delivery of instant messages and data streams to concurrent users via WebSockets and Server-Sent Events.
The system functions as a communication layer that separates network transport from backend business logic. It supports distributed messaging clusters using Redis for coordination of presence and message delivery across multiple server nodes.
The project covers channel subscription management, user presence tracking, and message recovery mechanisms to handle data loss during network disconnects. Security and operational capabilities include token-based connection authentication, proxy-based subscription validation, automated TLS certification, and connection rate limiting.
Administration is supported through a server management command-line interface, and the project is distributed as Docker container images for consistent deployment.
Features
- Real-Time Messaging Systems - Provides a scalable infrastructure for low-latency message delivery and state synchronization across various web protocols.
- Self-Hosted Communication Servers - Provides a self-hosted communication server for managing persistent connections and broadcasting on private infrastructure.
- Redis Connectors - Integrates Redis as a backend store for distributed message brokering and presence tracking.
- Distributed Messaging - Utilizes a distributed messaging architecture with Redis to coordinate presence and delivery across server nodes.
- Self-Hosted Infrastructure - Provides an independent, self-hosted infrastructure for real-time data streams and messaging.
- Real-time Notification Broadcasters - Sends time-sensitive updates and notifications to a large number of concurrent users via WebSocket connections.
- Message Brokers - Functions as a message broker to facilitate asynchronous communication and data distribution across server nodes.
- Pub-Sub Subscriptions - Implements a publish-subscribe system allowing clients to follow specific channels for real-time updates.
- Messaging Servers - Functions as a real-time messaging server delivering instant notifications via WebSockets and Server-Sent Events.
- Protocol-Agnostic Transport Layers - Decouples business logic from the network layer to support multiple transport protocols like WebSockets and SSE.
- Pub-Sub Systems - Implements a pub-sub system for managing channel subscriptions and real-time data delivery.
- Web Transport Streaming - Transmits real-time information to clients via standard web protocols including WebSockets and Server-Sent Events.
- Connection Authentication Mechanisms - Implements server-side validation of client identities using tokens and cryptographic keys.
- Token-Based Authentication - Uses cryptographically signed tokens to verify client identity and secure system access.
- PubSub Implementations - Implements a language-agnostic publish-subscribe model for efficient data distribution to multiple clients.
- Connection Rate Limiting - Caps the number of new connections per second to protect the server from resource exhaustion.
- Transport-Agnostic Delivery - Decouples business logic from network protocols to enable message delivery across diverse transport layers.
- Message Recovery Mechanisms - Tracks subscription states and message offsets to ensure data recovery after temporary network drops.
- Stateful Recovery Mechanisms - Tracks subscription states to automatically recover missed messages after network disconnects.
- External Authorization Proxies - Validates channel subscriptions by forwarding authorization requests to an external proxy service.
- Subscription Authorization - Controls channel access via proxy requests and verifies the expiration status of user subscriptions.
- User Presence Monitoring - Monitors and tracks the real-time online or offline status of users within communication channels.
- Messaging Systems - Real-time messaging server supporting WebSockets and SockJS.
- Communication and Messaging - Real-time messaging server.
- Communication and Real-time - A real-time messaging server for backend applications.
- Communication Systems - Real-time messaging server using WebSockets.
- Messaging - Listed in the “Messaging” section of the Awesome Go awesome list.
- Messaging Systems - Real-time messaging server.
Star history
How this analysis was created: This summary and feature list are AI-generated from collected project material and can contain mistakes. Stars, license and language are imported from GitHub. Inclusion does not mean that we have tested or audited this project. Check the source documentation for any feature you depend on. Learn more on our About page.
