前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >redis 学习(12)-- redis 发布订阅

redis 学习(12)-- redis 发布订阅

作者头像
希希里之海
发布2019-06-03 08:36:48
6800
发布2019-06-03 08:36:48
举报
文章被收录于专栏:weixuqin 的专栏

redis 发布订阅

发布订阅模式中的角色

  • 发布者(publisher)
  • 订阅者(subscriber)
  • 频道(channel)

如图所示:

发布者发布消息到频道,订阅了频道的订阅者可以收到消息,订阅者可以订阅不同的频道。

通信模型

  • RedisServer中可以创建若干channel
  • 一个订阅者可以订阅多个channel
  • 当发布者向一个频道中发布一条消息时,所有的订阅者都将会收到消息
  • Redis的发布订阅模型没有消息积压功能,即新加入的订阅者收不到发布者之前发布的消息
  • 当订阅者收到消息时,消息内容如下
    • 第一行:固定内容message
    • 第二行:channel的名称
    • 第三行:收到的新消息

发布订阅的 API

命令

含义

publish channel message

向指定的channel中发布消息

subscribe channel1 [channel2...]

订阅给定的一个或多个渠道的消息

unsubcribe [channel1 [channel2...]]

取消订阅给定的一个或多个渠道的消息

psubscribe pattern1 [pattern2...]

订阅一个或多个符合给定模式的频道

punsubscribe [pattern1 [pattern2...]]

退订所有给定模式的频道

pubsub channel

列出至少有一个订阅者的频道

pubsub numsub [channel...]

列出给定频道的订阅者数量

演示

消息队列和发布订阅区别

我们来看一张消息队列通信模型的图:

可以看到:

发布订阅模式是将消息通知每一个订阅者,消息队列是消息发布者发表消息后只有一个消息订阅者收得到,订阅者争抢接受消息,这是一个抢的功能。

发布订阅 - Jedis

代码语言:javascript
复制
//订阅
public void testSubscribe() {
    Jedis jedis = new Jedis("127.0.0.1" , 6381);
    jedis.subscribe(new JedisPubSub() {
        @Override
        public void onMessage(String channel, String message) {
            System.out.println("receive channel ["+channel+"] message ["+message+"]");
        }
    } , "aliTV" , "googleTV");
}

//发布
public void testPublish() {
    Jedis jedis = new Jedis("127.0.0.1" , 6381);
    jedis.publish("aliTV" , "I am xxx");
    jedis.publish("googleTV" , "My age is 21");
}
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2019-06-02 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • redis 发布订阅
    • 发布订阅模式中的角色
      • 通信模型
        • 发布订阅的 API
          • 演示
            • 消息队列和发布订阅区别
              • 发布订阅 - Jedis
              相关产品与服务
              消息队列 CMQ 版
              消息队列 CMQ 版(TDMQ for CMQ,简称 TDMQ CMQ 版)是一款分布式高可用的消息队列服务,它能够提供可靠的,基于消息的异步通信机制,能够将分布式部署的不同应用(或同一应用的不同组件)中的信息传递,存储在可靠有效的 CMQ 队列中,防止消息丢失。TDMQ CMQ 版支持多进程同时读写,收发互不干扰,无需各应用或组件始终处于运行状态。
              领券
              问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档