摘要

有这样的一个场景，管理员需要发布一条消息，所有的客户端都要受到通知。然后想到了发布订阅模式。使用redis的发布与订阅实现起来更简单一些，说做就做，这里弄个简单的demo，先模拟下。

核心代码

首先使用Nuget安装redis程序集。

服务端发布消息webApi

向频道chanel-1 发送消息。

 public class MessageController : ApiController
   {
       [HttpGet]
       [Route("api/send/{msg}")]        public HttpResponseMessage SendMessage(string msg)
       {
           IRedisClientsManager clientManager = new PooledRedisClientManager("[email protected]:6379");            var client = clientManager.GetClient();
           client.PublishMessage("channel-1", msg);            return new HttpResponseMessage() { Content = new StringContent(JsonConvert.SerializeObject(new { _code = 200, _msg = "Success" })) };
       }

   }

订阅客户端代码

  class Program
   {        static void Main(string[] args)
       {
           Subscript();
           Console.Read();
       }        /// <summary>
       /// 订阅        /// </summary>
       public static void Subscript()
       {
           IRedisClientsManager clientManager = new PooledRedisClientManager("[email protected]:6379");            var client = clientManager.GetClient();        
           //创建订阅
           IRedisSubscription subscription = client.CreateSubscription();            //接收消息处理Action
           subscription.OnMessage = (channel, msg) =>
           {
               Console.WriteLine("频道【{0}】[{1}]", channel, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
               Console.WriteLine(msg);
           };            //订阅事件处理
           subscription.OnSubscribe = (channel) =>
           {
               Console.WriteLine("订阅客户端：开始订阅" + channel);
           };            //取消订阅事件处理
           subscription.OnUnSubscribe = (a) => { Console.WriteLine("订阅客户端：取消订阅"); };            //订阅频道
           subscription.SubscribeToChannels("channel-1");

       }


   }
}

测试

通过postman调用接口，开启订阅客户端。

订阅的客户端

结语

发现通过这种方式实现的发布与订阅还是很简单的。