本文章学习资源黑马程序员Kafka视频教程及资料，黑马程序员YYDS
一、简介
1.消息队列简介
消息队列，英文名：Message Queue，经常缩写为MQ。从字面上来理解，消息队列是一种用来存储消息的队列。我们可以简单理解消息队列就是将需要传输的数据存放在队列中。很多时候消息队列不是一个永久性的存储，是作为临时存储存在的（设定一个期限：设置消息在MQ中保存10天）
2.消息队列中间件
消息队列中间件就是用来存储消息的软件（组件）。举个例子来理解，为了分析网站的用户行为，我们需要记录用户的访问日志。这些一条条的日志，可以看成是一条条的消息，我们可以将它们保存到消息队列中。将来有一些应用程序需要处理这些日志，就可以随时将这些消息取出来处理。
目前市面上的消息队列有很多，例如：Kafka、RabbitMQ、ActiveMQ、RocketMQ、ZeroMQ等。
3.消息中间件的应用场景
3.1 异步处理
电商网站中，新的用户注册时，需要将用户的信息保存到数据库中，同时还需要额外发送注册的邮件通知、以及短信注册码给用户。但因为发送邮件、发送注册短信需要连接外部的服务器，需要额外等待一段时间，此时，就可以使用消息队列来进行异步处理，从而实现快速响应。
3.2 系统解耦
原先一个微服务是通过接口（Feign）调用另一个微服务，这时候耦合很严重，只要接口发生变化就会导致系统不可用。
使用消息队列可以将系统进行解耦合，现在第一个微服务可以将消息放入到消息队列中，另一个微服务可以从消息队列中把消息取出来进行处理，进行系统解耦。
3.3 流量削峰
因为消息队列是低延迟、高可靠、高吞吐的，可以应对大量并发。
3.4 日志处理（大数据领域常见）
大型电商网站（淘宝、京东、国美、苏宁...）、App（抖音、美团、滴滴等）等需要分析用户行为，要根据用户的访问行为来发现用户的喜好以及活跃情况，需要在页面上收集大量的用户访问信息。可以使用消息队列作为临时存储，或者一种通信管道。
4.消息队列模型
生产者、消费者模型
我们之前学习过Java的服务器开发，Java服务器端开发的交互模型是这样的：
我们之前也学习过使用Java JDBC来访问操作MySQL数据库，它的交互模型是这样的：
它也是一种请求响应模型，只不过它不再是基于http协议，而是基于MySQL数据库的通信协议。
而如果我们基于消息队列来编程，此时的交互模式成为：生产者、消费者模型。
5.消息队列的俩种模式
5.1 点对点模式
消息发送者生产消息发送到消息队列中，然后消息接收者从消息队列中取出并且消费消息。消息被消费以后，消息队列中不再有存储，所以消息接收者不可能消费到已经被消费的消息。
点对点模式特点：
- 每个消息只有一个接收者（Consumer）(即一旦被消费，消息就不再在消息队列中)
- 发送者和接收者间没有依赖性，发送者发送消息之后，不管有没有接收者在运行，都不会影响到发送者下次发送消息；
- 接收者在成功接收消息之后需向队列应答成功，以便消息队列删除当前接收的消息；
5.2 发布订阅模式
发布/订阅模式特点：
- 每个消息可以有多个订阅者；
- 发布者和订阅者之间有时间上的依赖性。针对某个主题（Topic）的订阅者，它必须创建一个订阅者之后，才能消费发布者的消息。
- 为了消费消息，订阅者需要提前订阅该角色主题，并保持在线运行；