Redis不仅可作为缓存服务器，还可用作消息队列。它的列表类型天生支持用作消息队列。如下图所示：

image-20230904145115208

消息队列（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数据库，缓存，消息队列）

发布订阅

任务队列：顾名思义，就是“传递消息的队列”。与任务队列进行交互的实体有两类，一类是发布者，另
一类则是订阅者。生产者将需要处理的任务放入任务队列中，而消费者则不断地从任务独立中读入任
务信息并执行。
任务队列的好处
1）松耦合
生产者和消费者只需按照约定的任务描述格式，进行编写代码。
2）易于扩展
多消费者模式下，消费者可以分布在多个不同的服务器中，由此降低单台服务器的负载。
其实从Pub/Sub的机制来看，它更像是一个广播系统，多个订阅者（Subscriber）可以订阅多个频道
（Channel），多个发布者（Publisher）可以往多个频道（Channel）中发布消息。
可以这么简单的理解：
1）Subscriber：收音机，可以收到多个频道，并以队列方式显示
2）Publisher：电台，可以往不同的FM频道中发消息
3）Channel：不同频率的FM频道

image-20230904144402381

订阅发布模型

1）一个发布者多个订阅者
如下图所示，可以作为消息队列或者消息管道。
主要应用：通知、公告

image-20230904145718898

2）多个发布者一个订阅者

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

image-20230904145741009

3）多个发布者多个订阅者

故名思议，就是可以向不同的Channel中发送消息，由不同的Subscriber接收；主要应用：群聊、聊天

image-20230904145806593

发布订阅实践

#1）PUBLISH channel msg
将信息 message 发送到指定的频道 channel
#2）SUBSCRIBE channel [channel ...]
订阅频道，可以同时订阅多个频道
#3）UNSUBSCRIBE [channel ...]
取消订阅指定的频道, 如果不指定频道，则会取消订阅所有频道
#4）PSUBSCRIBE pattern [pattern ...]
订阅一个或多个符合给定模式的频道，每个模式以 * 作为匹配符，比如 it* 匹配所 有以 it 开头的
频道( it.news 、 it.blog 、 it.tweets 等等)， news.* 匹配所有 以 news. 开头的频道(
news.it 、 news.global.today 等等)，诸如此类
#5）PUNSUBSCRIBE [pattern [pattern ...]]
退订指定的规则, 如果没有参数则会退订所有规则
#6）PUBSUB subcommand [argument [argument ...]]
查看订阅与发布系统状态

一个发布者多个订阅者

# 1.先订阅频道
127.0.0.1:6379> SUBSCRIBE FM8888
1) "subscribe"
2) "FM8888"
3) (integer) 1
# 2.频道发布消息
127.0.0.1:6379> PUBLISH FM8888  test
(integer) 1
# 3.订阅频道查看消息
127.0.0.1:6379> SUBSCRIBE FM8888
1) "subscribe"
2) "FM8888"
3) (integer) 1
1) "message"
2) "FM8888"
3) "test"

image-20230904150826769

多个发布者一个订阅者

#发布消息
127.0.0.1:6379> PUBLISH FM8888 hello,world
(integer) 1
#订阅频道
127.0.0.1:6379> PSUBSCRIBE *
1) "psubscribe"
2) "*"
3) (integer) 1
Reading messages... (press Ctrl-C to quit
1) "pmessage"
2) "*"
3) "FM8888"
4) "hello,world"

image-20230904151532302

0