8 Redis消息队列

消息队列: 把要传输的数据放在队列中
功能: 可以实现多个系统之间的解耦, 异步, 削峰/限流等, 一个对立中可以有多个相同的消息

图片.png

消息队列主要分为两种, 这两种模式redis都支持
1. 生成者消费者模式
2. 发布者订阅者模式

redis并不是主流的消息队列产品, 不过其集群中的某些功能会调用消息队列功能实现
所以redis的消息队里功能一般都是满足自身的集群服务需要, 一般不会用redis作为生产环境的消息队列产品

8.1 生成者消费者模式

在生成者/消费者模式下(producer/consumer), 上层的应用接受到外部请求后, 开始处理其当前步骤的操作
在执行完成后, 将已经完成的操作发送至指定的频道(channel, 逻辑队列中), 并由其下层的应用监听该频道并继续下一步的操作
如果其处理完成后没有下一步的操作, 就直接返回数据给外部请求, 如果还有下一步曹组, 就再将任务发布到另一个频道, 由另外一个消费者继续监听和处理
此模式应用广泛

8.1.1 模式介绍

生产者消费者模式下, 多个消费者同时监听一个队列, 但是一个消息只能被最先抢到消息的消费者消费
即消息任务是一次性读取和处理, 此模式在分布式业务架构中很常用
比较常用的消息队里软件还要RabbitMQ, Kafka, RocketMQ...

8.1.2 队列介绍

队列当中的消息由不同的生产者写入, 也会有不同的消费者取出进行消费处理
但是一个消息一定是只能被取出一次, 也就是被消费一次
如下图, 生成者产生了两个消息, 分别是hello和java, 这两个消费分别只能被一个消费者抢占使用

图片.png

图片.png

实际举例:
大型分布式架构中, 会有多个服务器/容器来负责用户身份的验证
用户登录后, 其信息会被发送到验证channel中, 之后后端的多个验证服务器/容器会从队列中抢占用户信息用于验证
一旦在某个节点验证通过, 就不会发送到其他节点去验证

8.1.3 生成者发布消息

e[21:29:07 root@redis ~]#redis-cli
127.0.0.1:6379> 
127.0.0.1:6379> lpush channel1 msg1   # lpush从管道左侧写入
(integer) 1
127.0.0.1:6379> lpush channel1 msg2   # 消息队里利用的就是列表技术
(integer) 2
127.0.0.1:6379> lpush channel1 msg3
(integer) 3
127.0.0.1:6379> lpush channel1 msg4
(integer) 4
127.0.0.1:6379> lpush channel1 msg5
(integer) 5

8.1.4 查看队里中所有的消息

127.0.0.1:6379> lrange channel1 0 -1
1) "msg5"
2) "msg4"
3) "msg3"
4) "msg2"
5) "msg1"

8.1.5 消费者消费消息

# lpush从左侧写入消息, 需要用rpop从右侧消费消息, 实现先进先出, 也可以从左pop, 具体看程序设定

127.0.0.1:6379> rpop channel1
"msg1"
127.0.0.1:6379> rpop channel1
"msg2"
127.0.0.1:6379> rpop channel1
"msg3"
127.0.0.1:6379> rpop channel1
"msg4"
127.0.0.1:6379> rpop channel1
"msg5"
127.0.0.1:6379> rpop channel1
(nil)

8.1.6 再次验证队列消息

127.0.0.1:6379> lrange channel1 0 -1
(empty list or set)  # 队里中的消息已经被消费完

8.1.7 同一个消息, 只能被消费一次

127.0.0.1:6379> lpush channel1 msg1 
(integer) 1
127.0.0.1:6379> lpush channel1 msg2
(integer) 2
127.0.0.1:6379> lpush channel1 msg3
(integer) 3
127.0.0.1:6379> lpush channel1 msg4
(integer) 4
127.0.0.1:6379> lpush channel1 msg5
(integer) 5

图片.png

8.2 发布者订阅者模式

8.2.1 模式简介

在发布者订阅者模式下, 发布者将消息发布到指定的channel里面, 凡是监听该channel的订阅者都会收到同样的一份消息
这种模式类似于收音机广播电台, 凡是收听某个频道的听众都能收到主持人发布的相同的消息内容
此模式常用于语音聊天, 群通知, 群公告等场景
发布者订阅者模式, 要求订阅者事先订阅频道, 之后发布者再发布消息, 否则没订阅是收不到的

发布者: publisher
订阅者: subscriber
channel: 频道

图片.png

图片.png

8.2.2 订阅者监听频道

127.0.0.1:6379> subscribe channel1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel1"
3) (integer) 1

8.2.3 发布者发布消息

# 生产者消费者模式下用lpush生产消息, 而发布者订阅者模式下使用publish发布消息, 即使用哪个lpush生产了消息, 订阅者也收不到

图片.png

publish channel1 hello

127.0.0.1:6379> publish channel1 hello
(integer) 1

图片.png

8.2.4 各个订阅者都能收到消息

图片.png

8.2.5 订阅多个频道

127.0.0.1:6379> subscribe channel1 channel2
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel1"
3) (integer) 1
1) "subscribe"
2) "channel2"
3) (integer) 2
1) "message"
2) "channel1"
3) "redis"
1) "message"
2) "channel2"
3) "mysql"

# 每个订阅的频道的消息都能收到

127.0.0.1:6379> publish channel1 redis
(integer) 1 # 1表示该频道有1个订阅者
127.0.0.1:6379> publish channel2 mysql
(integer) 1

1) "message"
2) "channel1"
3) "redis"
1) "message"
2) "channel2"
3) "mysql"

8.2.6 订阅所有频道

psubscribe * # 订阅所有频道后, 所有已经存在的频道, 和之后创建的频道都会订阅, 只要发布消息就能手动

8.2.7 订阅匹配的频道

# 订阅频道支持通配符

psubscribe 105.*

8.2.8 取消订阅

127.0.0.1:6379> unsubscribe channel1
1) "unsubscribe"
2) "channel1"
3) (integer) 0