分类

生产者消费模式

发布者订阅模式

生产者消费模式

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

模式介绍

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

 队列介绍

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

 生产者发布消息

127.0.0.1:6379> lrange channell 0 -1
1) "x2"
2) "x1"
127.0.0.1:6379> lpush channell x3
(integer) 3
127.0.0.1:6379> lpush channell x4
(integer) 4
127.0.0.1:6379> lpush channell x5
(integer) 5

查看队列所有消息

127.0.0.1:6379> lrange channell 0 -1
1) "x5"
2) "x4"
3) "x3"
4) "x2"
5) "x1"

消费者消费消息

127.0.0.1:6379> rpop channell
"x1"
127.0.0.1:6379> rpop channell
"x2"
127.0.0.1:6379> rpop channell
"x3"
127.0.0.1:6379> rpop channell
"x4"
127.0.0.1:6379> rpop channell
"x5"
127.0.0.1:6379> rpop channell
(nil)
127.0.0.1:6379> 

再次查看队列消息

127.0.0.1:6379> lrange channell 0 -1
(empty array)

发布者订阅模式

模式简介

在发布者订阅者模式下，发布者将消息发布到指定的channel里面，凡是监听该channel的消费者都会收到同样的一份消息，这种模式类似于是收音机的广播模式，即凡是收听某个频道的听众都会收到主持人发布的相同的消息内容

此模式常用语群聊天、群通知、群公告等场景。
Subscriber：订阅者
Publisher：发布者
Channel：频道

 

 订阅者监听频道

订阅一个频道
127.0.0.1:6379> subscribe channel1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel1"
3) (integer) 1
1) "message"订阅多个频道
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订阅匹配频道
127.0.0.1:6379> psubscribe chann*
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "chann*"
3) (integer) 1订阅所有频道
127.0.0.1:6379> psubscribe *
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "*"
3) (integer) 1

发布者发布消息

127.0.0.1:6379> publish channel1 test
(integer) 1

验证消息

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) "test"