rocketmq擴(kuò)容怎么保證消息順序性？生產(chǎn)者中把orderId接受取模，把同一模的數(shù)據(jù)放到messagequeue里面，消費(fèi)者消費(fèi)同一個(gè)messagequeue，只要消費(fèi)者這邊活動有序消費(fèi)，那就是可

rocketmq擴(kuò)容怎么保證消息順序性？

生產(chǎn)者中把orderId接受取模，把同一模的數(shù)據(jù)放到messagequeue里面，消費(fèi)者消費(fèi)同一個(gè)messagequeue，只要消費(fèi)者這邊活動有序消費(fèi)，那就是可以可以保證數(shù)據(jù)被順序消費(fèi)。

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

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

現(xiàn)實(shí)中也有了很多再朝完全不同系統(tǒng)的消息隊(duì)列軟件，長大成熟的消息隊(duì)列如kafka，rocketmq等。其實(shí)現(xiàn)語言也多種多樣，你也可以從Github之類的地方獲得這些軟件來去學(xué)習(xí)和在用。

而自己電腦設(shè)計(jì)一套消息隊(duì)列，是因?yàn)槊鎸ο嗤膽?yīng)用場景，其要求是不一樣的，也沒也能適用所有場景的消息隊(duì)列。而下面我簡單啊講下一個(gè)其它的、稍微地完備的消息隊(duì)列框架估計(jì)怎么設(shè)計(jì)哪些東西，通?？梢越榻B下基本都功能，思想和設(shè)計(jì)。希望能幫到你。

消息隊(duì)列主要是目的是系統(tǒng)解耦，先講講設(shè)計(jì)上要確定哪些。

1、一個(gè)比較好求下載的消息隊(duì)列要考慮100元以內(nèi)功能（不全部列表）

消息收與發(fā)機(jī)制、消息剝落如何處理、、消息不持久化、消息可信投遞（最起碼絕對的保證三次投遞，這些再重復(fù)一遍投遞的處理）、Topic支持什么（僅有或多Topic）、多消費(fèi)者投遞（不同Topic消息）、投遞溯回、集群和負(fù)載均衡等性能設(shè)計(jì)、事務(wù)支持、監(jiān)控和告警等能維護(hù)功能

大概有這些吧。

以上是設(shè)計(jì)必須判斷的東東。

再簡單說說基于要確定什么。

2、實(shí)現(xiàn)方法的話，主要注意從協(xié)議、轉(zhuǎn)儲、消費(fèi)簡單的說說。

?

協(xié)議：這個(gè)發(fā)動了攻擊了很多內(nèi)容。簡單啊說那是現(xiàn)在高速公路通行的是用RPC框架實(shí)現(xiàn)通信。依靠PRC框架能解決負(fù)載均衡，服務(wù)發(fā)現(xiàn)，協(xié)議化，序列化等問題。RPC框架你這個(gè)可以百度打聽一下下。

消息簡單的方法Topic序列化并組織到存儲管道中，管道維護(hù)一個(gè)鎖，獲得鎖的消費(fèi)者查詢并我得到自己的消息項(xiàng)。

存儲：存儲管道一般會確立在內(nèi)存、文件系統(tǒng)（本地或分布式）、數(shù)據(jù)庫（關(guān)系、非關(guān)系男女皆）。這兩種依據(jù)什么具體怎么樣選用。.例如：需要速度，不要深度則判斷內(nèi)存，是需要可信就選數(shù)據(jù)庫，等等。

?

消費(fèi)關(guān)系：消息投遞到消費(fèi)者就像需要廣播或單播,最常見的使用場景是組內(nèi)單播，組間廣播，對如一個(gè)集群內(nèi)也可以不使用是一樣的的群組來注冊訂閱。正常情況還要輔助系統(tǒng)指導(dǎo)程序維護(hù)消費(fèi)訂閱關(guān)系，在消費(fèi)關(guān)系突然發(fā)生變化時(shí)發(fā)出通知。

?

別外不需要特別考慮到的東西也有：消息的靠譜經(jīng)過，再確認(rèn)與重發(fā)，序列號角點(diǎn)等等。這些幾句話說不上來，有時(shí)間你可以在回復(fù)中提問，我具體知道回答。