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

Zarządzany przez Redis serwer Pub/Sub

Silnik Pub/Sub obsługujący Redis ServerEvents i Redis MQ został wyodrębniony i umieszczony w klasie wielokrotnego użytku, która może być używana niezależnie do obsługi wiadomości publikowanych w określonych kanałach Redis Pub/Sub.

RedisPubSubServer przetwarza wiadomości w zarządzanym wątku w tle, który automatycznie łączy się ponownie gdy połączenie redis-serwer zawodzi i działa jak niezależna usługa działająca w tle, którą można zatrzymać i uruchomić na polecenie.

Publiczny interfejs API jest przechwytywany w interfejsie IRedisPubSubServer:

public interface IRedisPubSubServer : IDisposable
{
    IRedisClientsManager ClientsManager { get; }
    // What Channels it's subscribed to
    string[] Channels { get; }

    // Run once on initial StartUp
    Action OnInit { get; set; }
    // Called each time a new Connection is Started
    Action OnStart { get; set; }
    // Invoked when Connection is broken or Stopped
    Action OnStop { get; set; }
    // Invoked after Dispose()
    Action OnDispose { get; set; }

    // Fired when each message is received
    Action<string, string> OnMessage { get; set; }
    // Fired after successfully subscribing to the specified channels
    Action<string> OnUnSubscribe { get; set; }
    // Called when an exception occurs 
    Action<Exception> OnError { get; set; }
    // Called before attempting to Failover to a new redis master
    Action<IRedisPubSubServer> OnFailover { get; set; }

    int? KeepAliveRetryAfterMs { get; set; }
    // The Current Time for RedisServer
    DateTime CurrentServerTime { get; }

    // Current Status: Starting, Started, Stopping, Stopped, Disposed
    string GetStatus();
    // Different life-cycle stats
    string GetStatsDescription();
    
    // Subscribe to specified Channels and listening for new messages
    IRedisPubSubServer Start();
    // Close active Connection and stop running background thread
    void Stop();
    // Stop than Start
    void Restart();
}

Użycie #

Aby użyć RedisPubSubServer , zainicjuj go z kanałami, które chcesz subskrybować i przypisz obsługę dla każdego zdarzenia, które chcesz obsłużyć. Przynajmniej będziesz chciał obsłużyć OnMessage :

var clientsManager = new PooledRedisClientManager();
var redisPubSub = new RedisPubSubServer(clientsManager, "channel-1", "channel-2") {
        OnMessage = (channel, msg) => "Received '{0}' from '{1}'".Print(msg, channel)
    }.Start();

Wywołanie Start() po zainicjowaniu uruchomi nasłuchiwanie i przetwarzanie wszelkich wiadomości publikowanych na subskrybowanych kanałach.


  1. Redis
  2.   
  3. MongoDB
  4.   
  5. Memcached
  6.   
  7. HBase
  8.   
  9. CouchDB
  1. czy istnieje sposób na uzyskanie adresu IP klienta w redis?

  2. Projektowanie aplikacji z Redis jako magazynem danych. Co? Czemu?

  3. Redis — Jak klucze HASH, SET i ZSET są powiązane w zapisaniu CrudRepository?

  4. redis — Używanie haszów

  5. Serializacja i deserializacja Redis