zoukankan      html  css  js  c++  java
  • Redis(1.6)Redis发布订阅

    【0】发布订阅架构图

      

         客户端订阅某个频道,让后有人在频道上发布信息,频道就分发给所有的客户端。

      举个例子:就和微信公众号一样,文章作者者把文章发到微信公众号上,微信公众号平台把文章推送到所有的订阅用户上。

      应用场景:

        (1)在博客网站中,有100个粉丝订阅了你,当你发布新文章时,就可以推送消息给他们。

        (2)微信公众号模式

        (3)类似于开发设计模式中的 观察者模式

    【1】命令

      【1.1】订阅频道

        subscribe channel1 channel2.....  订阅一个或多个指定的频道   subscribe cctv1 cctv2

        psubscribe pattern1 parttern2....   订阅一个或多个符合特定模式的频道  psubscribe cctv*

      【1.2】发布频道信息

        publish channel1 message1    将 message1 发送到指定的 channel1 频道  publish cctv1 hello

        publish numsub channel:channel1    查看 channel1频道中有多少订阅

      【1.3】退订频道  

        unsubscribe channel1 channel2.....  退订一个或多个指定的频道 subscribe cctv1 cctv2

        punsubscribe pattern1 pattern2.....   退订一个或多个特定模式的频道 publish cctv*

    【2】实操演示

       【2.1】订阅频道 subscribe channel1

        

       【2.2】发布频道信息 publish channel messages1

        如果当前频道没有任何订阅者,下图中第2行会显示0,否则有n个订阅者这里就会显示n。

        

       【2.3】查看消息

        客户端1:发布消息

          

         客户端2:接受消息

          

       【2.4】特定模式的订阅与消息查收

        命令操作顺序

        (1)psubscribe cctv*(session1)

        (2)publish cctv1 'hello,cctv1'(session2)

        (3)publish cctv2 'hello,cctv2'(session2)

        且,其接受消息的 message 字段显示成了 pmessage

        session1

          

        session2

          

     【3】基本运作原理

    每个Redis 服务器进程都维持着一个表示服务器状态的 redis.h/redisServer结构, 结构的pubsub_channels 属性是一个字典, 这个字典就用于保存订阅频道的信息:

    struct redisServer {
        // ...
        dict *pubsub_channels;
        // ...
    };

    其中,字典的键为正在被订阅的频道, 而字典的值则是一个链表, 链表中保存了所有订阅这个频道的客户端。
    比如说,在下图展示的这个pubsub_channels示例中,client1 、 client2 和 client3 就订阅了 channel1 , 而client3也同时订阅了channel2。
    当客户端调用SUBSCRIBE命令时, 程序就将客户端和要订阅的频道在pubsub_channels字典中关联起来。

      

    SUBSCRIBE 命令的行为可以用伪代码表示如下:

    复制代码
    def SUBSCRIBE(client, channels):
    
        // 遍历所有输入频道
        for channel in channels:
    
            // 将客户端添加到链表的末尾
            redisServer.pubsub_channels[channel].append(client)
    复制代码

      通过pubsub_channels字典, 程序只要检查某个频道是否为字典的键, 就可以知道该频道是否正在被客户端订阅; 只要取出某个键的值, 就可以得到所有订阅该频道的客户端的信息。

      了解了pubsub_channels字典的结构之后, 解释PUBLISH命令的实现就非常简单了: 当调用PUBLISH channel message命令, 程序首先根据channel定位到字典的键, 然后将信息发送给字典值链表中的所有客户端。

    订阅模式

      redis的发布订阅不仅仅提供简单的订阅频道,还提供模式匹配订阅。模式订阅使用命令PSUBSCRIBE实现。

      redisServer.pubsub_patterns属性是一个链表,链表中保存着所有和模式相关的信息:

    struct redisServer {
        // ...
        list *pubsub_patterns;
        // ...
    };

      链表中的每个节点都包含一个redis.h/pubsubPattern结构:

    typedef struct pubsubPattern {
        redisClient *client;
        robj *pattern;
    } pubsubPattern;


    client 属性保存着订阅模式的客户端,而 pattern 属性则保存着被订阅的模式。
    每当调用 PSUBSCRIBE命令订阅一个模式时, 程序就创建一个包含客户端信息和被订阅模式的pubsubPattern结构, 并将该结构添加到redisServer.pubsub_patterns链表中。
    作为例子,下图展示了一个包含两个模式的 pubsub_patterns 链表, 其中 client123 和 client256 都正在订阅 tweet.shop.* 模式:

    通过遍历整个pubsub_patterns链表,程序可以检查所有正在被订阅的模式,以及订阅这些模式的客户端。

      当执行PUBLISH进行命令向channel命令发送消息时,PUBLISH除了将message 发送到所有订阅channel的客户端之外, 它还会将channel和pubsub_patterns中的模式进行对比,。

      如果channel和某个模式匹配的话, 那么也将message 发送到订阅那个模式的客户端,例如一个客户端订阅了aa.bb.*频道,那么他会收到来自所有aa.bb开头的所有频道消息。

    参考:https://www.cnblogs.com/wdliu/p/9360286.html

  • 相关阅读:
    SVN安装
    MS SQL Server 查询元数据
    MS SQL Server 时间函数
    Codeforces 666E Forensic Examination (后缀自动机 + 线段树合并)
    2020牛客暑期多校训练营(第八场) H Hard String Problem
    2020牛客暑期多校训练营(第四场) B Count New String
    2020牛客暑期多校训练营(第四场) A Ancient Distance
    2020杭电多校第三场 1007 Tokitsukaze and Rescue
    codeforces 1037H
    2020牛客暑期多校训练营(第三场) H Sort the Strings Revision
  • 原文地址:https://www.cnblogs.com/gered/p/11720027.html
Copyright © 2011-2022 走看看