频道栏目
首页 > 数据库 > 其他综合 > 正文
Redis系列(三)-Redis发布订阅及客户端编程
2017-07-15 11:24:12      个评论    来源:秋夜无霜  
收藏   我要投稿

阅读目录

  1. 发布订阅模型
  2. Redis中的发布订阅
  3. 客户端编程示例
  4. 0.3版本Hredis

    发布订阅模型

    在应用级其作用是为了减少依赖关系,通常也叫观察者模式。主要是把耦合点单独抽离出来作为第三方,隔离易变化的发送方和接收方。

    发送方:只负责向第三方发送消息。(杂志社把读者杂志交给邮局)
    接收方:被动接收消息。(1:向邮局订阅读者杂志,2:门口去接邮过来的杂志)
    第三方作用是:存储订阅杂志的接收方,并在杂志过来时送给接收方。 (邮局)

    C#示例,发送方把杂志放到邮局里面:

        if (QA.AddBug())
                EmailNotify();
    接收方到邮局登记地址,有杂志过来时送货上门:
        EmailNotify += () => { Console.WriteLine("A君"); };
        EmailNotify += () => { Console.WriteLine("B君"); };

    第三方邮局接受读者杂志订阅,收到杂志时进行派送:

        public delegate void MessageHandler();
        public static event MessageHandler  EmailNotify;
    
            if (QA.AddBug())
                EmailNotify();

    当我们把观察者模式放大到系统级时,就是发布订阅(pub/sub)了。 主要是用来降低发布者和订阅者的耦合,提高前端系统吞吐量。结构如图:

    \

    Redis中的发布订阅

    Redis实现完整的发布订阅范式,就是说任何一台redis服务器,启动后都可以当做发布订阅服务器。

    普通订阅

    启动订阅者client。

    redis-cli.exe -h 127.0.0.1 -p 6379

    订阅bar频道。格式:SUBSCRIBE name1 name2。
    成功订阅回复,分别对应订阅类型、订阅频道、订阅数量。

    127.0.0.1:6379> SUBSCRIBE bar
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"
    2) "bar"
    3) (integer) 1

    新起个发布者client,发送消息。格式:publish channelName Message。

    127.0.0.1:6379> publish bar val
    (integer) 1

    订阅client回复,分别对应消息类型,频道,消息。

    1) "message"
    2) "bar"
    3) "val"

    图例

    \

    模式订阅

    Redis支持模式匹配订阅,*为模糊匹配符。
    订阅所有频道的消息

    PSUBSCRIBE *  

    订阅以news.开头的所有频道。

    PSUBSCRIBE news.*

    取消订阅

    取消普通订阅和取消模式订阅的命令。

    UNSUBSCRIBE  bar
    PUNSUBSCRIBE  ba*

    取消在官方提供的连接工具中无法模拟的。

    查看订阅信息

    查看订阅消息是redis在2.8中心增加的命令之一。

    pubsub channels [pattern] 。

    返回当前服务器被订阅的所有频道。

    127.0.0.1:6379> pubsub channels
    1) "bar"

    指定匹配参数,返回与模式匹配的所有频道。

    127.0.0.1:6379> pubsub channels ba*
    1) "bar"

    pubsub numsub [channel-1 channel-2 ...channel-n]

    接受任意多个频道作为输入参数,返回这些频道的订阅者数量。

    127.0.0.1:6379> pubsub numsub  bar bar2
    1) "bar"
    2) (integer) 1
    3) "bar2"
    4) (integer) 0

    客户端编程示例

                RedisPubSub client = new RedisPubSub("127.0.0.1", 6381);
                client.OnUnSubscribe += (obj) => {
                    Console.WriteLine();
                };
                client.OnMessage = (sender, arcgs) =>{
                    Console.WriteLine(arcgs);
                };
                client.OnError = (Exception) => { 
                    Console.WriteLine(Exception.Message);
                };
                client.Subscribe("bar");
    
                Console.ReadLine();

    0.3版本HRedis

    基本使用

        using (RedisClient client = new RedisClient("127.0.0.1", 6381))
            {
                client.Set("key", "value");
                client.Get("key");
            }

    使用连接池,自动回收连接。

            PoolRedisClient prc = new PoolRedisClient(new PoolConfiguration());
    
            prc.Single.Set("key", "value");
    
            prc.Single.Get("key");
点击复制链接 与好友分享!回本站首页
上一篇:Redis主从复制原理及设置
下一篇:Redis系列(四)-低成本高可用方案设计
相关文章
图文推荐

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训

版权所有: 红黑联盟--致力于做实用的IT技术学习网站