目 录CONTENT

文章目录

Redis管道和发布订阅

Sakura
2023-09-06 / 0 评论 / 0 点赞 / 33 阅读 / 0 字 / 正在检测是否收录...
温馨提示:
本文最后更新于57天前,若内容或图片失效,请留言反馈。 部分素材来自网络,若不小心影响到您的利益,请联系我们删除。

Redis管道和发布订阅

1. 管道

1.1 基本介绍

官网 : https://redis.io/docs/manual/pipelining

Pipeline是为了解决RTT往返回时,仅仅是将命令打包一次性发送,对整个Redis的执行不造成其它任何影响

批处理命令变种优化措施,类似 Redis 的原生批命令 ( mget 和 mset )

1.2 使用

  1. 将批量命令写入文件

  2. cat 文件通过管道符号 , 执行 redis -- pipe 命令

  3. 查看执行结果errors repies

1.3 管道和原生批量命令的对比

  1. 原生批量命令是原子性(例如:mset, mget ), pipeline 是非原子性

  2. 原生批量命令一次只能执行一种命令,pipeline 支持批量执行不同命令

  3. 原生批命令是服务端实现,而 pipeline 需要服务端与客户端共同完成

1.4 管道和事务的对比

  1. 事务具有原子性,管道不具有原子性

  2. 管道一次性将多条命令发送到服务器,事务是一条一条的发,事务只有在接收到eXec命令后才会执行,管道不会

  3. 执行事务时会阻塞其他命令的执行,而执行管道中的命令时不会

1.5 注意事项

  • pipeline 缓冲的指令只是会依次执行,不保证原子性,如果执行中指令发生异常,将会继续执行后续的指令

  • 使用 pipeline 组装的命令个数不能太多,不然数据量过大客户端阻塞的时间可能过久,同时服务端比时也被迫回复一个队列答复,占用很多内存

2. 发布订阅

2.1 基本介绍

是一种消息通信模式:发送者(PUBLISH)发送消息订阅者(SUBSCRIBE)接收消息可以实现进程间的消息传递

发布订阅就是 Redis 消息中间件 ( Stream ) 的前身

  • 不推荐使用该功能使用 Stream 也不用发布订阅,专业的事情交给专业的中间件处理,Redis 就做好分布式缓存功能

2.2 基本命令

-- 订阅一个或多个给定模式的频道(pattern可以匹配通配符)
PSUBSCRIBE pattern [pattern...]

-- 查看订阅与发布系统状态
PUBSUB CHANNELS -- 查看具体的频道
PUBSUB NUMPAT -- 只统计使用PSUB命令执行的
PUBSUB NUMPAT channel -- 返回某个频道有几个订阅者

-- 将信息发送到指定的频道
PUBLISH channel message

-- 订阅给定的一个或多个频道的消息
SUBSCRIBE channel

-- 退订所有给定模式的频道
UNSUBSCRIBE

-- 退订给定的频道 
PUNSUBSCRIBE 

2.3 使用

  1. 开启三个客户端,A,B 订阅消息,C 发布消息

# 两个客户端订阅
subscribe c1
subscribe c1,c2

# 第三个客户端发布消息
# 返回收到的频道数
publish c1 hello

订阅的客户单每次可以收到 3 个参数的消息,分别消息种类,始发频道的名称,实际的消息内容

  1. 演示批量订阅和发布

# 批量订阅
PSUBSCRIBE c* a?

# 查看模式订阅的频道
PUBSUB NUMPAT 

# 发布消息
publish c111 hello
  1. 取消订阅

2.4 Pub/Sub 缺点

  1. 发布的消息在 Redis 系统中不能持久化,因此,必须先执行订阅,再等待消息发布。如果先发布了消息,那么该消息由于没有订阅者,消息将被直接丢弃

  2. 消息只管发送对于发布者而言消息是即发即失的,不管接收,也没有 ACK 机制,无法保证消息的消费成功

  3. 以上的缺点导致 Redis 的 Pub/Sub 模式就像个小玩具,在生产环境中几乎无用武之地,为此Redis 5.0 版本新增了 Stream 数据结构,不但支持多播,还支持数据持久化,相比 Pub/Sub 更加的强大

0

评论区