pub&sub(发布&订阅)
发布/订阅
是一种消息通信模式：发送者（publish）发送消息，订阅者（subscribe）接受消息，可以实现进程间的消息传递
Redis 可以实现消息中间件 MQ 的功能，通过发布订阅实现消息的引导和分流。不推荐使用该功能，专业的事情交给专业的中间件，redis就做好分布式缓存功能
能干嘛？
redis 客户端可以订阅任意数量的频道，类似我们微信关注多个公众号
- 当有新的消息通过 publish 命令发送给频道 channel1 时
总结：
发布/订阅其实是一个轻量的队列，只不过数据不会被持久化，一般用来处理实时性较高的异步消息
常用命令
subscribe channel [channel...] |
- 订阅给定的一个或多个频道的信息
- 推荐先执行订阅后再发布，订阅成功之前发布的消息是收不到的
- 订阅的客户端每次可以收到一个3个参数的消息
- 消息的种类
- 始发频道的名称
- 实际的消息内容
publish channel message |
- 发布消息到指定的频道
psubscribe pattern[pattern...] |
按照模式批量订阅，订阅一个或多个符合给定模式（支持*号？号之类的）频道
pubsub subcommand [argument [argument ...]] |
- 查看订阅与发布系统状态
pubsub channels |
由活跃频道组成的列表
pubsub numsub [channel [channel...]] |
- 某个频道有几个订阅者
pubsub numpay |
- 只统计使用 pubscribe 命令执行的，返回客户端订阅的唯一模式的数量
unsubscribe [channel [channel...]] |
- 取消订阅
punsubscribe [pattern [pattern...]] |
- 退订所有给定模式的频道
总结
- redis 可以实现消息中间件 MQ 的功能，通过发布订阅实现消息的引导和分流。不推荐使用该功能，专业的事情交给专业的中间件出来，redis就做好分布式缓存功能
- pub/sub 缺点
- 发布的消息在 redis 系统中不能持久化，因此，必须先订阅，再等待消息发布。如果先发布了消息，那么该消息由于没有订阅者，消息将被直接丢弃
- 消息只管发送对于发布者而言消息是即发即失的，不管接收，也没有 ack 机制，无法保证消息的消费成功。
- 以上的缺点导致redis的pub/sub模式就像个小玩具，在生产环境中几乎无用武之地，为此redis 5.0 版本新增了 stream 数据结构，不但支持多播，还支持数据持久化，相比 pub/sub 更加的强大
本博客所有文章除特别声明外，均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来源 Lazy的个人博客！
相关推荐
2025-08-13
RedLock算法和底层源码分析和缓存淘汰策略
上一章自研的redis锁对于一般中小公司，不是特别高并发场景足够用了，单机redis小业务也撑得住。但是对于特别高并发场景的话，就得使用Redisson了 Redis分布式锁-RedLock红锁算法（Distributed locks with Redis）官网：Redis 的分布式锁 |文档 说明： 为什么学习这个？怎样产生的？ 线程 1 首先获取锁成功，将键值对写入 redis 的 master 节点，在 redis 将该键值对同步到 slave 节点之前，master 发生了故障；redis 触发故障转移，其中一个 slave 升级为新的 master，此时新上位的master并不包含线程1写入的键值对，因此线程 2 尝试获取锁也可以成功拿到锁，此时相当于有两个线程获取到了锁，可能会导致各种预期之外的情况发生，例如最常见的脏数据。 我们加的是排它独占锁，同一时间只能有一个建redis锁成功并持有锁，严禁出现2个以上的请求线程拿到锁。危险的！ RedLock算法设计理念Redis也提供了Redlock算法，用来实现基于多个实例的分布式锁。锁变量由多个实例维护，即使有实...
2025-08-13
RDB+AOF
redis数据数据持久化 为什么要用数据持久化？ 数据持久化可以在内存丢失或其他灾难性故障的情况下实现恢复。 数据持久化的两种方式 AOF：以日志的形式来记录每个写操作，将redis执行过的所有写指令记录下来（读操作不记录），只许追加文件但不可以改写文件，redis启动之初会读取该文件重新构建数据，换言之，redis重启的话就根据日志文件的内容将写入指令从前到后执行一次以完成数据的恢复工作。 RDB（Redis 数据库）：RDB 持久性以指定的时间间隔执行数据集的时间点快照。 rdb（redis database）能干嘛？ 在指定的时间间隔内将内存中的数据集快照写入磁盘，也就是行话讲的Snapshot内存快照，它恢复时再将硬盘快照文件直接读回到内存里。Redis的数据都在内存中，保存备份时它执行的是全量快照，也就是说，把内存中的所有数据都记录到磁盘中，一锅端。 Rdb保存的是dump.rdb文件 Redis6.0.16以下 Redis6.2以及Redis-7.0.0 自动触发 redis7版本，按照redis.conf里配置的save<seconds><...
2025-08-13
BigKey和缓存双写
Redis为什么是单线程这种问法其实并不严谨，为啥这么说呢? Redis的版本很多3.x、4.x、6.x，版本不同架构也是不同的，不限定版本问是否单线程也不太严谨。 版本3.x ，最早版本，也就是大家口口相传的redis是单线程，阳哥2016年讲解的redis就是3.X的版本。 版本4.x，严格意义来说也不是单线程，而是负责处理客户端请求的线程是单线程，但是开始加了点多线程的东西(异步删除)。—貌似 2020年5月版本的6.0.x后及2022年出的7.0版本后，告别了大家印象中的单线程，用一种全新的多线程来解决问题。—实锤 几个里程碑的redis版本！ 5.0版本是直接升级到6.0版本，对于这个激进的升级，Redis之父antirez表现得很有信心和兴奋， 所以第一时间发文来阐述6.0的一些重大功能”Redis 6.0.0 GA is out!” 当然，Redis7.0后版本更加厉害 Redis是单线程 主要是指Redis的网络IO和键值对读写是由一个线程来完成的，Redis在处理客户端的请求时包括获取 (socket 读)、解析、执行、内容返回 (socket 写...
2025-08-13
HyperLogLog&Geo&Bitmap
统计类型有哪些？ 亿级系统中常见的四种统计 聚合统计 统计多个集合元素的聚合结果，就是前面的交集差集等集合统计 排序统计（zset） 在面对需要展示最新列表、排行榜等场景时，如果数据更新频繁或者需要分页显示，建议使用ZSet 因为可以使用分页，正反排序 二值统计（bitmap） 集合元素的取值就只有0和1两种，在钉钉上班签到打开的场景中，我们只用记录有签到（1）和没签到（0） 基数统计（hyperloglog） 指 统计一个集合不重复元素个数 HyperLogLog名词解释 什么是UV? Unique Visitor，独立访客，一般理解为客户端IP 需要去重考虑，例如一个人一天访问了10次网站，一天的UV就是1 什么是PV? Page View，页面浏览量 不用去重，例如一个人一天访问了10次网站，一天的PV就是10 什么是DAU? Daily Active User 日活跃用户量 登录或者使用了某个产品的用户数（去重复登录的用户），避免恶意刷单 常用于反映网站，互联网应用或者网络游戏的运营情况 什么是MAU？ Monthly...
2025-08-13
epoll函数和IO多路复用深度解析
epoll 函数和 IO 多路复用深度解析没有 epoll 和 IO 多路复用之前多路复用要解决的问题并发多客户端连接，在多路复用之前最简单和典型的方案：同步阻塞网络IO模型 这种模式的特点就是用一个进程来处理一个网络连接(一个用户请求)，比如一段典型的示例代码如下。 直接调用 recv 函数从一个 socket 上读取数据。 int main(){ ... recv(sock, ...) //从用户角度来看非常简单，一个recv一用，要接收的数据就到我们手里了。} 我们来总结一下这种方式： 优点： 就是这种方式非常容易让人理解，写起代码来非常的自然，符合人的直线型思维。 缺点： 就是性能差，每个用户请求到来都得占用一个进程来处理，来一个请求就要分配一个进程跟进处理， 类似一个学生配一个老师，一位患者配一个医生，可能吗？进程是一个很笨重的东西。一台服务器上创建不了多少个进程。 结论进程在 Linux 上是一个开销不小的家伙，先不说创建，光是上下文切换一次就得几个微秒。所以为了高效地对海量用户提供服务，必须要让一个进程能同时处理很多个 tcp 连接才行。现在假...
2025-08-13
Redis基础
什么是Redis？Redis 是一个内存数据存储，被数百万开发者用作缓存、向量数据库、文档数据库、流式引擎和消息代理。Redis 具有内置的复制和不同级别的磁盘持久化。它支持复杂的数据类型（例如，字符串、散列、列表、集合、有序集合和 JSON），并为这些数据类型定义了原子操作。 Redis 通常被称为数据结构服务器。这意味着 Redis 通过一组命令提供对可变数据结构的访问，这些命令通过 TCP 套接字和简单协议使用服务器-客户端模型发送。因此，不同的进程可以以共享的方式查询和修改相同的数据结构。 Redis 实现的数据结构具有一些特殊的属性： Redis 会将其存储在磁盘上，即使它们总是被服务器内存中读取和修改。这意味着 Redis 速度快，但同时也非易失性。 数据结构的实现强调内存效率，因此 Redis 内部的数据结构可能比使用高级编程语言建模的相同数据结构模型使用更少的内存。 Redis 提供了一系列数据库中常见的功能，如复制、可调的持久性级别、集群和高度可用性。 下载Redis 命名规则： 版本号第二位如果是奇数，则为非稳定版本，如2.7、2.9、3.1 版本...
