前言：在這里我將用java來簡單的實現(xiàn)rabbitMQ。下面我們帶著下面問題來一步步的了解和學(xué)習(xí)rabbitMQ。
1：如果消費者連接中斷，這期間我們應(yīng)該怎么辦
2：如何做到負載均衡
3：如何有效的將數(shù)據(jù)發(fā)送到相關(guān)的接收者？就是怎么樣過濾
4：如何保證消費者收到完整正確的數(shù)據(jù)
5：如何讓優(yōu)先級高的接收者先收到數(shù)據(jù)
一："Hello RabbitMQ"
下面有一幅圖，其中P表示生產(chǎn)者，C表示消費者，紅色部分為消息隊列
二：項目開始
2.1：首先引入rabbitMQ jar包
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>3.6.5</version>
</dependency>
2.2：創(chuàng)建消費者Producer
