1、什么是rabbitmq

采用AMQP高級消息隊(duì)列協(xié)議的一種消息隊(duì)列技術(shù),最大的特點(diǎn)就是消費(fèi)并不需要確保提供方存在,實(shí)現(xiàn)了服務(wù)之間的高度解耦

2、為什么要使用rabbitmq

1. 在分布式系統(tǒng)下具備異步,削峰,負(fù)載均衡等一系列高級功能;

2. 擁有持久化的機(jī)制，進(jìn)程消息，隊(duì)列中的信息也可以保存下來。

3. 實(shí)現(xiàn)消費(fèi)者和生產(chǎn)者之間的解耦。

4. 對于高并發(fā)場景下，利用消息隊(duì)列可以使得同步訪問變?yōu)榇性L問達(dá)到一定量的限流，利于數(shù)據(jù)庫的操作。

可以使用消息隊(duì)列達(dá)到異步下單的效果，排隊(duì)中，后臺進(jìn)行邏輯下單

3、使用rabbitmq的場景

1. 服務(wù)間異步通信

2. 順序消費(fèi)

3. 定時(shí)任務(wù)

4. 請求削峰

4、如何確保消息正確地發(fā)送至RabbitMQ？ 如何確保消息接收方消費(fèi)了消息？

發(fā)送方確認(rèn)模式

將信道設(shè)置成confirm模式（發(fā)送方確認(rèn)模式），則所有在信道上發(fā)布的消息都會被指派一個(gè)唯一的ID。

一旦消息被投遞到目的隊(duì)列后，或者消息被寫入磁盤后（可持久化的消息），信道會發(fā)送一個(gè)確認(rèn)給生產(chǎn)者（包含消息唯一ID）。

如果RabbitMQ發(fā)生內(nèi)部錯誤從而導(dǎo)致消息丟失，會發(fā)送一條nack（not acknowledged，未確認(rèn)）消息。

發(fā)送方確認(rèn)模式是異步的，生產(chǎn)者應(yīng)用程序在等待確認(rèn)的同時(shí)，可以繼續(xù)發(fā)送消息。當(dāng)確認(rèn)消息到達(dá)生產(chǎn)者應(yīng)用程序，生產(chǎn)者應(yīng)用程序的回調(diào)方法就會被觸發(fā)來處理確認(rèn)消息。

接收方確認(rèn)機(jī)制

接收方消息確認(rèn)機(jī)制

消費(fèi)者接收每一條消息后都必須進(jìn)行確認(rèn)（消息接收和消息確認(rèn)是兩個(gè)不同操作）。只有消費(fèi)者確認(rèn)了消息，RabbitMQ才能安全地把消息從隊(duì)列中刪除。

這里并沒有用到超時(shí)機(jī)制，RabbitMQ僅通過Consumer的連接中斷來確認(rèn)是否需要重新發(fā)送消息。也就是說，只要連接不中斷，RabbitMQ給了Consumer足夠長的時(shí)間來處理消息。保證數(shù)據(jù)的最終一致性；

下面羅列幾種特殊情況

如果消費(fèi)者接收到消息，在確認(rèn)之前斷開了連接或取消訂閱，RabbitMQ會認(rèn)為消息沒有被分發(fā)，然后重新分發(fā)給下一個(gè)訂閱的消費(fèi)者。（可能存在消息重復(fù)消費(fèi)的隱患，需要去重）

如果消費(fèi)者接收到消息卻沒有確認(rèn)消息，連接也未斷開，則RabbitMQ認(rèn)為該消費(fèi)者繁忙，將不會給該消費(fèi)者分發(fā)