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.