消息队列是什么

消息队列

消息队列：（Message Queue），经常缩写为MQ。从字面上来理解，消息队列是一种用来存储消息的队列。
看下面的代码：

// 1. 创建一个保存字符串的队列
Queue<String> stringQueue = new LinkedList<String>();

// 2. 往消息队列中放入消息
stringQueue.offer("hello");

// 3. 从消息队列中取出消息并打印
System.out.println(stringQueue.poll());
1
2
3
4
5
6
7
8

创建了一个队列，先往队列中添加了一个消息，然后又从队列中取出了一个消息。这说明了队列是可以用来存取消息的。

我们就可以简单理解消息队列就是将需要传输的数据存放在队列中。

总结一下：

• 消息队列就是用于存放消息的组件
• 程序员可以将消息放入到队列当中，也可以从消息队列中获取消息
• 在很多时候，消息队列它不是一个永久性的存储，是作为临时存储存在的（设定一个期限：设置消息在MQ中保存10天）
• 消息队列中间件：消息队列的组件。例如：Kafka、Active MQ、RabbitMQ、RocketMQ…

消息队列的应用场景

异步处理

在网站新用户注册时，需要将用户的信息保存到数据库中，同时还需要额外发送注册的邮件通知、以及短信注册码给用户。但因为发送邮件、发送注册短信需要连接外部的服务器，需要额外等待一段时间，此时，就可以使用消息队列来进行异步处理，从而实现快速响应。

系统解耦

使用消息队列可以实现系统与系统之间的解耦，比如 买票系统中买票，用户是不直接调用数据库系统的接口，而是把订单信息放到消息队列当中，然后数据库系统从消息队列当中拿去信息，然后再去减库存信息。

流行削峰

在像双11 的时候秒杀等系统的时候，用户直接访问数据库，数据库一时接受到大量的数据请求，就会压垮数据库，所以在这个时候加入消息队列，用消息队列的大吞吐量，快速处理用户的请求（哪怕是Redis还不足够应对这种大数据访问）。
因为消息队列是低延迟、高可靠、高吞吐的，可以应对大量并发

日志处理（大数据领域很常见）

在大型的电商网站（淘宝、京东）还有一些App（抖音、美团）等，都有视频商品等的推荐，就是根据用户的访问点击等行为发现用户的喜好以及活跃程度进行推荐，那么就需要用到消息队列对这些信息的一个收集。

生产者、消费者

在我们之前所学的Java等服务器上，Java是基于http请求的。

而在我们的消息队列当中，这时的交互模式为生产者、消费者模型的。

特点：

• 生产者负责将消息生产到MQ中
• 消费者负责从MQ中获取消息
• 生产者和消费者是解耦的，可能是生产者一个程序、消费者是另外一个程序

消息队列的两种模式

点对点模式

消息发送者生产消息发送到消息队列当中，然后消息接收者从消息队列中取出并且消费信息。消息被消费以后，消息队列中不再有存储了，所以消息接收者不可能消费到已经被消费的信息。

特点：

• 每个消息只有一个接收者（Consumer）(即一旦被消费，消息就不再在消息队列中)；
• 发送者和接收者间没有依赖性，发送者发送消息之后，不管有没有接收者在运行，都不会影响到发送者下次发送消息；
• 接收者在成功接收消息之后需向队列应答成功，以便消息队列删除当前接收的消息。

发布订阅模式

特点：

• 每个消息可以有多个订阅者；
• 发布者和订阅者之间有时间上的依赖性。针对某个主题的订阅者，它必须创建一个订阅者之后，才能消费发布者的消息；
• 为了消费消息，订阅者需要提前订阅该角色主题，并保持在线运行；