primus/primus

Features

• Transport Abstractions - Provides a unified interface that abstracts underlying socket implementations to allow swapping transport engines.
• Unified Transport Abstractions - Provides a single API that abstracts multiple transport protocols so the same code works across environments.
• Room Management - Organizes connections into named rooms to facilitate targeted broadcasting of messages to specific subsets of users.
• Automatic Reconnection Logic - Implements automatic reconnection logic using randomized exponential back-off to restore dropped connections without stressing the server.
• Middleware-Based Request Pipelines - Implements a modular chain of pluggable components to intercept and modify network requests and responses.
• Connection Multiplexing - Bundles multiple logical data streams into a single physical connection for organized data flow.
• Connection Lifecycle Managers - Manages the full lifecycle of persistent connections, including heartbeats and automated reconnection logic.
• Room-Based Client Grouping - Organizes connected clients into named rooms for efficient targeted broadcasting and event delivery.
• Multi-Transport Real-time Layers - Standardizes the real-time messaging interface to allow swapping between different transport engines without rewriting application logic.
• Transport Abstraction Layers - Standardizes messaging interfaces to allow swapping transport layers without changing application logic.
• Real-Time Message Routing - Organizes real-time data flows using communication rooms and virtual stream multiplexing for targeted broadcasting.
• Virtual Channel Multiplexing - Supports streaming multiple distinct data flows over a single physical network connection using logical channels.
• WebSocket Transports - Provides a standardized wrapper for managing WebSocket lifecycles, connection recovery, and transport abstraction.
• Named Event Exchanges - Enables the exchange of named events with serializable data over persistent real-time connections.
• Real-Time Middleware Pipelines - Provides a framework for intercepting and transforming incoming and outgoing data packets to apply security and serialization rules.
• Client Library Generators - Automates the creation of compatible client-side libraries based on the server's current configuration.
• Client Library Generators - Automatically creating compatible client-side libraries based on server configurations to ensure consistent communication protocols.
• Request Interception Middleware - Provides pipeline handlers for intercepting and modifying network traffic before it reaches the transformer.
• Real-Time Frameworks - Provides a framework for real-time communication with built-in support for intercepting and transforming bidirectional data streams.
• WebSocket Connection Validations - Validates WebSocket connection requests using authentication headers to authorize sessions before they are established.
• Data Type Serialization Configurations - Allows configuring how data is serialized to support various formats like JSON or binary.
• Latency Monitors - Implements heartbeat-based monitoring to track network latency and detect dead connections.
• Broadcast Messaging - Sends messages to all connected clients or targeted subsets within a room.
• Connection Loss Detection - Identifies when a client loses connectivity to trigger automatic reconnection attempts once the network returns.
• Health Monitoring - Implements heartbeat mechanisms using ping-pong signaling to calculate network latency and detect dead connections.
• Automatic Connection Recovery - Provides mechanisms for automatically re-establishing lost network connections to maintain service stability.
• Message Content Transformation - Modifies the content and metadata of messages before they trigger application events.
• Message Encoders and Decoders - Implements customizable parsers to encode and decode messages between raw bytes and structured domain objects.
• Pluggable Serialization - Provides an extensible system for using custom encoders and decoders to support multiple data formats.
• Transport Engine Swappers - Allows changing real-time transformers to adapt to specific browser requirements or network constraints.
• Exponential Backoff Retries - Restores dropped connections using a timing strategy that increases retry intervals to prevent server congestion.
• Connection Authentication Mechanisms - Provides server-side validation of incoming client identities using customizable authentication hooks.
• Plugin Extenders - Supports loading custom external libraries at runtime to augment core application functionality via plugins.
• Heartbeat - Calculates network latency and detects dead connections by exchanging periodic heartbeat ping and pong messages.
• Request Interception Middlewares - Provides middleware pipelines to intercept and modify incoming requests before they reach the primary transformation logic.
• Real Time Communication - Abstraction layer for real-time frameworks.

Star history