Redis
 sql >> Teknologi Basis Data >  >> NoSQL >> Redis

Redis Pub/Sub ServiceStack, membatalkan utas

Contoh yang menunjukkan cara berlangganan dan berhenti berlangganan dari pesan ada di RedisMqServer, mis:

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
}

Di mana ia menggunakan pesan kontrol khusus untuk membuka blokir utas latar belakang dan berhenti berlangganan dari semua saluran dari langganan OnMessage penangan.




  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. Cara memuat hash dengan aman, dan mengonversi nilai menjadi boolean jika ada

  2. Waktu Penyelamatan::Kesalahan dari Redis Gem (Ruby)

  3. Redis di Spark:Tugas tidak dapat diserialisasi

  4. Redis `SCAN`:bagaimana menjaga keseimbangan antara kunci baru yang mungkin cocok dan memastikan hasil akhirnya dalam waktu yang wajar?

  5. Mengakses variabel di luar fungsi redis pipelining di Laravel