Redis
 sql >> Baza danych >  >> NoSQL >> Redis

Redis Pub/Sub ServiceStack, anulowanie wątku

Przykład, który pokazuje, jak subskrybować i wypisywać się z wiadomości, znajduje się w RedisMqServer, np.:

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
}

Gdzie używa niestandardowego komunikatu kontrolnego, aby odblokować wątek w tle i anulować subskrypcję wszystkich kanałów z subskrypcji OnMessage przewodnik.




  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Uzyskaj wszystkie klucze w bazie danych Redis za pomocą Pythona

  2. Algorytm dopasowywania użytkowników

  3. Redis typowany klient

  4. przechowywanie danych w redis przez zadanie cron

  5. Jak ponownie podłączyć klienta redis po restarcie/skalowaniu serwera redis?