消息队列主要分为两种，分别是生产者消费者模式和发布者订阅者模式，这两种模式 Redis 都支持。

生产消费者模式

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

生产消费这模式介绍

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

队列介绍

  队列当中的 消息由不同的生产者写入也会有不同的消费者取出进行消费处理，但是一个消息一定是只能被取出一次也就是被消费一次。

生产者发布消息

127.0.0.1:6379> LPUSH channel1 msg1 # 从管道的左侧写入(integer) 1127.0.0.1:6379> LPUSH channel1 msg2(integer) 2127.0.0.1:6379> LPUSH channel1 msg3(integer) 3127.0.0.1:6379> LPUSH channel1 msg4(integer) 4127.0.0.1:6379> LPUSH channel1 msg5(integer) 5

查看队列所有消息

127.0.0.1:6379> LRANGE channel1 0 -11) "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 -11) "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-cli127.0.0.1:6379> PUBLISH channel1 test1  # 发布消息(integer) 1127.0.0.1:6379> PUBLISH channel1 test2(integer) 1

订阅者验证消息

[root@centos7-6 ~]#redis-cli 127.0.0.1:6379> SUBSCRIBE channel1Reading messages... (press Ctrl-C to quit)1) "subscribe"2) "channel1"3) (integer) 11) "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* #匹配订阅多个频道