精品国产人成在线_亚洲高清无码在线观看_国产在线视频国产永久2021_国产AV综合第一页一个的一区免费影院黑人_最近中文字幕MV高清在线视频

0
  • 聊天消息
  • 系統(tǒng)消息
  • 評(píng)論與回復(fù)
登錄后你可以
  • 下載海量資料
  • 學(xué)習(xí)在線課程
  • 觀看技術(shù)視頻
  • 寫文章/發(fā)帖/加入社區(qū)
會(huì)員中心
創(chuàng)作中心

完善資料讓更多小伙伴認(rèn)識(shí)你,還能領(lǐng)取20積分哦,立即完善>

3天內(nèi)不再提示

RocketMQ在業(yè)務(wù)消息場(chǎng)景的優(yōu)勢(shì)有哪些呢?

OSC開源社區(qū) ? 來源:阿里云云原生 ? 2023-08-07 11:36 ? 次閱讀

01

消息場(chǎng)景

Cloud Native

RocketMQ 5.0 是消息事件流一體的實(shí)時(shí)數(shù)據(jù)處理平臺(tái),是業(yè)務(wù)消息領(lǐng)域的事實(shí)標(biāo)準(zhǔn),很多互聯(lián)網(wǎng)公司在業(yè)務(wù)消息場(chǎng)景會(huì)使用 RocketMQ。

b78a889a-32af-11ee-9e74-dac502259ad0.png

我們反復(fù)提到的“消息、業(yè)務(wù)消息”,指的是分布式應(yīng)用解耦,是 RocketMQ 的業(yè)務(wù)基本盤。通過本文,我們將深入了解 RocketMQ 5.0 在業(yè)務(wù)消息場(chǎng)景的優(yōu)勢(shì)能力,了解為什么 RocketMQ 能夠成為業(yè)務(wù)消息領(lǐng)域的事實(shí)標(biāo)準(zhǔn)。

RocketMQ 在業(yè)務(wù)消息領(lǐng)域的經(jīng)典場(chǎng)景是應(yīng)用解耦,這也是 RocketMQ 誕生初期解決阿里電商分布式互聯(lián)網(wǎng)架構(gòu)的核心場(chǎng)景,主要承擔(dān)分布式應(yīng)用(微服務(wù))的異步集成,達(dá)到應(yīng)用解耦的效果。解耦是所有的軟件架構(gòu)最重要的追求。

分布式應(yīng)用(微服務(wù))采用同步 RPC 與異步消息的對(duì)比。比如在業(yè)務(wù)系統(tǒng)中,有三個(gè)上游應(yīng)用與 4 個(gè)下游應(yīng)用,采用同步 RPC 的方式,會(huì)有 3*4 的依賴復(fù)雜度;而采用異步消息的方式則可以化繁為簡(jiǎn),簡(jiǎn)化為 3+4 的依賴復(fù)雜度,從乘法簡(jiǎn)化為加法。

通過引入消息隊(duì)列實(shí)現(xiàn)應(yīng)用的異步集成可以獲得四大解耦優(yōu)勢(shì)。

代碼解耦 極大提升業(yè)務(wù)敏捷度。如果用同步調(diào)用的方式,每次擴(kuò)展業(yè)務(wù)邏輯都需要上游應(yīng)用顯式調(diào)用下游應(yīng)用接口,代碼直接耦合,上游應(yīng)用要做變更發(fā)布,業(yè)務(wù)迭代互相掣肘。而通過使用消息隊(duì)列擴(kuò)展新的業(yè)務(wù)邏輯,只需要增加下游應(yīng)用訂閱某個(gè) Topic,上下游應(yīng)用互相透明,業(yè)務(wù)可以保持靈活獨(dú)立快速迭代。

