RabbitMq 简介

小灰灰 2022-05-18 23:45 318阅读 0赞

## 一、RabbitMQ是什么 ##

RabbitMQ,遵循AMQP协议，由内在高并发的erlanng语言开发，用在实时的对可靠性要求比较高的消息传递上。

学过websocket的来理解rabbitMQ应该是非常简单的了，websocket是基于服务器和页面之间的通信协议，一次握手，多次通信。 而rabbitMQ就像是服务器之间的socket，一个服务器连上MQ监听，而另一个服务器只要通过MQ发送消息就能被监听服务器所接收。

但是MQ和socket还是有区别的，socket相当于是页面直接监听服务器。而MQ就是服务器之间的中转站，例如邮箱，一个人投递信件给邮箱，另一个人去邮箱取，他们中间没有直接的关系，所以耦合度相比socket小了很多。

![1111496-20170729155404128-1688170534.png][]

上图是最简单的MQ关系，生产者-MQ队列-消费者

##  二、MQ使用场景 ##

别啥固定式使用场景了，说的透彻一点，他就是服务器之间通信的，前面博文中提到的Httpclient也可以做到，但是这个相对于其他通信在中间做了一个中间仓库。

**优势：**

1、降低了两台服务器之间的耦合，哪怕是一台服务器挂了，另外一台服务器也不会报错或者休克，反正他监听的是MQ，只要服务器恢复再重新连上MQ发送消息，监听服务器就能再次接收。

2、MQ作为一个仓库，本身就提供了非常强大的功能，例如不再是简单的一对一功能，还能一对多，多对一，自己脑补保险箱场景，只要有特定的密码，谁都能存，谁都能取。也就是说能实现群发消息和以此衍生的功能。

![1111496-20170729160855878-683443698.png][]

3、现在普遍化的持久化功能，当MQ挂掉可以存储在磁盘等下重启恢复。（需要设置）

## 三、专业术语介绍 ##

**生产者：** 在现实生活中就好比制造商品的工厂，他们是商品的生产者。生产者只意味着发送。发送消息的程序称之为一个生产者。

**队列：**rabbitMQ就像一个仓库，一个仓库里面可以 有很多队列，每个队列才是服务器之间消息通信的载体。

**消费者：**消费者就好比是从商店购买或从仓库取走商品的人，消费的意思就是接收。消费者是一个程序，主要是等待接收消息。

**交换器：**在生产者和消息队列之间的交换器，功能类似于网络宽带的交换机，可以根据不同的关键字，将信息发送到不同的队列。下图的E就是交换器，通过关键字绑定，如果生产者给的消息中指定类型是ERROR，就给队列1，如果是INFO或者WARN就给队列2。当然也可以一个关键字绑定两个队列。（INFO等字段自己可以定义，也可以用\*，\#来匹配。\*（星号）表示一个单词\#（井号）表示零个或者多个单词。 比如ok.yes可以被ok.\*匹配到）

![1111496-20170729161926769-1481403890.png][]

**临时队列：**根据需求临时创建的一条队列，在断开连接后自动删除。

##  四、流程介绍 ##

生产者发送一条消息给交换机——交换机根据关键字匹配到对应的队列——将消息存入队列——消费者从队列中取出消息使用。

##  五、一些细节说明 ##

MQ不能进行批量的消息处理，你看到的传输再多也只是消息被一条一条的存入队列，消费者从队列中一条一条的取出。这kafKa有区别，所以在效率上比不上kafKa，但是MQ主打的是稳定。

每次消费者取出消息时会通知队列，我拿到了，当队列接收到这条消息，就会把消息删除，这是默认的ACK机制。如果在接收消息之后，消费者挂掉，或者任何情况没有返回ack，队列中这条消息将不会删除，可以一直存着，等待其他消费者来取。    注意，但是如果设置不返回ack，在不断的发送消息到队列又不删除，会导致MQ仓库boom~~~~

[1111496-20170729155404128-1688170534.png]: /images/20220519/f81f761a9da74a928239dec015b4eb5e.png
[1111496-20170729160855878-683443698.png]: /images/20220519/831a18f39fee4b42b6eba1bd7d33b50f.png
[1111496-20170729161926769-1481403890.png]: /images/20220519/9f1934d4c43a48969032f7ecd42d5726.png