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

rocketmq擴容怎么保證消息順序性？

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

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

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

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

而自己電腦設計一套消息隊列，是因為面對相同的應用場景，其要求是不一樣的，也沒也能適用所有場景的消息隊列。而下面我簡單啊講下一個其它的、稍微地完備的消息隊列框架估計怎么設計哪些東西，通?？梢越榻B下基本都功能，思想和設計。希望能幫到你。

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

1、一個比較好求下載的消息隊列要考慮100元以內功能（不全部列表）

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

大概有這些吧。

以上是設計必須判斷的東東。

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

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

?

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

消息簡單的方法Topic序列化并組織到存儲管道中，管道維護一個鎖，獲得鎖的消費者查詢并我得到自己的消息項。

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

?

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

?

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