延遲解耦 如果使用同步調(diào)用的方式,隨著業(yè)務(wù)邏輯的增加,用戶操作的遠(yuǎn)程調(diào)用次數(shù)會(huì)越來越多,業(yè)務(wù)響應(yīng)越來越慢,性能衰減,業(yè)務(wù)發(fā)展不可持續(xù)。而使用消息隊(duì)列,無論增加多少業(yè)務(wù),上游應(yīng)用只需調(diào)用一次消息隊(duì)列的發(fā)送接口即可響應(yīng)線上用戶,延遲為常量,基本在 5ms 以內(nèi)。

可用性解耦 如果使用同步調(diào)用的方式,任何下游業(yè)務(wù)不可用都會(huì)導(dǎo)致整個(gè)鏈路失敗。該種結(jié)構(gòu)下類似于串聯(lián)電路,甚至在部分調(diào)用失敗的情況下,還會(huì)出現(xiàn)狀態(tài)不一致。而采用 RocketMQ 進(jìn)行異步集成,只要 RocketMQ 服務(wù)可用,用戶的業(yè)務(wù)操作便可用。RocketMQ 服務(wù)通過多對(duì)主備組成的 broker 集群提供,只要有一對(duì)主備可用,則整體服務(wù)可用,作為基礎(chǔ)軟件,可用性遠(yuǎn)大于普通的業(yè)務(wù)應(yīng)用,下游應(yīng)用的業(yè)務(wù)推進(jìn)都可以通過 MQ 的可靠消息投遞來達(dá)成。

流量解耦

即削峰填谷。如果采用同步調(diào)用的方式,上下游的容量必須對(duì)齊,否則會(huì)出現(xiàn)級(jí)聯(lián)不可用。容量完全對(duì)齊需要投入大量精力進(jìn)行全鏈路壓測(cè)與更多機(jī)器成本。而通過引入 RocketMQ,基于 RocketMQ 億級(jí)消息的堆積能力,對(duì)于實(shí)時(shí)性要求不高的下游業(yè)務(wù),可以盡最大努力消費(fèi),既保證了系統(tǒng)穩(wěn)定性,又降低了機(jī)器成本與研發(fā)運(yùn)維成本。

02

基礎(chǔ)特性

Cloud Native

阿里的交易應(yīng)用流程為:用戶在淘寶上下單時(shí)會(huì)調(diào)用交易應(yīng)用創(chuàng)建訂單,交易應(yīng)用將訂單落到數(shù)據(jù)庫(kù),然后生產(chǎn)一條訂單創(chuàng)建的消息到 RocketMQ,返回給終端用戶訂單創(chuàng)建成功的接口。完成的交易流程推進(jìn)則是依賴 RocketMQ 將訂單創(chuàng)建消息投遞給下游應(yīng)用,會(huì)員應(yīng)用收到訂單消息,需要給買家贈(zèng)送積分、淘金幣,觸發(fā)用戶激勵(lì)相關(guān)的業(yè)務(wù)。購(gòu)物車應(yīng)用則是負(fù)責(zé)刪除在購(gòu)物車?yán)锩娴?a target="_blank">商品,避免用戶重復(fù)購(gòu)買。同時(shí),支付系統(tǒng)與物流系統(tǒng)也都會(huì)基于訂單狀態(tài)的變更,推進(jìn)支付環(huán)節(jié)與履約環(huán)節(jié)。

b7e66dc2-32af-11ee-9e74-dac502259ad0.png

過去十年多年,阿里電商業(yè)務(wù)持續(xù)蓬勃發(fā)展,交易的下游應(yīng)用已達(dá)數(shù)百個(gè),并且還在不斷增加。基于 RocketMQ 的電商架構(gòu)極大提高了阿里電商業(yè)務(wù)的敏捷度,上游核心的交易系統(tǒng)完全無需關(guān)心哪些應(yīng)用在訂閱交易消息,交易應(yīng)用的延遲與可用性也一直保持在很高水準(zhǔn),只依賴少量的核心系統(tǒng)與 RocketMQ,不會(huì)受數(shù)百個(gè)下游應(yīng)用的影響。

