Redis 订阅发布_Jedis实现方法
作者:jingxian 发布时间:2023-11-10 03:38:41
我想到使用Redis的订阅发布模式是用来解决推送问题的~。
对于概念性的叙述,多多少少还是要提一下的:
什么是Redis发布订阅?Redis发布订阅是一种消息通信模式,发送者通过通道A发送消息message,订阅过通道A的客户端就可以接收到消息message。嗯度娘上面的解释要比我所说的好多了,而我所理解的就是:所谓的订阅发布模式,其实和我们看电视,听广播差不多,在我们没有调台(换频道)的时候,那个频道也是在传递消息的(发布)。我们换到那个频道上(订阅)就能接收到消息了。是的,虽然可能有些不恰当~
说明
本文中示例采用了三个客户端,以“品”字形排列,由上至下,由左至右分别为客户端1(c1),客户端2(c2),客户端3(c3).特此说明。
Redis订阅与发布命令
首先声明,有关Redis服务器的搭建工作,请自行查阅相关资料进行环境抢建
听说Redis中发布与订阅只有简单的6个命令。即:
PSUBSCRIBE pattern [pattern ...]
订阅一个或者多个符合pattern格式的频道
PUBLISH channel message
发布消息到chanel中
PUBSUB subcommand [argument [argument ...]]
查看订阅与发布系统状态
PUNSUBSCRIBE [pattern [pattern ...]]
退订所有符合格式的频道
SUBSCRIBE channel [channel ...]
订阅一个或者多个频道
UNSUBSCRIBE [channel [channel ...]]
取消订阅频道
例1 - SUBSCRIBE
连接redis后键入命令
SUBSCRIBE study
这样便订阅了一个名为study的频道。
接下来study频道要发消息啦。~~
例2 - PUBLISH
另开启一个客户端,我使用的是品字形布局的最上面那个做为发布者,键入
PUBLISH study "message1-go go go"
可以看到,当客户端1在study频道发布消息时,客户端2(已订阅study频道)可以接收到c1发布的消息,而客户端3由于没有订阅study频道,所以接收不到c1发送的消息。
例3 - PSUBSCRIBE
现在,跟着博主左手,右手一个慢动作。在c3中键入
PSUBSCRIBE study*
OK,现在在c1中键入
PUBLISH study "message2"
上结果图:
c3采用的通配符的形式,也将study频道给订阅成功了。
接下来,在c1中继续键入命令:
PUBLISH study:java "I hate java forever"
可以看到,使用psubscribe不仅将study频道订阅了,而且将以study为首的频道也订阅了。
例4 - PUBSUB
在c1中键入pubsub channel,可以获得:
127.0.0.1:6379> PUBSUB channels
1) "study"
意为当前正在活跃的频道。
Jedis实现订阅发布者模式


猜你喜欢
- 配置java环境变量这里是将环境变量配置在etc/profile,即为所有用户配置JDK环境。sudo vi /etc/profile配置环
- 获取当前年的周数 /// <summary> /// 获得今年有几周 /// </summa
- MyBatis resultMap id标签的错误使用我们在编写VO对象,如果业务场景稍微复杂一点,就会用到集合属性。例如用户查看个人订单列
- 下拉刷新对于一个app来说是必不可少的一个功能,在早期大多数使用的是chrisbanes的PullToRefresh,或是修改自该框架的其他
- 目录概述准备工作使用概述springboot通常整合redis,采用的是RedisTemplate的形式,除了这种形式以外,还有另外一种形式
- 前言LocalDateTime、LocalDate、LocalTime 是 Java8 全新的日期框架,加强了对时间的管理,有很多特别好用的
- 1. 日志框架的选择:(这两个框架,springBoot已经整合,无需引入jar包)2. 在resources目录下配置logback-sp
- MD5加密在我们的程序中,不管是什么,都会有安全问题,今天就说的是MD5加密的方法MD5是哈希算法,也就是 从明文A到密文B很容易,但是从密
- <?xml version="1.0" encoding="utf-8"?> <L
- <html> <head> &nb
- 一、前言:垃圾回收:在未来的JDK中可能G1会为ZGC所取代先问自己几个问题:什么是垃圾?垃圾就是堆内存中(范指)没有任何指针指向的对象实体
- 本文实例讲述了Android自动朗读TTS用法。分享给大家供大家参考,具体如下:TextToSpeech简称 TTS,是自Android 1
- Radiobutton是一种单选按钮,是由于RadioGroup管理下的一组按钮,所以一旦其中的一个button选中,再点击,就不能取消,想
- 前言对象关系映射(ORM)已经被使用了很长时间,以解决在编程过程中对象模型与数据模型在关系数据库中不匹配的问题。Dapper是由Stack
- 获取缓存大小接口主要这里的方法已经和7.0不兼容了。import android.app.usage.UsageStats;import a
- 在应用C#进行Winform窗体程序编写的时候,经常需要编写工具栏。下面小编给大家分享一下C#如何应用ToolSctrip控件编写工具栏。1
- C#实现:#region 计算字符串相似度 /// &l
- 1. 前言本文主要是介绍一下RocketMQ消息生产者在发送消息的时候发送失败的问题处理?这里有两个点,一个是关于消息的处理,一个是关于br
- 2018年3月20日,Oracle发布java10。java10为java带来了很多新特性,其中让人眼前一亮的便是var关键字的引入。wha
- FreeMarker是一个模板引擎,一个基于模板生成文本输出的通用工具,使用纯Java编写FreeMarker被设计用来生成HTML Web