ServiceStack.Redis訂閱發布服務的調用

1.Redis訂閱發布介紹
Redis訂閱發布是一種消息通信模式：發布者（publisher)發送消息，訂閱者（Subscriber）接受消息。類似於設計模式中的觀察者模式。
發布者和訂閱者之間使用頻道進行通信，當需要發送消息時，發布者通過publish命令將消息發送到頻道上，該消息就會發送給訂閱這個頻道的訂閱者。

圖片來自於http://www.runoob.com/redis/redis-pub-sub.html

2.ServiceStack.Redis
　　ServiceStack.Redis是Redis的C#版本的客戶端，是ServiceStack的一部分。
　　　　ServiceStack的地址為https://servicestack.net

 

3.訂閱者
首先創建RedisClient，然后調用CreateSubscription()方法創建訂閱客戶端，然后設置訂閱客戶端的幾個事件：
OnMessage:接受到消息時。
OnSubscribe：訂閱頻道時。
OnUnSubscribe：取消訂閱頻道時。
最后，調用subscribeToChannels(channelName)，訂閱頻道。
詳細代碼如下：

/// <summary>
    /// Redis訂閱
    /// </summary>
    public static void Subscribe()
    {
        using (RedisClient consumer = new RedisClient("127.0.0.1", 6379))
        {
            //創建訂閱
            IRedisSubscription subscription = consumer.CreateSubscription();
            //接受到消息時
            subscription.OnMessage = (channel, msg) =>
            {
                Console.WriteLine($"從頻道：{channel}上接受到消息：{msg},時間：{DateTime.Now.ToString("yyyyMMdd HH:mm:ss")}");
                Console.WriteLine($"頻道訂閱數目：{subscription.SubscriptionCount}");
                Console.WriteLine("___________________________________________________________________");
            };
            //訂閱頻道時
            subscription.OnSubscribe = (channel) =>
            {
                Console.WriteLine("訂閱客戶端：開始訂閱" + channel);
            };
            //取消訂閱頻道時
            subscription.OnUnSubscribe = (a) => { Console.WriteLine("訂閱客戶端：取消訂閱"); };

            //訂閱頻道
            subscription.SubscribeToChannels("channel1");
        }
    }

4.發布者
首先創建RedisClient，然后調用PublishMessage(channelName,message)發布消息。
詳細代碼如下：
RedisClient client = new RedisClient("127.0.0.1", 6379);
string message = "發布消息測試";
client.PublishMessage("channel1", message);

到目前為止，一個簡單的Redis發布訂閱就完成了。

5.Redis發布服務
使用發布者僅僅能夠發布消息，但是不能夠檢測一些事件的變化，Redis中還有一個RedisPublishServer的類，里面包括一些事件能夠使我們很好地檢測服務的運行。
OnMessage：接受到消息；
OnStart:發布服務開始運行時；
OnStop：發布服務停止運行時；
OnUnSubscribe：訂閱者取消訂閱時；
OnError:發布出現錯誤時；
OnFailover:Redis服務器冗余切換時；
發布服務端初始化完成后，調用Start()方法，開始執行發布服務。

發布服務執行后，執行消息的發布client.PublishMessage時，發布服務端也能夠接受到發布的消息。
詳細代碼如下：

public void Publish()
    {
        //PooledRedisClientManager
        IRedisClientsManager redisClientManager = new PooledRedisClientManager("127.0.0.1:6379");
        //發布、訂閱服務 IRedisPubSubServer
        RedisPubSubServer pubSubServer = new RedisPubSubServer(redisClientManager, "channel1")
        {
            OnMessage = (channel, msg) =>
            {
                Console.WriteLine($"從頻道：{channel}上接受到消息：{msg},時間：{DateTime.Now.ToString("yyyyMMdd HH:mm:ss")}");
                Console.WriteLine("___________________________________________________________________");
            },
            OnStart = () =>
            {
                Console.WriteLine("發布服務已啟動");
                Console.WriteLine("___________________________________________________________________");
            },
            OnStop = () => { Console.WriteLine("發布服務停止"); },
            OnUnSubscribe = channel => { Console.WriteLine(channel); },
            OnError = e => { Console.WriteLine(e.Message); },
            OnFailover = s => { Console.WriteLine(s); },
        };
        //接收消息
        pubSubServer.Start();
    }