交易的下游業(yè)務(wù)類型不一,有大量的業(yè)務(wù)場(chǎng)景不需要實(shí)時(shí)消費(fèi)交易數(shù)據(jù),比如物流場(chǎng)景能容忍一定的延遲。通過 RocketMQ 的億級(jí)堆積能力,極大降低了機(jī)器成本。RocketMQ 的 shared-nothing 架構(gòu)具備無限橫向擴(kuò)展的能力,已經(jīng)連續(xù) 10 年支撐了高速增長(zhǎng)的雙十一消息峰值,在幾年前達(dá)到億級(jí) TPS。

03

增強(qiáng)能力

Cloud Native

經(jīng)典場(chǎng)景下,RocketMQ 相對(duì)于其他消息隊(duì)列,擁有諸多差異化優(yōu)勢(shì)與增強(qiáng)。

首先,穩(wěn)定性方面,穩(wěn)定性交易是金融場(chǎng)景最重要的需求。RocketMQ 的穩(wěn)定性不僅限于高可用架構(gòu),而是通過全方位的產(chǎn)品能力來構(gòu)建穩(wěn)定性競(jìng)爭(zhēng)力。比如重試隊(duì)列,當(dāng)下游消費(fèi)者因?yàn)闃I(yè)務(wù)數(shù)據(jù)不 ready 或其他原因?qū)е履硹l消息消費(fèi)失敗,RocketMQ 不會(huì)因此阻塞消費(fèi),而是能將此消息加入到重試隊(duì)列,然后按時(shí)間衰減重試。如果某條消息因?yàn)槟承┮蛩亟?jīng)過十幾次重試始終無法消費(fèi)成功,則 RocketMQ 會(huì)將它轉(zhuǎn)到死信隊(duì)列,用戶可以通過其他手段來處理失敗的消息,是金融行業(yè)的剛需。

b83cfc32-32af-11ee-9e74-dac502259ad0.png

同時(shí),消費(fèi)成功后如果因?yàn)榇a bug 導(dǎo)致業(yè)務(wù)不符合預(yù)期,應(yīng)用可以對(duì)業(yè)務(wù) bug 進(jìn)行修復(fù)并重新發(fā)布,然后應(yīng)用消息回溯的功能將消息拉回到之前的時(shí)間點(diǎn),讓業(yè)務(wù)按照正確邏輯重新處理。

RocketMQ 的消費(fèi)實(shí)現(xiàn)機(jī)制采用自適應(yīng)拉模式的消費(fèi),在極端的場(chǎng)景下能夠避免消費(fèi)者被大流量打垮。同時(shí),在消費(fèi)者的 SDK 里,做了緩存本地的消息數(shù)量與消息內(nèi)存占用的閾值保護(hù),防止消費(fèi)應(yīng)用的內(nèi)存風(fēng)險(xiǎn)。

其次,RocketMQ 還具備優(yōu)秀的可觀測(cè)能力,是穩(wěn)定性的重要輔助手段。

RocketMQ 是業(yè)界第一個(gè)提供消息消息級(jí)別可觀測(cè)能力的消息隊(duì)列,每條消息都可以帶上業(yè)務(wù)主鍵,比如在交易場(chǎng)景,用戶可以將訂單 ID 作為消息的業(yè)務(wù)主鍵。當(dāng)某個(gè)訂單的業(yè)務(wù)需要排查,用戶可以基于訂單 ID 查詢?cè)摋l消息的生成時(shí)間以及消息內(nèi)容。消息的可觀測(cè)數(shù)據(jù)還能繼續(xù)下鉆,通過消息軌跡查看消息由哪臺(tái)生產(chǎn)者機(jī)器發(fā)送、由哪些消費(fèi)者機(jī)器在什么時(shí)間消費(fèi)、消費(fèi)狀態(tài)是成功或失敗等。

b892867a-32af-11ee-9e74-dac502259ad0.png

b917cc4a-32af-11ee-9e74-dac502259ad0.png

