前言
- 业务接触到RabbitMQ,为了梳理相关知识，特别做个梳理
什么是RabbitMQ
- MQ:Message Queue，即消息队列。
- 什么是消息队列？
- 消息指的是应用之间传输的数据。
- 消息队列是一种应用间的通信方式。消息发布者只用负责发布消息到MQ，而不用管谁来消费；消费者只用关心消费哪个队列的消息，而不用关心这个消息是谁生产的。
使用消息队列的场景
- 订单系统；
- 业务描述：用户下订单要处理下面的过程
- 用户下订单
- 库存结算
- 这两者如果按照传统的处理方式是：
- 订单系统->库存系统，这样会产生高耦合的关系，如果库存系统因为高并发冲击而崩掉，订单因为库存没有减少而失败。
- 一种解决思路：引入MQ
- 订单系统下单->发布消息到消息队列
- 库存系统到消息队列取订单记录，库存系统自己慢慢消费这个队列
- 因为是异步，有足够的时间处理；而且就算库存系统崩掉，订单也不会因为库存系统崩掉而失败，只要修复库存系统再消费队列消息即可。
- 业务描述：用户下订单要处理下面的过程
- 注册系统
- 业务描述：用户注册，假设系统要做几件事：
- 注册信息写入数据库
- 发送注册确认邮件
- 发送注册验证短信
- 其中第二第三步其实用户不太关心。在严格意义上，用户希望注册点击提交之后，马上可以看到注册结果。这个时候系统只要在很短的时间内返回注册处理消息，比如告诉用户，你注册成功了，请注意接收短信或者邮箱确认。如果全部串行处理完，在大量注册行为的情况下用户体验不好；如果引入MQ，处理将会变成这样：
- 注册信息写入数据库
- 注册记录写入MQ，
- 邮件系统和短信系统分别从MQ里取消息消费。完成相应动作。
- 最终的结果是，在注册信息写入数据库就可以知道用户完成了数据库写入的操作，而不用依赖于短信和邮箱，可以提高处理时间。
- 业务描述：用户注册，假设系统要做几件事：
先来理解一下RabbitMQ的模型
-
消息模型
消费者（consumer）订阅某个队列。生产者（producer）创建消息，然后发布到队列（queue）中，最后将消息发送到监听的消费者。
1.png -
RabbitMQ基本概念:RabbitMQ 是 AMQP 协议的一个开源实现，所以其内部实际上也是 AMQP 中的基本概念：
2.png其中对于各种名词的通俗解释：
- (Message)消息：消息头+消息体
- (Publisher)消息生产者，一个发布消息的程序
- (Exchange)交换器，相当于一个中转站，用于接收消息并将消息经路由发送给服务器中的队列
- Binding绑定，用于消息队列和交换器之间的关联，它其实是一个规则，我们可以想象成他是一个由绑定构成的路由表。
- Queue消息队列，是消息的容器，消息是一直放在队列里的，等待消费者连接到这个队列将他取走。
- Connection网络连接，eg:TCP连接
- Channel信道，多路复用连接中的一条独立的双向数据流通道。信道是建立在真实的TCP连接内地虚拟连接，AMQP 命令都是通过信道发出去的，不管是发布消息、订阅队列还是接收消息，这些动作都是通过信道完成。因为对于操作系统来说建立和销毁 TCP 都是非常昂贵的开销，所以引入了信道的概念，以复用一条 TCP 连接。（写出这个解释的作者非常棒）
- Consumer消费者，从消息队列中取得消息的客户端程序
- Virtual Host虚拟主机，表示一批交换器、消息队列和相关对象。虚拟主机是共享相同的身份认证和加密环境的独立服务器域。每个 vhost 本质上就是一个 mini 版的 RabbitMQ 服务器，拥有自己的队列、交换器、绑定和权限机制。vhost 是 AMQP 概念的基础，必须在连接时指定，RabbitMQ 默认的 vhost 是 / 。
- Broker消息队列服务器实体
-
消息路由
3.png
暂时写到这，以后深入补。
参考文章
