RocketMQ

1、什么是RocketMQ？

RocketMQ 是一个消息中间件，使用的数据存储结构是队列，队列的特点是先进先出。消息队列就是一个使用队列来通信的组件。

常用术语：

RocketMQ（nameserver（broker（topic（MessageQueue（msg

Message： msg 消息

Message Queue： 消息存储的队列，可以有很多个消息队列，这些消息队列是存在broker里面的。

topic： 由一个或多个消息队列Message Queue 队列组成，为了做业务上的分类。

tag： 标签，对msg打个标签

broker： 这些消息队列肯定会保存在某一台生产服务器上，而这台生产服务器我们就称为 broker

nameserver： 服务注册中心（就是各个服务的节点信息注册到这个注册中心里面）

发送消息的是生产者producer，
接收消费消息的为消费者consumer，
消息队列服务端为broker。

消息从producer发往broker，broker将消息存储到本地，然后consumer从broker拉取消息，或者broker推送消息至consumer，最后消费。

为了提高并发度，

2、为什么需要消息队列

因为随着业务不断扩张，从之前的单体架构到现在的微服务架构，成百上千的服务之间的相互调用和依赖，我们需要一个东西来解耦各个服务之间的关系，控制资源合理的使用以及缓冲流量洪峰等等。

这个时候消息队列就应运而生。它常用来实现：异步处理、服务解耦、流量控制。

3、什么是异步处理

随着业务的发展，项目的请求链路会越来越长。比如之前的简单的查库存、下单，到后面的加上积分服务、短信服务等，这一路同步调用下来，客户可能就等着急了，这个时候就可以使用消息队列来进行异步处理。

调用链路长，响应就会变慢，对于一些不需要那么及时的功能，比如短信或者加积分之类的，只需要在下单结束后，扔个消息到消息队列中就可以直接返回响应了。积分服务和短信服务可以并行的消费这条消息。

优点：消息队列的异步处理可以减少请求的等待时间，还能让服务异步