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