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 个参数的消息，分别消息种类，始发频道的名称，实际的消息内容

2. 演示批量订阅和发布

# 批量订阅
PSUBSCRIBE c* a?

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

# 发布消息
publish c111 hello

2. 取消订阅

2.4 Pub/Sub 缺点

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

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

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