消息隊(duì)列是怎么實(shí)現(xiàn)的，能給出思路？我想你的問(wèn)題是想問(wèn)“如何能自己啊,設(shè)計(jì)”一套消息隊(duì)列框架，對(duì)嗎？現(xiàn)實(shí)中巳經(jīng)有了很多面向相同系統(tǒng)的消息隊(duì)列軟件，能成熟的消息隊(duì)列如kafka，rocketmq等。其實(shí)現(xiàn)

消息隊(duì)列是怎么實(shí)現(xiàn)的，能給出思路？

我想你的問(wèn)題是想問(wèn)“如何能自己啊,設(shè)計(jì)”一套消息隊(duì)列框架，對(duì)嗎？

現(xiàn)實(shí)中巳經(jīng)有了很多面向相同系統(tǒng)的消息隊(duì)列軟件，能成熟的消息隊(duì)列如kafka，rocketmq等。其實(shí)現(xiàn)語(yǔ)言也類型眾多，你是可以從Github之類的地方額外這些軟件來(lái)去學(xué)習(xí)和不使用。

而自己啊,設(shè)計(jì)一套消息隊(duì)列，只不過(guò)遇上不同的應(yīng)用場(chǎng)景，其要求是是一樣的的，也沒(méi)都能夠適用所有場(chǎng)景的消息隊(duì)列。而下面我很簡(jiǎn)單分析分析一個(gè)普通的、稍微地完備的消息隊(duì)列框架應(yīng)該設(shè)計(jì)哪些東西，主要推薦再看看基本都功能，思想和設(shè)計(jì)。希望能幫到你。

消息隊(duì)列要注意是是為系統(tǒng)解耦，先說(shuō)說(shuō)看設(shè)計(jì)上必須考慮到哪些。

1、一個(gè)都很發(fā)下的消息隊(duì)列要確定100元以內(nèi)功能（不已經(jīng)列表）

消息收與發(fā)機(jī)制、消息剝落如何處理、、消息不易脫妝化、消息可信度高投遞（至多保證四次投遞，以及重復(fù)投遞的處理）、Topic接受（僅有或多Topic）、多消費(fèi)者投遞（同一Topic消息）、投遞回溯、集群和負(fù)載均衡等性能設(shè)計(jì)、事務(wù)支持、監(jiān)控和告警等魔獸維護(hù)功能

也差不多有這些吧。

以上是設(shè)計(jì)是需要確定的東東。

再簡(jiǎn)單說(shuō)哈實(shí)現(xiàn)程序要確定什么。

2、實(shí)現(xiàn)的話，要注意從協(xié)議、轉(zhuǎn)儲(chǔ)、消費(fèi)簡(jiǎn)單點(diǎn)說(shuō)說(shuō)。

?

協(xié)議：這個(gè)展開(kāi)攻擊了很多內(nèi)容。簡(jiǎn)單啊說(shuō)那是現(xiàn)在高速公路通行的是用RPC框架利用通信。借用PRC框架幫忙解決負(fù)載均衡，服務(wù)發(fā)現(xiàn)自己，協(xié)議化，序列化等問(wèn)題。RPC框架你可以不百度清楚下。

消息首先Topic序列化并組織到存儲(chǔ)管道中，管道維護(hù)一個(gè)鎖，完成鎖的消費(fèi)者網(wǎng)站查詢并獲得自己的消息項(xiàng)。

存儲(chǔ)：存儲(chǔ)管道象會(huì)建立起在內(nèi)存、文件系統(tǒng)（本地或分布式）、數(shù)據(jù)庫(kù)（關(guān)系、非關(guān)系兩者皆可）。這哪一種依據(jù)什么具體情況選用。比如：不需要速度，不必須深度則判斷內(nèi)存，是需要可信度高就選數(shù)據(jù)庫(kù)，等等。

?

消費(fèi)關(guān)系：消息投遞到消費(fèi)者一般需要廣播或單播,最常見(jiàn)的使用場(chǎng)景是組內(nèi)單播，組間廣播，對(duì)如一個(gè)集群內(nèi)可以不不使用相同的群組來(lái)注冊(cè)訂閱。大多還不需要輔助系統(tǒng)好處程序維護(hù)消費(fèi)訂閱關(guān)系，在消費(fèi)關(guān)系發(fā)生了什么變化時(shí)口中發(fā)出通知。

?

同時(shí)是需要而且判斷的東西另外：消息的可靠到達(dá)，去確認(rèn)與刪一，序列號(hào)環(huán)形折彎等等。這些幾句話說(shuō)不清楚，有時(shí)間你可以不在快回復(fù)中提問(wèn)，我具體看知道回答。

rabbitMQ點(diǎn)對(duì)點(diǎn)，一個(gè)隊(duì)列可以多個(gè)消費(fèi)者嗎？

rabbitMQ沒(méi)用啊過(guò)，ActiveMQ中我剛測(cè)試出來(lái)，這個(gè)可以有多個(gè)消費(fèi)者，而且消息是按順序交回給不同的消費(fèi)者，例如消息1給消費(fèi)者a，消息2給消費(fèi)者b，消息3給消費(fèi)者a，消息4給消費(fèi)者b...，這樣的好處是實(shí)現(xiàn)方法了負(fù)載均衡，要是消費(fèi)者b突然死干凈了，消費(fèi)者a那就可以正常了接收的。

個(gè)人再理解，要是我說(shuō)的不對(duì)，期望有大神糾正，多謝了。