Pipeline de consommation séquentielle de messages distribués Message Pipe v1.0.6

Message Pipe est un pipeline de messages séquentiels implémenté sur la base de Redis. Étant donné que le verrou distribué Redisson est introduit en interne, il est thread-safe dans les situations multithread, la consommation sera également effectuée dans l'ordre écrit dans le pipeline.

Message Pipe est conçu en utilisant les concepts de client et de serveur. En interne, grpc-netty est utilisé pour établir de longues connexions permettant aux canaux de messages de communiquer entre eux. Le serveur est responsable de la distribution des messages et les messages de chaque pipeline sont distribués. via LoadBalance (équilibrage de charge). Méthode pour obtenir des informations sur le client en ligne et envoyer des messages au client de manière séquentielle.

caractéristiques

Inscription automatique

vérification du rythme cardiaque

diffusion des messages

Consommation séquentielle

Séparation en lecture et en écriture

Sécurité du fil

équilibrage de charge

Abattage automatique