相关概念
消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削峰等问题。实现高性能，高可用，可伸缩和最终一致性架构，是大型分布式系统不可缺少的中间件。流量如果非常之巨大，消息队列必不可少的。
使用场景
异步处理
场景说明：当用户注册成功后，发送注册邮件，发完邮件然后发送注册短信。
传统串行方式：将注册信息写入数据库成功后，向用户发送邮件，再发送注册短信，将结果返回客户端。
对于客户端接收来说，经历了三个业务节点：入库、邮件、短信，对于用户就会消耗累积三个业务节点的时间。
优化方式
并行方式：将注册信息写入数据库成功后，发送注册邮件的同时也发送注册短信，以上三个任务完成后，返回给客户端。这样节省了一个业务节点环节。
消息队列：将注册信息写入数据库成功后，注册信息写入消息队列，发送邮件和短信的消费者异步读取消息队列，写入消息队列即将结果返回给客户端，告诉用户注册成功。（后台跑消费者，通过消费者消费消息队列，完成邮件和短信的发送）
应用解耦
场景说明：电商平台日益强大之后，我们可以将订单系统和库存系统分离，用户下单后，订单系统需要通知库存系统，比如库存有100个商品，用户下单成功之后通知库存系统做处理。
传统方式：订单系统调用库存系统的接口。这种方式并不是很可靠，比如我们在访问接口的时候，系统挂了，或者库存系统挂了，这样用户下单就会失败。
消息队列
订单系统：用户下单后，订单系统完成持久化处理，将消息写入消息队列，返回用户订单下单成功，先不管库存的事。
库存系统：订阅下单的消息，采用拉/推得方式，获取下单信息，库存系统根据下单信息，进行库存操作，这样用户下单的时候不管库存的事。
流量削峰
场景说明：比如电商平台做秒杀活动，一般会因为流量过大，导致流量暴增，服务端压力会巨大。
传统方式：服务端突然接收到来自前端的大量订单请求。
消息队列：在应用前端加入消息队列。
1：当用户请求，服务器接收后，首先写入消息队列。假如消息队列长度超过最大数量，则直接抛弃用户请求或者跳转到其他页面，不至于服务器挂掉影响其他用户请求。
2：秒杀业务根据消息队列中的请求信息，再做后续处理。
日志处理
解决大量日志传输的问题
日志采集客户端，负责日志数据采集，写入RabbitMq、kafka队列。
RabbitMq、kafka消息队列，负责日志数据的接收，存储和转发。
日志处理应用：订阅并消费RabbitMq、kafka队列中的日志数据，进行处理。
消息通讯
点对点消息队列，或者聊天室
点对点：客户端A和客户端B使用同一队列，进行消息通讯，就相当于A和B通话。
聊天室：客户端A，客户端B，客户端N订阅同一个主题，进行消息发布和接收，相当于QQ群、微信群。
