zoukankan      html  css  js  c++  java
  • redis的Pub/Sub功能

    Pub/Sub功能(即Publish,Subscribe)意思是发布及订阅功能。简单的理解就像我们订阅blog一样,不同的是,这里的客户端与server端采用长连接建立推送机制,一个客户端发布消息,可以在多个客户端收到通知。
    发布订阅(pub/sub)是一种消息通信模式,主要的目的是解耦消息发布者和消息订阅者之间的耦合,这点和设计模式中的观察者模式比较相似。pub /sub不仅仅解决发布者和订阅者直接代码级别耦合也解决两者在物理部署上的耦合。redis作为一个pub/sub server,在订阅者和发布者之间起到了消息路由的功能。订阅者可以通过subscribe和psubscribe命令向redis server订阅自己感兴趣的消息类型,redis将消息类型称为通道(channel)。当发布者通过publish命令向redis server发送特定类型的消息时。订阅该消息类型的全部client都会收到此消息。这里消息的传递是多对多的。一个client可以订阅多个channel,也可以向多个channel发送消息。

    客户端一 在监听tv1频道 客户端二 在监听tv1和tv2多个频道 发布者
    > subscribe tv1
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"  # 显示订阅成功
    2) "tv1"        # 订阅的频道(通道)名称
    3) (integer) 1  # 自己订阅的频道数量
    > subscribe tv1 tv2
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"
    2) "tv1"
    3) (integer) 1
    1) "subscribe"
    2) "tv2"
    3) (integer) 2
     
        > publish tv1 1111111111111
    (integer) 2
    发布tv1频道消息
    返回int 2 表示有2个客户端收到了tv1频道消息 
    > subscribe tv1
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"
    2) "tv1"
    3) (integer) 1
    1) "message"            #有消息
    2) "tv1"                    #收到消息频道tv1
    3) "1111111111111"  #消息内容
    > subscribe tv1 tv2
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"
    2) "tv1"
    3) (integer) 1
    1) "subscribe"
    2) "tv2"
    3) (integer) 2
    1) "message"           #有消息
    2) "tv1"                   #收到消息频道tv1
    3) "1111111111111" #消息内容
    <-- 说明:两客户端均收到了tv1频道消息。
        > publish tv2 222222222222
    (integer) 1
    继续发布tv2频道消息
    返回 int 1 表示有1个客户端收到tv2频道消息
    > subscribe tv1
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"
    2) "tv1"
    3) (integer) 1
    1) "message"
    2) "tv1"
    3) "1111111111111"
    > subscribe tv1 tv2
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"
    2) "tv1"
    3) (integer) 1
    1) "subscribe"
    2) "tv2"
    3) (integer) 2
    1) "message"
    2) "tv1"
    3) "1111111111111"
    1) "message"           #有消息
    2) "tv2"                   #收到消息频道tv2
    3) "2222222222222" #消息内容

    <-- 说明:因为客户端一只订阅了tv1频道消息,其收不到此次tv2频道的消息内容;而客户端二订阅了tv1和tv2两个频道消息,故而能收到tv2的消息;
         
  • 相关阅读:
    Android Studio 使用 Gradle 打包 Jar
    图片相关
    判断SIM卡状态,获取SIM卡信息
    SwipeRefreshLayout完美添加及完善上拉加载功能
    环境变量配置文件,本地登录前提示信息/etc/issue
    变量声明declare,简单运算符运算,变量测试与内容替换
    变量:用户自定义变量(本地变量),环境变量,位置参数变量,预定义变量
    多命令顺序执行,dd命令,管道|,grep,通配符,其他特殊符号
    历史命令~/.bash_history,查看所有别名alias,命令执行顺序,命令行常用快捷键,输入输出重定向,wc统计字节单词行数
    查看当前支持的shell,echo -e相关转义符,一个简单shell脚本,dos2unix命令把windows格式转为Linux格式
  • 原文地址:https://www.cnblogs.com/martinzhang/p/3415160.html
Copyright © 2011-2022 走看看