sql >> Database >  >> NoSQL >> Redis

Redis Pub/Sub ServiceStack, de discussie annuleren

Een voorbeeld dat laat zien hoe u zich kunt abonneren en afmelden voor berichten is in RedisMqServer, bijvoorbeeld:

using (var subscription = redisClient.CreateSubscription())
{
    subscription.OnUnSubscribe = channel => 
        Log.Debug("OnUnSubscribe: " + channel);

    subscription.OnMessage = (channel, msg) =>
    {
        if (msg == "STOP")
        {
            Log.Debug("Stop Command Issued");
            Log.Debug("Unsubscribing from all Channels...");
            subscription.UnSubscribeFromAllChannels(); //Unblocks thread.
        }
    };

    subscription.SubscribeToChannels(QueueNames.TopicIn); //blocks thread
}

Waar het een aangepast controlebericht gebruikt om de achtergrondthread te deblokkeren en zich af te melden voor alle kanalen van het abonnement OnMessage afhandelaar.




  1. Django REST-framework reageert nog steeds met gegevens in de cache, zelfs na lege redis-sleutels

  2. Sla een afbeelding op in MongoDB met Node.js/Express en Mongoose

  3. MongoDB $in Query-operator

  4. is er een manier om de cliënt IP in redis te krijgen?