訊息有序指的是可以按照訊息的傳送順序來消費。
rocketmq可以嚴格的保證訊息有序。但這個順序，不是全域性順序，只是分割槽（queue）順序。要全域性順序只能乙個分割槽。
之所以出現你這個場景看起來不是順序的，是因為傳送訊息的時候，訊息傳送預設是會採用輪詢的方式傳送到不通的queue（分割槽）。如圖：
而消費端消費的時候，是會分配到多個queue的，多個queue是同時拉取提交消費。如圖：
但是同一條queue裡面，rocketmq的確是能保證fifo的。那麼要做到順序訊息，應該怎麼實現呢——把訊息確保投遞到同一條queue。
下面用訂單進行示例。乙個訂單的順序流程是：建立、付款、推送、完成。訂單號相同的訊息會被先後傳送到同乙個佇列中，消費時，同乙個orderid獲取到的肯定是同乙個佇列。
rocketmq訊息生產端示例**如下：
/*** producer，傳送順序訊息
*/public class producer ;
// 訂單列表
listorderlist = new producer().buildorders();
date date = new date();
******dateformat sdf = new ******dateformat("yyyy-mm-dd hh:mm:ss");
string datestr = sdf.format(date);
for (int i = 0; i < 10; i++)
}, orderlist.get(i).getorderid());//訂單id
system.out.println(sendresult + ", body:" + body);
}producer.shutdown();
} catch (mqclientexception e) catch (remotingexception e) catch (mqbrokerexception e) catch (interruptedexception e)
system.in.read();
}/**
* 生成模擬訂單資料
*/private listbuildorders()
輸出：
從圖中紅色框可以看出，orderid等於15103111039的訂單被順序放入queueid等於7的佇列。queueoffset同時在順序增長。
傳送時有序，接收（消費）時也要有序，才能保證順序消費。如下這段**演示了普通消費（非有序消費）的實現方式。
/*** 普通資訊消費
*/public class consumer
try catch (exception e)
return consumeconcurrentlystatus.consume_success;
}});
consumer.start();
system.out.println("consumer started.");}}
輸出：
可見，訂單號為15103111039的訂單被消費時順序完成亂了。所以用messagelistenerconcurrently這種消費者是無法做到順序消費的，採用下面這種方式就做到了順序消費：
/*** 順序訊息消費，帶事務方式（應用可控制offset什麼時候提交）
*/public class consumerinorder
try catch (exception e)
return consumeorderlystatus.success;
}});
consumer.start();
system.out.println("consumer started.");}}
輸出：
messagelistenerorderly能夠保證順序消費，從圖中我們也看到了期望的結果。圖中的輸出是只啟動了乙個消費者時的輸出，看起來訂單號還是混在一起，但是每組訂單號之間是有序的。因為訊息傳送時被分配到了三個佇列（參見前面生產者輸出日誌），那麼這三個佇列的訊息被這唯一消費者消費。
如果啟動2個消費者呢？那麼其中乙個消費者對應消費2個佇列，另乙個消費者對應消費剩下的1個佇列。
如果啟動3個消費者呢？那麼每個消費者都對應消費1個佇列，訂單號就區分開了。輸出變為這樣：
消費者1輸出：
消費者2輸出：
消費者3輸出：
很完美，有木有？！
按照這個示例，把訂單號取了做了乙個取模運算再丟到selector中，selector保證同乙個模的都會投遞到同一條queue。即： 相同訂單號的--->有相同的模--->有相同的queue。最後就會類似這樣：
總結：rocketmq的順序訊息需要滿足2點：
1.producer端保證傳送訊息有序，且傳送到同乙個佇列。
2.consumer端保證消費同乙個佇列。
RocketMQ 如何保證訊息順序消費
rocketmq支援區域性順序消費，但不支援全域性，換句話說針對topic中的每個queue是可以按照fifo進行消費。要保證乙個訂單有關的訊息順序消費，有兩點需要注意，一是將訂單有關的訊息傳送到相關topic中同乙個queue裡，二是消費者按照先進先出的原則進行消費。在訊息傳送時，需指定對應的me...
RocketMQ訊息順序傳送和消費問題
事故現場分析 由於創新業務產品上線，運營產品想通過一些活動來刺激使用者，採用註冊邀請機制即可獲取積分的相關活動。考慮到後續可能還有其他可能的活動來發放積分，所以設計的時候，採用mq訊息模式發放積分，非同步解耦，並能夠保證資料的最終一致性。考慮到使用者積分計算的時候可能存在併發操作的情況，想到兩種解決...
RocketMQ（04） 傳送順序訊息
如果你的業務上對訊息的傳送和消費順序有較高的需求，那麼在傳送訊息的時候你需要把它們放到同乙個訊息佇列中，因為只有同乙個佇列的訊息才能確保消費的順序性。下面 我們在傳送訊息的時候，呼叫的是需要傳遞messagequeueselector的send 該方法還可以傳遞乙個額外的引數，其對應messageq...