消息队列主要分为两种, 分别是生产者消费者模式和发布者订阅者模式, 这两种模式 Redis 都支持.
生产消费者模式
在生产消费者 (Producer/Consumer) 模式下, 上层应用接收到的外部请求后开始处理其当前步骤的操作, 在执行完成后将已经完成的操作发送至指定的频道 (channel) 当中, 并由其下层的应用监听该频道并继续下一步的操作, 如果其处理完成后没有下一步的操作就直接返回数据给外部请求, 如果还有下一步的操作就再将任务发布到另外一个频道, 由另外一个消费者继续监听和处理.
生产消费这模式介绍
生产者消费者模式下, 多个消费者同时监听一个队列, 但是一个消息只能被最先抢到消息的消费者消费, 即消息任务是一次性读取和处理, 此模式在分布式业务架构中非常常用, 比较常用的软件还有 RabbitMQ, Kafka, RocketMQ, ActiveMQ 等
队列介绍
队列当中的 消息由不同的生产者写入也会有不同的消费者取出进行消费处理, 但是一个消息一定是只能被取出一次也就是被消费一次.
生产者发布消息
- 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
查看队列所有消息
- 127.0.0.1:6379> LRANGE channel1 0 -1
- 1) "msg5"
- 2) "msg4"
- 3) "msg3"
- 4) "msg2"
- 5) "msg1"
消费者消费消息
- 127.0.0.1:6379> RPOP channel1 # 从管道的右侧消费
- "msg1"
- 127.0.0.1:6379> RPOP channel1
- "msg2"
- 127.0.0.1:6379> LRANGE channel1 0 -1
- 1) "msg5"
- 2) "msg4"
- 3) "msg3"
- 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)
验证队列消息
- 127.0.0.1:6379> LRANGE channel1 0 -1
- (empty list or set) # 队列中的消息已经被已全部消费完毕
发布者订阅模式
在发布者订阅者模式下, 发布者将消息发布到指定的 channel 里面, 凡是监听该 channel 的消费者都会收到同样的一份消息, 这种模式类似于是收音机模式, 即凡是收听某个频道的听众都会收到主持人发布的相同的消息内容.
此模式常用语群聊天, 群通知, 群公告等场景.
Subscriber: 订阅者
Publisher: 发布者
Channel: 频道
监听者监听频道
- [[email protected] ~]#Redis-cli
- 127.0.0.1:6379> SUBSCRIBE channel1 # 订阅者订阅指定频道
- Reading messages... (press Ctrl-C to quit)
- 1) "subscribe"
- 2) "channel1"
- 3) (integer) 1
发布者发布消息
- [[email protected] ~]#Redis-cli
- 127.0.0.1:6379> PUBLISH channel1 test1 # 发布消息
- (integer) 1
- 127.0.0.1:6379> PUBLISH channel1 test2
- (integer) 1
订阅者验证消息
- [[email protected] ~]#Redis-cli
- 127.0.0.1:6379> SUBSCRIBE channel1
- Reading messages... (press Ctrl-C to quit)
- 1) "subscribe"
- 2) "channel1"
- 3) (integer) 1
- 1) "message"
- 2) "channel1"
- 3) "test1" # 发布者发布的 test1 消息
- 1) "message"
- 2) "channel1"
- 3) "test2" # 发布者发布的 test2 消息
订阅多个频道
- # 订阅指定的多个频道
- 127.0.0.1:6379> SUBSCRIBE channel1 channel2
订阅所有频道
127.0.0.1:6379> PSUBSCRIBE *
订阅匹配的频道
127.0.0.1:6379> PSUBSCRIBE chann* #匹配订阅多个频道
来源: http://www.bubuko.com/infodetail-3089955.html