Redis消息队列
  DcpJeOZ6VzTX 2023年11月02日 287 0

消息列队

生产消费模型

Redis消息队列_消息队列

消息队列(Message Queue)是一种应用间的通信方式,消息发送后可以立即返回,有消息系统来确保信息的可靠专递,消息生产者只管把消息发布到MQ中而不管谁来取,消息消费者只管从MQ中取消息而不管谁发布的,这样发布者和使用者都不用知道对方的存在。

消息队列使用原因 首先,我们可以知道,消息队列是一种异步的工作机制,比如说日志收集系统,为了避免数据在传输过程中丢失,还有订单系统,下单后,会生成对应的单据,库存的扣减,消费信息的发送,一个下单,产生这么多的消息,都是通过一个操作的触发,然后将其他的消息放入消息队列中,依次产生。再就是很多网站的,秒杀活动之类的,前多少名用户会便宜,都是通过消息队列来实现的。

VMware集群化产品

VCenterServer VspareCLient

Linux虚拟化产品

VirtualBox KVM (OpenStack是KVM的编排工具)

消息队列产品

1)rabbit-MQ(最初起源于金融系统,用于分布式系统中存储转发消息。OpenStack) 2)Zero-MQ(SaltStack) 3)Kafka(JAVA) 4)redis(key:value数据库,缓存,消息队列)

Redis发布消息的两种模式

任务队列模式

**任务队列:**顾名思义,就是“传递消息的队列”。与任务队列进行交互的实体有两类,一类是生产者,另 一类则是消费者。生产者将需要处理的任务放入任务队列中,而消费者则不断地从任务独立中读入任 务信息并执行。 任务队列的好处 1)松耦合。 生产者和消费者只需按照约定的任务描述格式,进行编写代码。 2)易于扩展。 多消费者模式下,消费者可以分布在多个不同的服务器中,由此降低单台服务器的负载。

发布-订阅模式

其实从Pub/Sub的机制来看,它更像是一个广播系统,多个订阅者(Subscriber)可以订阅多个频道(Channel),多个发布者(Publisher)可以往多个频道(Channel)中发布消息。 可以这么简单的理解: 1)Subscriber:收音机,可以收到多个频道,并以队列方式显示 2)Publisher:电台,可以往不同的FM频道中发消息 3)Channel:不同频率的FM频道

订阅发布模型

1)一个发布者多个订阅者

下图所示,可以作为消息队列或者消息管道。 主要应用:通知、公告


2)多个发布者一个订阅者 可以将PubSub做成独立的HTTP接口,各应用程序作为Publisher向Channel中发送消息,Subscriber端 收到消息后执行相应的业务逻辑,比如写数据库,显示等等。 主要应用:排行榜、投票、计数。


3)多个发布者多个订阅者 故名思议,就是可以向不同的Channel中发送消息,由不同的Subscriber接收。 主要应用:群聊、聊天。


发布订阅实践
1)PUBLISH channel msg
将信息 message 发送到指定的频道 channel

2)SUBSCRIBE channel [channel ...]
订阅频道,可以同时订阅多个频道

3)UNSUBSCRIBE [channel ...]		#(ctr;+C就是取消订阅)
取消订阅指定的频道, 如果不指定频道,则会取消订阅所有频道

4)PSUBSCRIBE pattern [pattern ...]
订阅一个或多个符合给定模式的频道,每个模式以 * 作为匹配符,比如 it* 匹配所 有以 it 开头的频道( it.news 、 it.blog 、 it.tweets 等等), news.* 匹配所有 以 news. 开头的频道(news.it 、 news.global.today 等等),诸如此类

5)PUNSUBSCRIBE [pattern [pattern ...]]		#(ctr;+C就是取消订阅)
退订指定的规则, 如果没有参数则会退订所有规则

6)PUBSUB subcommand [argument [argument ...]]
查看订阅与发布系统状态
一个发布者多个订阅者
# 1.先订阅频道
127.0.0.1:6379> SUBSCRIBE FM8888
1) "subscribe"
2) "FM888"
3) (integer) 1
# 2.发布者将信息发到频道
127.0.0.1:6379(subscribed mode)> SUBSCRIBE FM888 test

Redis消息队列_发布-订阅模式_02

多个发布者一个订阅者
# 多个发布者(同一个频道发布者不同)
127.0.0.1:6379> PUBLISH FM8888 test2
127.0.0.1:6379> publish FM8888 test3
# 订阅者
127.0.0.1:6379(subscribed mode)> SUBSCRIBE FM8888
1) "message"
2) "FM8888"
3) "test2"
1) "message"
2) "FM8888"
3) "test3"

Redis消息队列_任务队列模式_03

多个发布者多个订阅者
# 1.订阅者订阅所有频道
127.0.0.1:6379> PSUBSCRIBE *
# 2.发布者发布内容
127.0.0.1:6379> PUBLISH FM8888 test4
(integer) 1
127.0.0.1:6379> PUBLISH FM111 test5
(integer) 1
127.0.0.1:6379> PUBLISH FM222 111

Redis消息队列_发布-订阅模式_04

【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

上一篇: Redis哨兵模式 下一篇: Redis的事务和锁
  1. 分享:
最后一次编辑于 2023年11月08日 0

暂无评论