除此之外,它支持了幾十種核心的度量數(shù)據(jù),包括集群生產(chǎn)者流量分布、慢消費(fèi)者排行、消費(fèi)的平均延遲、消費(fèi)堆積數(shù)量、消費(fèi)成功率等。基于豐富的指標(biāo),用戶可以搭建更加完善的監(jiān)控報(bào)警體系來進(jìn)一步加固穩(wěn)定性。

b982c8f6-32af-11ee-9e74-dac502259ad0.png

b9be2392-32af-11ee-9e74-dac502259ad0.png

為了支撐更靈活的應(yīng)用架構(gòu),RocketMQ 在生產(chǎn)與消費(fèi)等關(guān)鍵接口提供了多種模式。

生產(chǎn)者接口RocketMQ 同時(shí)提供了同步發(fā)送接口與異步發(fā)送接口。同步發(fā)送是最常用的模式,業(yè)務(wù)流程的編排是串行的,在應(yīng)用發(fā)完消息、Broker 完成存儲(chǔ)后返回成功后,應(yīng)用再執(zhí)行下一步邏輯。然而在某些場(chǎng)景下,完成業(yè)務(wù)涉及多個(gè)遠(yuǎn)程調(diào)用,應(yīng)用為了進(jìn)一步降低延遲、提高性能,會(huì)采用全異步化的方式,并發(fā)發(fā)出遠(yuǎn)程調(diào)用(可以是多次發(fā)消息或 RPC 的組合),異步收集結(jié)果推,進(jìn)業(yè)務(wù)邏輯。

ba404ce6-32af-11ee-9e74-dac502259ad0.png

消費(fèi)者的接口方面也提供了兩種方式:

baa74e28-32af-11ee-9e74-dac502259ad0.png

監(jiān)聽器模式被動(dòng)消費(fèi) 這是目前使用最廣泛的方式,用戶無需關(guān)心客戶端何時(shí)去 Broker 拉取消息,何時(shí)向 Broker 發(fā)出消費(fèi)成功的確認(rèn),也無需維護(hù)消費(fèi)線程池、本地消息緩存等細(xì)節(jié)。只需要寫一段消息監(jiān)聽器的業(yè)務(wù)邏輯,根據(jù)業(yè)務(wù)執(zhí)行結(jié)果返回 Success 或 Failure。它屬于全托管的模式,用戶可以專注于業(yè)務(wù)邏輯的編寫,而將實(shí)現(xiàn)細(xì)節(jié)完全委托給 RocketMQ 客戶端。

主動(dòng)消費(fèi)模式

將更多的自主權(quán)交給用戶,也稱為 Simple Consumer。在該種模式下,用戶可以自己決定何時(shí)去 Broker 讀取消息、何時(shí)發(fā)起消費(fèi)確認(rèn)消息。對(duì)業(yè)務(wù)邏輯的執(zhí)行線程也有自主可控性,讀取完消息后,可以將消費(fèi)邏輯放在自定義的線程池執(zhí)行。在某些場(chǎng)景下,不同消息的處理時(shí)長(zhǎng)與優(yōu)先級(jí)會(huì)有所不同,采用 Simple Consumer 的模式,用戶可根據(jù)消息的屬性、大小做二次分發(fā),隔離到不同的業(yè)務(wù)線程池執(zhí)行處理。該模式還提供了消息粒度消費(fèi)超時(shí)時(shí)間的設(shè)定能力,針對(duì)某些消費(fèi)耗時(shí)長(zhǎng)的消息,用戶能夠調(diào)用 change Invisible Duration 接口,延長(zhǎng)消費(fèi)時(shí)間,避免超時(shí)重試。

04

總結(jié)

Cloud Native

消息經(jīng)典場(chǎng)景:應(yīng)用解耦;

bb647a52-32af-11ee-9e74-dac502259ad0.jpg

RocketMQ 基礎(chǔ)特性:發(fā)布訂閱、可靠消息、億級(jí)堆積、無限擴(kuò)展;

業(yè)務(wù)消息場(chǎng)景的增強(qiáng)能力:穩(wěn)定性、可觀測(cè)、多樣化接口。






