Xe228資訊網(wǎng)——每日最新資訊28at.com

關(guān)鍵字摘要

• 全局有序
• 局部有序
• 局部有序能一直有序嗎
• 順序消息的限制

Q1：什么是全局有序？如何實(shí)現(xiàn)全局有序？

適用于性能要求不高，所有的消息嚴(yán)格按照先進(jìn)先出（FIFO）的原則來(lái)發(fā)布和消費(fèi)的場(chǎng)景。Xe228資訊網(wǎng)——每日最新資訊28at.com

例如，在證券處理中，以人民幣兌換美元為Topic，在價(jià)格相同的情況下，先出價(jià)者優(yōu)先處理，則可以按照FIFO的方式發(fā)布和消費(fèi)全局順序消息。Xe228資訊網(wǎng)——每日最新資訊28at.com

要實(shí)現(xiàn)全局有序，必須控制Topic只有一個(gè)隊(duì)列queue，才能實(shí)現(xiàn)全局有序。Xe228資訊網(wǎng)——每日最新資訊28at.com

由于只有一個(gè)隊(duì)列存在，這種方式雖然保證了全局有序，但是性能不高，無(wú)法擴(kuò)展。Xe228資訊網(wǎng)——每日最新資訊28at.com

Q2：什么是局部有序？如何實(shí)現(xiàn)局部有序？

適用于性能要求高，以Sharding Key作為分區(qū)字段，在同一個(gè)隊(duì)列queue中嚴(yán)格地按照FIFO原則進(jìn)行消息發(fā)布和消費(fèi)的場(chǎng)景。Xe228資訊網(wǎng)——每日最新資訊28at.com

例如，用戶注冊(cè)需要發(fā)送發(fā)驗(yàn)證碼，以用戶ID作為Sharding Key，那么同一個(gè)用戶發(fā)送的消息都會(huì)按照發(fā)布的先后順序來(lái)消費(fèi)。Xe228資訊網(wǎng)——每日最新資訊28at.com

保證「消息生產(chǎn)」的順序性，則必須滿足以下條件：Xe228資訊網(wǎng)——每日最新資訊28at.com

• 單一生產(chǎn)者：消息生產(chǎn)的順序性僅支持單一生產(chǎn)者，不同生產(chǎn)者分布在不同的系統(tǒng)，即使設(shè)置相同的分區(qū)鍵，不同生產(chǎn)者之間產(chǎn)生的消息也無(wú)法判定其先后順序。
• 串行發(fā)送：生產(chǎn)者客戶端支持多線程安全訪問(wèn)，但如果生產(chǎn)者使用多線程并行發(fā)送，則不同線程間產(chǎn)生的消息將無(wú)法判定其先后順序。

滿足以上條件的生產(chǎn)者，將 「順序消息」 發(fā)送至服務(wù)端后，會(huì)保證設(shè)置了同一分區(qū)鍵的消息，按照發(fā)送順序存儲(chǔ)在同一隊(duì)列中。Xe228資訊網(wǎng)——每日最新資訊28at.com

局部有序（分區(qū)有序）Xe228資訊網(wǎng)——每日最新資訊28at.com

注意，在RocketMQ 5.x版本中，新增了「消息組」概念，順序消息發(fā)送必須要設(shè)置消息組。Xe228資訊網(wǎng)——每日最新資訊28at.com

保證「消息消費(fèi)」的順序性，則必須滿足以下條件：Xe228資訊網(wǎng)——每日最新資訊28at.com

• 語(yǔ)義正確。業(yè)務(wù)方消費(fèi)消息時(shí)需要嚴(yán)格按照 接收---處理---應(yīng)答 的語(yǔ)義處理消息，避免因異步處理導(dǎo)致消息亂序。
• 有限重試。順序消息消費(fèi)投遞次數(shù)限定有限范圍內(nèi)，即一條消息如果超過(guò)最大重試次數(shù)后，將跳過(guò)這條消息消費(fèi)，不會(huì)一直阻塞后續(xù)消息處理。

對(duì)于需要嚴(yán)格保證消費(fèi)順序的場(chǎng)景，請(qǐng)務(wù)必設(shè)置合理的重試次數(shù)，避免參數(shù)不合理導(dǎo)致消息亂序。Xe228資訊網(wǎng)——每日最新資訊28at.com

Q3:如果Broker掉線，局部有序還能保持有序嗎？

如果一個(gè)Broker掉線，那么此時(shí)隊(duì)列總數(shù)是否會(huì)發(fā)化？Xe228資訊網(wǎng)——每日最新資訊28at.com

如果發(fā)生變化，那么同一個(gè) ShardingKey 的消息就會(huì)發(fā)送到不同的隊(duì)列上，造成亂序。Xe228資訊網(wǎng)——每日最新資訊28at.com

如果不發(fā)生變化，那消息將會(huì)發(fā)送到掉線Broker的隊(duì)列上，必然是失敗的。Xe228資訊網(wǎng)——每日最新資訊28at.com

因此 Apache RocketMQ 提供了兩種模式，如果要保證嚴(yán)格順序而不是可用性，創(chuàng)建 Topic 是要指定 -o 參數(shù)（--order）為true，表示順序消息:Xe228資訊網(wǎng)——每日最新資訊28at.com

$ sh bin/mqadmin updateTopic -c DefaultCluster -t TopicTest -o true -n 127.0.0.1:9876create topic to 127.0.0.1:10911 success.TopicConfig [topicName=TopicTest, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=true, attributes=null]

其次，要保證NameServer中的配置 orderMessageEnable 和 returnOrderTopicConfigToBroker 必須是 true。Xe228資訊網(wǎng)——每日最新資訊28at.com

如果上述任意一個(gè)條件不滿足，則是保證可用性而不是嚴(yán)格順序。Xe228資訊網(wǎng)——每日最新資訊28at.com

Q4: 順序消息有哪些限制？

同一條消息是否可以既是順序消息，又是定時(shí)消息和事務(wù)消息？Xe228資訊網(wǎng)——每日最新資訊28at.com

不可以。順序消息、定時(shí)消息、事務(wù)消息是不同的消息類型，三者是互斥關(guān)系，不能疊加在一起使用。Xe228資訊網(wǎng)——每日最新資訊28at.com

為什么全局順序消息性能一般？Xe228資訊網(wǎng)——每日最新資訊28at.com

全局順序消息是嚴(yán)格按照FIFO的消息阻塞原則，即上一條消息沒(méi)有被成功消費(fèi)，那么下一條消息會(huì)一直被存儲(chǔ)到Topic隊(duì)列中。Xe228資訊網(wǎng)——每日最新資訊28at.com

關(guān)鍵字總結(jié)

• 全局有序：必須控制Topic只有一個(gè)隊(duì)列queue，才能實(shí)現(xiàn)全局有序，性能一般。
• 局部有序：性能較好，需要確保「生產(chǎn)有序」和「消費(fèi)有序」，同時(shí)注意Broker掉線時(shí)的 可用性 與 有序性 權(quán)衡。

本文鏈接：http://www.www897cc.com/showinfo-26-10904-0.html三分鐘白話RocketMQ系列—— 如何保證消息順序性

聲明：本網(wǎng)頁(yè)內(nèi)容旨在傳播知識(shí)，若有侵權(quán)等問(wèn)題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com

上一篇： 實(shí)用！Python數(shù)據(jù)去重與唯一值提取：高效整理數(shù)據(jù)

下一篇： 什么是 Merge Queue，為什么要使用它？