Maintenir un abonnement Redis PubSub ouvert avec Booksleeve

Question

J'utilise un canal Redis pubsub pour envoyer des messages d'un pool de processus de travail à mon application ASP.NET. Lorsqu'un message est reçu, mon application transmet le message au navigateur d'un client avec SignalR.

J'ai trouvé this solution pour maintenir une connexion ouverte à Redis, mais elle ne tient pas compte des abonnements lorsqu'elle recrée la connexion.

Je me occupe actuellement Redis messages PubSub dans mon fichier Global.asax:

public class Application : HttpApplication 
{ 
    protected void Application_Start() 
    { 
     var gateway = Resolve<RedisConnectionGateway>(); 
     var connection = gateway.GetConnection(); 
     var channel = connection.GetOpenSubscriberChannel(); 

     channel.PatternSubscribe("workers:job-done:*", OnExecutionCompleted); 
    } 

    /// <summary> 
    /// Handle messages received from workers through Redis.</summary> 
    private static void OnExecutionCompleted(string key, byte[] message) 
    { 
     /* forwarded the response to the client that requested it */ 
    } 
} 

Le problème se produit lorsque le RedisConnection courant est fermé pour une raison quelconque. La solution la plus simple est de déclencher un événement de la classe RedisConnectionGateway lorsque la connexion a été réinitialisée et de vous réabonner en utilisant un nouveau RedisSubscriberChannel. Cependant, tous les messages publiés sur le canal pendant la réinitialisation de la connexion seront perdus.

Existe-t-il des exemples de méthodes recommandées pour gérer cette situation?

Answer 1

Oui, si la connexion est interrompue (instabilité du réseau, re-mastering, etc.), vous devrez ré-appliquer les abonnements que vous avez effectués. Un événement pour se reconnecter et se réabonner est assez normal, et pas très différent de ce que nous utilisons ici sur SE/SO (sauf que nous suivons généralement des abonnements plus granulaires, et avons du code wrapper qui gère tout cela).

Oui, tous les événements publiés lorsque votre connexion a été rompue ont disparu. C'est la nature de redis pub/sub; il ne garantit pas la livraison aux clients déconnectés. Utilisez pour le faire, ou utilisez redis pour piloter une file d'attente. t le laisser tomber après l'avoir sorti de la liste). Si cela aide, j'ai sur ma liste une demande pour ajouter les méthodes pop bloquantes - elles détruisent totalement l'intention du multiplexeur, mais elles ont une utilisation réelle dans certains cas, donc je ne suis pas contre leur ajout.