zoukankan      html  css  js  c++  java
  • [Redis]发布/订阅

    摘要

    有这样的一个场景,管理员需要发布一条消息,所有的客户端都要受到通知。然后想到了发布订阅模式。使用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("password@192.168.1.102: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("password@192.168.1.102: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调用接口,开启订阅客户端。

    订阅的客户端

    结语

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

    转载:博客地址:http://www.cnblogs.com/wolf-sun/

  • 相关阅读:
    Linux下NDK编译FFMPEG包含neon参数
    编译器优化陷阱——全局指针多次使用异常
    Linux下使用NDK编译FFMPEG(libstagefright)
    查看Android支持的硬解码信息
    图片格式转换
    转 MFC 主界面函数中线程等待避免界面卡死的处理方法
    Windows Shell编程实现重叠图标IconOverlay
    转 MFC中 GB2312、UTF-8、unicode 之间转换
    windows双机调试
    位图BITMAP结构
  • 原文地址:https://www.cnblogs.com/cqqinjie/p/7297918.html
Copyright © 2011-2022 走看看