Awesome GitHub RepositoriesMessaging Server Clustering

Cim is a distributed instant messaging system and server-side backend designed to manage real-time communication across a cluster of servers. It provides a scalable infrastructure for routing private and group messages while tracking user connection states and session locations across distributed nodes. The project features an interception layer for AI messaging middleware, which allows artificial intelligence agents to intercept incoming communication and generate automated responses. It also includes a real-time push infrastructure to deliver notifications and messages from the server to en

This is a Golang client library for interacting with a cloud native distributed messaging system. It provides the necessary tools for Go applications to exchange messages using publish-subscribe and request-reply patterns, as well as specialized clients for managing persistent streams and distributed storage. The library includes a JetStream client for durable message streaming and replay, a Key-Value store client for managing distributed state with versioning and watchers, and an Object Store client for the storage and retrieval of large binary files via chunked delivery. The implementation

Faye est un middleware de messagerie en temps réel et un serveur de publication-abonnement WebSocket. Il fonctionne comme une couche de communication qui achemine les messages entre les clients et gère les abonnements aux canaux pour permettre la synchronisation des données sur le web. Le projet fournit une passerelle de communication inter-domaines, permettant aux clients web sur différents domaines de communiquer avec un serveur central. Il est conçu comme un backend de messagerie en cluster capable de partager l'état entre plusieurs instances en utilisant un stockage externe pour gérer de gros volumes de connexions réseau persistantes. Sa surface de fonctionnalités inclut une logique pub-sub pour la gestion des canaux et le routage des messages, ainsi qu'une couche de protocole agnostique au transport qui prend en charge à la fois les WebSockets et le long-polling. Le système intègre un middleware de sécurité pour les restrictions d'accès à la publication et aux abonnements, ainsi qu'une interception du trafic de messages pour modifier ou filtrer les données. Pour maintenir la stabilité, le système utilise une récupération de connexion basée sur des battements de cœur (heartbeats) pour détecter les liens rompus et renvoyer automatiquement les messages manqués.

Openfire is an XMPP communication server and enterprise messaging platform designed for real-time collaboration. It serves as a communication hub providing instant messaging, presence tracking, and multi-user chat capabilities for organizational use. The server supports federated network routing via an XMPP federation gateway, allowing users across different domains to exchange messages. It is designed for high availability through server node clustering and multi-node synchronization to balance client traffic and ensure continuous uptime. The platform integrates with external directory serv

This project is a reference library of architectural blueprints, study materials, and design patterns for building scalable, high-availability distributed systems. It serves as a technical guide for scalability engineering, providing structural solutions for common engineering challenges. The repository focuses on distributed systems design, covering essential patterns for data replication, consensus algorithms, and transaction management. It distinguishes itself by offering detailed blueprints for specialized domains, including real-time data streaming, large-scale data storage, and high-ava