【RabbitMQ】初识消息中间件MQ

灰太狼 2023-09-27 17:24 127阅读 0赞

**目录**

一、什么是MQ

二、MQ的优缺点

1、MQ的优点

1.应用解耦

2.削峰填谷

3.异步提速

2、MQ的缺点

1.可用性低

2.系统复杂度高

3.数据一致性问题

三、MQ使用场景

四、常见的MQ

--------------------

## 一、什么是MQ ##

MQ（Message Queue）：消息队列，他是在消息传输过程中的消息保存容器，生产者生产消息后存入消息队列后被消费者消费时拿走。MQ多用于分布式系统之间的通信。分布式系统之间的通信主要有两种：远程直接调用接口、通过MQ来实现通信

## 二、MQ的优缺点 ##

### 1、MQ的优点 ###

#### 1.应用解耦 ####

在分布式系统里各个子系统去进行通信如果使用远程调用的方法代码的耦合度比较高，如果某个接口异常或后续添加新的子模块对原有系统的代码改动是非常大的耦合度高

![9ab63f14e92e489fad2bb790b955e5c4.png][]

如果我们使用MQ进行通信就可以很好的达到解耦的效果，后续新增模块不再需要去关心系统A如何实现，直接去对接MQ即可

![2dd60ee289bc4cd89a3cf0cff05ec97e.png][]

#### 2.削峰填谷 ####

如果我们的服务器等承受的请求位1000，当某一时刻请求剧增达到10000时，此时服务器就会宕机，面对剧增的请求我们可以在请求到达服务器前让他先存入MQ里，然后由MQ每次给服务器1000条请求进行处理![a71f82ab8d8b4599a23a84376726b63c.png][]

#### 3.异步提速 ####

当用户确认订单后后台会相应的去调用库存系统、物流系统、支付系统等，订单系统收到各个系统的响应后才会给用户反馈，此过程是同步的，需要消耗的时间对于用户来说是比较长的用户

![09f9de47854a4d4aa560df942806a74b.png][]

用户需要等待500+500+500+10ms,此时如果我们加入MQ异步的去处理就会极大的提高响应速度

![fa37a17f1e3b4d6d8bbf8822d28fe1ca.png][]

我们只需要把消息交给MQ去异步地处理就可以提高响应速度与系统吞吐量

### 2、MQ的缺点 ###

#### 1.可用性低 ####

如果使用不当导致MQ服务器宕机就会对整个分布式系统产生很大的影响

#### 2.系统复杂度高 ####

使用MQ关联各个子系统，导致系统复杂度高可能会存在消息重复消费、消息丢失等问题

#### 3.数据一致性问题 ####

使用MQ关联分布式系统的子系统时数据的统一性也是一个存在的问题

## 三、MQ使用场景 ##

当生产者不需要等待消费者返回相应的业务场景就可以使用MQ ,以及使用MQ对系统带来的收益大于缺点时可以使用MQ，业务允许数据存在短暂的不一致性时也可以使用MQ

## 四、常见的MQ ##

<table style="width:500px;"> 
 <tbody> 
  <tr> 
   <td></td> 
   <td>社区</td> 
   <td style="width:114px;">开发语言</td> 
   <td style="width:33px;">支持协议</td> 
   <td>支持语言</td> 
   <td>单机吞吐量</td> 
   <td>延迟</td> 
   <td>特点</td> 
  </tr> 
  <tr> 
   <td>RabbitMQ</td> 
   <td>Rabbit</td> 
   <td style="width:114px;">Erlang</td> 
   <td style="width:33px;">AMQP、&nbsp; XMPP、SMTP、STOMP</td> 
   <td>Erlang、Java、Ruby等</td> 
   <td>万&nbsp; 级&nbsp; &nbsp;&nbsp;</td> 
   <td>微秒级</td> 
   <td>社区活跃、并发性好、延迟低、性能好</td> 
  </tr> 
  <tr> 
   <td style="width:114px;">Kafka</td> 
   <td>Apache</td> 
   <td style="width:114px;">Scala、Java</td> 
   <td style="width:33px;">自定义协议，他的社区封装了HTTP协议</td> 
   <td>Java、PHP、Python等</td> 
   <td>十万级</td> 
   <td>毫秒内</td> 
   <td>主要用户大数据领域，只支持主要的MQ功能</td> 
  </tr> 
  <tr> 
   <td>RocketMQ</td> 
   <td>阿里</td> 
   <td style="width:114px;">Java</td> 
   <td style="width:33px;">自定义协议</td> 
   <td>Java、C++</td> 
   <td>十万级</td> 
   <td>毫秒级</td> 
   <td>具有完备的MQ功能，可扩展性极佳</td> 
  </tr> 
  <tr> 
   <td>ActiveMQ</td> 
   <td>Apache</td> 
   <td style="width:114px;">Java</td> 
   <td style="width:33px;">OpenWire、AMQP、STOMP、XMPP、REST</td> 
   <td>Java、C、C++、PHP等</td> 
   <td>万级</td> 
   <td>毫秒级</td> 
   <td>老牌产品、文档多、成熟</td> 
  </tr> 
 </tbody> 
</table>

其中单机吞吐量最好到最差依次是：RocketMQ、Kafka、RabbitMQ、ActiveMQ

[9ab63f14e92e489fad2bb790b955e5c4.png]: https://img-blog.csdnimg.cn/9ab63f14e92e489fad2bb790b955e5c4.png
[2dd60ee289bc4cd89a3cf0cff05ec97e.png]: https://img-blog.csdnimg.cn/2dd60ee289bc4cd89a3cf0cff05ec97e.png
[a71f82ab8d8b4599a23a84376726b63c.png]: https://img-blog.csdnimg.cn/a71f82ab8d8b4599a23a84376726b63c.png
[09f9de47854a4d4aa560df942806a74b.png]: https://img-blog.csdnimg.cn/09f9de47854a4d4aa560df942806a74b.png
[fa37a17f1e3b4d6d8bbf8822d28fe1ca.png]: https://img-blog.csdnimg.cn/fa37a17f1e3b4d6d8bbf8822d28fe1ca.png