審核編輯:劉清
聲明:本文內(nèi)容及配圖由入駐作者撰寫或者入駐合作網(wǎng)站授權(quán)轉(zhuǎn)載。文章觀點(diǎn)僅代表作者本人,不代表電子發(fā)燒友網(wǎng)立場(chǎng)。文章及其配圖僅供工程師學(xué)習(xí)之用,如有內(nèi)容侵權(quán)或者其他違規(guī)問題,請(qǐng)聯(lián)系本站處理。 舉報(bào)投訴
  • 存儲(chǔ)器
    +關(guān)注

    關(guān)注

    38

    文章

    7455

    瀏覽量

    163624
  • 衰減器
    +關(guān)注

    關(guān)注

    4

    文章

    635

    瀏覽量

    34310
  • RPC
    RPC
    +關(guān)注

    關(guān)注

    0

    文章

    111

    瀏覽量

    11515
  • TPS
    TPS
    +關(guān)注

    關(guān)注

    0

    文章

    83

    瀏覽量

    36189
  • 解耦控制
    +關(guān)注

    關(guān)注

    0

    文章

    29

    瀏覽量

    10208

原文標(biāo)題:RocketMQ在業(yè)務(wù)消息場(chǎng)景的優(yōu)勢(shì)詳解

文章出處:【微信號(hào):OSC開源社區(qū),微信公眾號(hào):OSC開源社區(qū)】歡迎添加關(guān)注!文章轉(zhuǎn)載請(qǐng)注明出處。

