消息队列主要分为两种,这两种模式Redis都支持
生产者/消费者模式
发布者/订阅者模式生产者消费者模式
在生产者/消费者(Producer/Consumer)模式下,上层应用接收到的外部请求后开始处理其当前步骤的 *** 作,在执行完成后将已经完成的 *** 作发送至指定的频道(channel)当中,并由其下层的应用监听该频道并继续下一步的 *** 作,如果其处理完成后没有下一步的 *** 作就直接返回数据给外部请求,如果还有下一步的 *** 作就再将任务发布到另外一个频道,由另外一个消费者继续监听和处理。此模式应用广泛
模式介绍生产者消费者模式下,多个消费者同时监听一个队列,但是一个消息只能被最先抢到消息的消费者消费,即消息任
务是一次性读取和处理,此模式在分布式业务架构中很常用,比较常用的消息队列软件还有RabbitMQ、Kafka、RocketMQ、ActiveMQ等。
队列当中的 消息由不同的生产者写入,也会有不同的消费者取出进行消费处理,但是一个消息一定是只能被取出一次也就是被消费一次。
[root@redis-s4 ~]# redis-cli 127.0.0.1:6379> AUTH 123456 OK 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> 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的消费者都会收到同样的
一份消息,这种模式类似于是收音机的广播模式,即凡是收听某个频道的听众都会收到主持人发布的相同的消息内
容。此模式常用语群聊天、群通知、群公告等场景。
Publisher:发布者
Subscriber:订阅者
Channel:频道订阅者监听频道
[root@redis-s4 ~]# redis-cli 127.0.0.1:6379> AUTH 123456 OK 127.0.0.1:6379> SUBSCRIBE channel1 #订阅者事先订阅指定的频道,之后发布的消息才能收到 Reading messages... (press Ctrl-C to quit) 1) "subscribe" 2) "channel1" 3) (integer) 1发布者发布消息
127.0.0.1:6379> PUBLISH channel1 test1 #发布者发布消息 (integer) 2 127.0.0.1:6379> PUBLISH channel1 test2 (integer) 2各订阅者验证消息
#订阅指定的多个频道 127.0.0.1:6379> SUBSCRIBE channel1 channel2订阅所有频道
127.0.0.1:6379> PSUBSCRIBE * #支持通配符*订阅匹配的频道
127.0.0.1:6379> PSUBSCRIBE chann* #匹配订阅多个频道
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)