日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

基本概念

更新時(shí)間:

本文介紹云消息隊(duì)列 RocketMQ 版的基本概念,以便您更好地理解和使用云消息隊(duì)列 RocketMQ 版

  • 主題(Topic)

    • 云消息隊(duì)列 RocketMQ 版中消息傳輸和存儲(chǔ)的頂層容器,用于標(biāo)識(shí)同一類業(yè)務(wù)邏輯的消息。主題通過(guò)TopicName來(lái)做唯一標(biāo)識(shí)和區(qū)分。更多信息,請(qǐng)參見(jiàn)主題(Topic)

  • 消息類型(MessageType)

    • 云消息隊(duì)列 RocketMQ 版中按照消息傳輸特性的不同而定義的分類,用于類型管理和安全校驗(yàn)。云消息隊(duì)列 RocketMQ 版支持的消息類型有普通消息、順序消息、事務(wù)消息和定時(shí)/延時(shí)消息。

  • 消息隊(duì)列(MessageQueue)

    • 隊(duì)列是云消息隊(duì)列 RocketMQ 版中消息存儲(chǔ)和傳輸?shù)膶?shí)際容器,也是消息的最小存儲(chǔ)單元。云消息隊(duì)列 RocketMQ 版的所有主題都是由多個(gè)隊(duì)列組成,以此實(shí)現(xiàn)隊(duì)列數(shù)量的水平拆分和隊(duì)列內(nèi)部的流式存儲(chǔ)。隊(duì)列通過(guò)QueueId來(lái)做唯一標(biāo)識(shí)和區(qū)分。更多信息,請(qǐng)參見(jiàn)隊(duì)列(MessageQueue)

  • 消息(Message)

    • 消息是云消息隊(duì)列 RocketMQ 版中的最小數(shù)據(jù)傳輸單元。生產(chǎn)者將業(yè)務(wù)數(shù)據(jù)的負(fù)載和拓展屬性包裝成消息發(fā)送到云消息隊(duì)列 RocketMQ 版服務(wù)端,服務(wù)端按照相關(guān)語(yǔ)義將消息投遞到消費(fèi)端進(jìn)行消費(fèi)。更多信息,請(qǐng)參見(jiàn)消息(Message)

  • 消息視圖(MessageView)

    • 消息視圖是云消息隊(duì)列 RocketMQ 版面向開(kāi)發(fā)視角提供的一種消息只讀接口。通過(guò)消息視圖可以讀取消息內(nèi)部的多個(gè)屬性和負(fù)載信息,但是不能對(duì)消息本身做任何修改。

  • 消息標(biāo)簽(MessageTag)

    • 消息標(biāo)簽是云消息隊(duì)列 RocketMQ 版提供的細(xì)粒度消息分類屬性,可以在主題層級(jí)之下做消息類型的細(xì)分。消費(fèi)者通過(guò)訂閱特定的標(biāo)簽來(lái)實(shí)現(xiàn)細(xì)粒度過(guò)濾。更多信息,請(qǐng)參見(jiàn)消息過(guò)濾

  • 消息位點(diǎn)(MessageQueueOffset)

    • 消息是按到達(dá)云消息隊(duì)列 RocketMQ 版服務(wù)端的先后順序存儲(chǔ)在指定主題的多個(gè)隊(duì)列中,每條消息在隊(duì)列中都有一個(gè)唯一的Long類型坐標(biāo),這個(gè)坐標(biāo)被定義為消息位點(diǎn)。更多信息,請(qǐng)參見(jiàn)消費(fèi)進(jìn)度管理

  • 消費(fèi)位點(diǎn)(ConsumerOffset)

    • 一條消息被某個(gè)消費(fèi)者消費(fèi)完成后不會(huì)立即從隊(duì)列中刪除,云消息隊(duì)列 RocketMQ 版會(huì)基于每個(gè)消費(fèi)者分組記錄消費(fèi)過(guò)的最新一條消息的位點(diǎn),即消費(fèi)位點(diǎn)。更多信息,請(qǐng)參見(jiàn)消費(fèi)進(jìn)度管理

  • 消息索引(MessageKey)

    • 消息索引是云消息隊(duì)列 RocketMQ 版提供的面向消息的索引屬性。通過(guò)設(shè)置的消息索引可以快速查找到對(duì)應(yīng)的消息內(nèi)容。

  • 生產(chǎn)者(Producer)

    • 生產(chǎn)者是云消息隊(duì)列 RocketMQ 版系統(tǒng)中用來(lái)構(gòu)建并傳輸消息到服務(wù)端的運(yùn)行實(shí)體。生產(chǎn)者通常被集成在業(yè)務(wù)系統(tǒng)中,將業(yè)務(wù)消息按照要求封裝成云消息隊(duì)列 RocketMQ 版的消息并發(fā)送至服務(wù)端。更多信息,請(qǐng)參見(jiàn)生產(chǎn)者(Producer)

  • 事務(wù)檢查器(TransactionChecker)

    • 云消息隊(duì)列 RocketMQ 版中生產(chǎn)者用來(lái)執(zhí)行本地事務(wù)檢查和異常事務(wù)恢復(fù)的監(jiān)聽(tīng)器。事務(wù)檢查器應(yīng)該通過(guò)業(yè)務(wù)側(cè)數(shù)據(jù)的狀態(tài)來(lái)檢查和判斷事務(wù)消息的狀態(tài)。更多信息,請(qǐng)參見(jiàn)事務(wù)消息

  • 事務(wù)狀態(tài)(TransactionResolution)

    • 云消息隊(duì)列 RocketMQ 版中事務(wù)消息發(fā)送過(guò)程中,事務(wù)提交的狀態(tài)標(biāo)識(shí),服務(wù)端通過(guò)事務(wù)狀態(tài)控制事務(wù)消息是否應(yīng)該提交和投遞。事務(wù)狀態(tài)包括事務(wù)提交、事務(wù)回滾和事務(wù)未決。更多信息,請(qǐng)參見(jiàn)事務(wù)消息

  • 消費(fèi)者分組(ConsumerGroup)

    • 消費(fèi)者分組是云消息隊(duì)列 RocketMQ 版系統(tǒng)中承載多個(gè)消費(fèi)行為一致的消費(fèi)者的負(fù)載均衡分組。和消費(fèi)者不同,消費(fèi)者分組并不是運(yùn)行實(shí)體,而是一個(gè)邏輯資源。在云消息隊(duì)列 RocketMQ 版中,通過(guò)消費(fèi)者分組內(nèi)初始化多個(gè)消費(fèi)者實(shí)現(xiàn)消費(fèi)性能的水平擴(kuò)展以及高可用容災(zāi)。更多信息,請(qǐng)參見(jiàn)消費(fèi)者分組(ConsumerGroup)

  • 消費(fèi)者(Consumer)

    • 消費(fèi)者是云消息隊(duì)列 RocketMQ 版中用來(lái)接收并處理消息的運(yùn)行實(shí)體。消費(fèi)者通常被集成在業(yè)務(wù)系統(tǒng)中,從云消息隊(duì)列 RocketMQ 版服務(wù)端獲取消息,并將消息轉(zhuǎn)化成業(yè)務(wù)可理解的信息,供業(yè)務(wù)邏輯處理。更多信息,請(qǐng)參見(jiàn)消費(fèi)者(Consumer)

  • 消費(fèi)結(jié)果(ConsumeResult)

    • 云消息隊(duì)列 RocketMQ 版中PushConsumer消費(fèi)監(jiān)聽(tīng)器處理消息完成后返回的處理結(jié)果,用來(lái)標(biāo)識(shí)本次消息是否正確處理。消費(fèi)結(jié)果包含消費(fèi)成功和消費(fèi)失敗。

  • 訂閱關(guān)系(Subscription)

    • 訂閱關(guān)系是云消息隊(duì)列 RocketMQ 版系統(tǒng)中消費(fèi)者獲取消息、處理消息的規(guī)則和狀態(tài)配置。訂閱關(guān)系由消費(fèi)者分組動(dòng)態(tài)注冊(cè)到服務(wù)端系統(tǒng),并在后續(xù)的消息傳輸中按照訂閱關(guān)系定義的過(guò)濾規(guī)則進(jìn)行消息匹配和消費(fèi)進(jìn)度維護(hù)。更多信息,請(qǐng)參見(jiàn)訂閱關(guān)系(Subscription)

  • 消息過(guò)濾

    • 消費(fèi)者可以通過(guò)訂閱指定消息標(biāo)簽(Tag)對(duì)消息進(jìn)行過(guò)濾,確保最終只接收被過(guò)濾后的消息合集。過(guò)濾規(guī)則的計(jì)算和匹配在云消息隊(duì)列 RocketMQ 版的服務(wù)端完成。更多信息,請(qǐng)參見(jiàn)消息過(guò)濾

  • 重置消費(fèi)位點(diǎn)

    • 以時(shí)間軸為坐標(biāo),在消息持久化存儲(chǔ)的時(shí)間范圍內(nèi),重新設(shè)置消費(fèi)者分組對(duì)已訂閱主題的消費(fèi)進(jìn)度,設(shè)置完成后消費(fèi)者將接收設(shè)定時(shí)間點(diǎn)之后,由生產(chǎn)者發(fā)送到云消息隊(duì)列 RocketMQ 版服務(wù)端的消息。更多信息,請(qǐng)參見(jiàn)重置消費(fèi)位點(diǎn)

  • 消息軌跡

    • 在一條消息從生產(chǎn)者發(fā)出到消費(fèi)者接收并處理過(guò)程中,由各個(gè)相關(guān)節(jié)點(diǎn)的時(shí)間、地點(diǎn)等數(shù)據(jù)匯聚而成的完整鏈路信息。通過(guò)消息軌跡,您能清晰定位消息從生產(chǎn)者發(fā)出,經(jīng)由云消息隊(duì)列 RocketMQ 版服務(wù)端,投遞給消費(fèi)者的完整鏈路,方便定位排查問(wèn)題。

  • 消息堆積

    • 生產(chǎn)者已經(jīng)將消息發(fā)送到云消息隊(duì)列 RocketMQ 版的服務(wù)端,但由于消費(fèi)者的消費(fèi)能力有限,未能在短時(shí)間內(nèi)將所有消息正確消費(fèi)掉,此時(shí)在云消息隊(duì)列 RocketMQ 版的服務(wù)端保存著未被消費(fèi)的消息,該狀態(tài)即消息堆積。

  • 事務(wù)消息

    • 事務(wù)消息是云消息隊(duì)列 RocketMQ 版提供的一種高級(jí)消息類型,支持在分布式場(chǎng)景下保障消息生產(chǎn)和本地事務(wù)的最終一致性。

  • 定時(shí)/延時(shí)消息

    • 定時(shí)/延時(shí)消息是云消息隊(duì)列 RocketMQ 版提供的一種高級(jí)消息類型,消息被發(fā)送至服務(wù)端后,在指定時(shí)間后才能被消費(fèi)者消費(fèi)。通過(guò)設(shè)置一定的定時(shí)時(shí)間可以實(shí)現(xiàn)分布式場(chǎng)景的延時(shí)調(diào)度觸發(fā)效果。

  • 順序消息

    • 順序消息是云消息隊(duì)列 RocketMQ 版提供的一種高級(jí)消息類型,支持消費(fèi)者按照發(fā)送消息的先后順序獲取消息,從而實(shí)現(xiàn)業(yè)務(wù)場(chǎng)景中的順序處理。