收藏 人收藏

    評(píng)論

    相關(guān)推薦

    LoRa?技術(shù)在業(yè)內(nèi)討論得如火如荼,究竟是何方神圣,比起傳統(tǒng)的無線通信技術(shù)又有哪些優(yōu)勢(shì)

    LoRa?技術(shù)在業(yè)內(nèi)討論得如火如荼,究竟是何方神圣,比起傳統(tǒng)的無線通信技術(shù)又有哪些優(yōu)勢(shì)?主要應(yīng)用在哪里?與NB-IoT啥區(qū)別?
    發(fā)表于 11-17 12:02

    RocketMQ入門手冊(cè)

    RocketMQ入門篇
    發(fā)表于 10-09 14:13

    Rocketmq怎么安裝

    Rocketmq 安裝步驟
    發(fā)表于 10-24 07:47

    企業(yè)如何選擇適合自己業(yè)務(wù)場(chǎng)景的視頻會(huì)議系統(tǒng)

    企業(yè)如何選擇適合自己業(yè)務(wù)場(chǎng)景的視頻會(huì)議系統(tǒng)
    發(fā)表于 02-10 06:29

    在Linux系統(tǒng)下部署RocketMQ單機(jī)實(shí)例

    server3.product沒有正確的連接到name server對(duì)于情況1,在啟動(dòng)broker的時(shí)候添加autoCreateTopicEnable=true`參數(shù)就好了。情況2可能是name
    發(fā)表于 11-11 16:29

    展望Apache RocketMQ5.0 | 談RocketMQ的過去、現(xiàn)在和未來

    。基于RocketMQ在各類場(chǎng)景下的豐富實(shí)踐,我們將互聯(lián)網(wǎng)業(yè)務(wù)對(duì)消息的需求進(jìn)行抽象,形成了一套能滿足大多數(shù)業(yè)務(wù)場(chǎng)景的標(biāo)準(zhǔn)模型,逐步發(fā)展成與廠
    發(fā)表于 08-14 16:37 ?193次閱讀

    Apache RocketMQ MQTT協(xié)議架構(gòu)模型

    rocketmq-mqtt.zip
    發(fā)表于 04-20 10:45 ?0次下載
    Apache <b class='flag-5'>RocketMQ</b> MQTT協(xié)議架構(gòu)模型

    開源軟件-RocketMQ Externals Apache RocketMQ的擴(kuò)展項(xiàng)目

    ./oschina_soft/rocketmq-externals.zip
    發(fā)表于 06-23 15:03 ?0次下載
    開源軟件-<b class='flag-5'>RocketMQ</b> Externals Apache <b class='flag-5'>RocketMQ</b>的擴(kuò)展項(xiàng)目

    RocketMQ on openEuler提供高性能消息隊(duì)列的穩(wěn)定性解決方案

    RocketMQ on openEuler,是一種將 RocketMQ 消息中間件通過容器化的方式部署在 openEuler 操作系統(tǒng)上運(yùn)行,借助 openEuler 系統(tǒng)對(duì)于 OS 緩存回收
    的頭像 發(fā)表于 06-28 10:57 ?576次閱讀
    <b class='flag-5'>RocketMQ</b> on openEuler提供高性能消息隊(duì)列的穩(wěn)定性解決方案

    聊聊RocketMQ的主從復(fù)制

    RocketMQ 主從復(fù)制是 RocketMQ 高可用機(jī)制之一,數(shù)據(jù)可以從主節(jié)點(diǎn)復(fù)制到一個(gè)或多個(gè)從節(jié)點(diǎn)。
    的頭像 發(fā)表于 07-04 09:42 ?586次閱讀
    聊聊<b class='flag-5'>RocketMQ</b>的主從復(fù)制

    RocketMQ和RabbitMQ的區(qū)別

    RocketMQ主要使用Java開發(fā),而RabbitMQ則使用Erlang語言開發(fā)。 性能:RocketMQ在性能方面更強(qiáng),具備高吞吐量和低延遲的優(yōu)勢(shì);RabbitMQ則提供了更豐富的功能和更高的靈活性。 數(shù)據(jù)持久
    的頭像 發(fā)表于 07-24 13:39 ?1.4w次閱讀

    RocketMQ生產(chǎn)者為什么需要負(fù)載均衡?

    本文分析了RocketMQ生產(chǎn)者底層的實(shí)現(xiàn),設(shè)計(jì)地方巧妙之處,值得我們學(xué)習(xí),上面是發(fā)送非順序消息的場(chǎng)景, 如果是順序消息,我們作為使用者可以指定負(fù)載均衡策略。
    的頭像 發(fā)表于 11-13 11:04 ?436次閱讀
    <b class='flag-5'>RocketMQ</b>生產(chǎn)者為什么需要負(fù)載均衡?

    磁盤中RocketMQ構(gòu)建的索引結(jié)構(gòu)

    RocketMQ 廣泛使用于各類業(yè)務(wù)場(chǎng)景中,在實(shí)際生產(chǎn)場(chǎng)景中,用戶通常會(huì)選擇消息 ID 或者特定的業(yè)務(wù) Key(例如學(xué)號(hào),訂單號(hào))來查詢和定
    的頭像 發(fā)表于 12-22 10:43 ?378次閱讀
    磁盤中<b class='flag-5'>RocketMQ</b>構(gòu)建的索引結(jié)構(gòu)

    RocketMQ協(xié)議是什么?RocketMQ協(xié)議特點(diǎn)

    RocketMQ是由阿里巴巴開發(fā)的開源分布式消息和流處理平臺(tái)。它提供可靠、可擴(kuò)展和高性能的消息傳輸和實(shí)時(shí)處理解決方案。 RocketMQ使用一種名為RocketMQ協(xié)議的通信協(xié)議。該協(xié)議旨在促進(jìn)
    的頭像 發(fā)表于 01-03 16:11 ?782次閱讀

    光通信的未來:多業(yè)務(wù)光端機(jī)的優(yōu)勢(shì)與應(yīng)用場(chǎng)景

    隨著科技的進(jìn)步和人們對(duì)信息傳輸速度需求的不斷提高,光通信作為一種高速、高效的通信方式,正逐漸成為未來通信領(lǐng)域的主流。而多業(yè)務(wù)光端機(jī),作為光通信領(lǐng)域的關(guān)鍵設(shè)備,憑借其獨(dú)特的優(yōu)勢(shì),將在未來的光通信中扮演
    的頭像 發(fā)表于 02-23 14:09 ?914次閱讀