Redis消息队列

  消息队列主要分为两种，分别是生产者消费者模式和发布者订阅者模式，这两种模式 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： 频道

监听者监听频道

[root@centos7-6 ~]#redis-cli 
127.0.0.1:6379> SUBSCRIBE channel1  # 订阅者订阅指定频道
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel1"
3) (integer) 1

发布者发布消息

[root@centos7-6 ~]#redis-cli
127.0.0.1:6379> PUBLISH channel1 test1  # 发布消息
(integer) 1
127.0.0.1:6379> PUBLISH channel1 test2
(integer) 1

订阅者验证消息

[root@centos7-6 ~]#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* #匹配订阅多个频道