AVt天堂网 手机版,亚洲va久久久噜噜噜久久4399,天天综合亚洲色在线精品,亚洲一级Av无码毛片久久精品

當前位置:首頁 > 科技  > 軟件

聽說異步和解耦才是消息隊列最有價值的功能

來源: 責編: 時間:2024-07-11 09:29:15 704觀看
導讀消息隊列作為互聯網互聯網項目的一個可選中間件,被很多的項目、產品采用。就算你沒用過,肯定也多少了解一些,因為它是現代面試八股文必考科目之一。消息隊列這個很形象,就是把消息推到一個隊列中,然后再到這個隊列里讀,是不

消息隊列作為互聯網互聯網項目的一個可選中間件,被很多的項目、產品采用。就算你沒用過,肯定也多少了解一些,因為它是現代面試八股文必考科目之一。R3e28資訊網——每日最新資訊28at.com

消息隊列這個很形象,就是把消息推到一個隊列中,然后再到這個隊列里讀,是不是就這么簡單。R3e28資訊網——每日最新資訊28at.com

圖片圖片R3e28資訊網——每日最新資訊28at.com

聽說消息隊列最有用的功能是異步和解耦,而什么消峰填谷、分布式事務都是錦上添花而已。R3e28資訊網——每日最新資訊28at.com

常用的消息隊列

RocketMQ

RocketMQ 是阿里巴巴開發,現在已經是 Apache 軟件基金會的頂級項目。RocketMQ 是用 Java 開發,很多使用 Java 技術棧的公司都用 RocketMQ 作為消息隊列。我們就主要使用 RocketMQ 作為消息隊列服務。R3e28資訊網——每日最新資訊28at.com

RabbitMQ

RabbitMQ 是一個開源的消息代理軟件,它采用了高級消息隊列協議(AMQP),用于在分布式系統中實現異步通信和消息傳遞,采用 Erlang 語言開發。最開始學習消息隊列就是用的 RabbitMQ。R3e28資訊網——每日最新資訊28at.com

Apache Kafka

pache Kafka 是一個分布式流處理平臺,最初由 LinkedIn 開發,并于2011年開源,之后成為 Apache 軟件基金會的頂級項目。Kafka 旨在處理實時數據流,具有高吞吐量、低延遲和高可靠性的特點,廣泛應用于日志收集、流處理、數據集成等場景。R3e28資訊網——每日最新資訊28at.com

ActiveMQ

Apache ActiveMQ 是一個開源的消息代理和集成模式服務器,由 Apache 軟件基金會開發。ActiveMQ 在形式上和 RabbitMQ 比較像,ActiveMQ 也是用 Java 開發的。R3e28資訊網——每日最新資訊28at.com

除此之外,其實 Redis 也可以做消息隊列。R3e28資訊網——每日最新資訊28at.com

消息隊列的應用場景

消息隊列最厲害的地方并不是采用的技術有多厲害,而是它的應用場景,只要把它加到某些應用場景中,有很多問題都可以迎刃而解。所以說,它厲害在思想上。R3e28資訊網——每日最新資訊28at.com

異步處理和解耦

說到異步就離不開解耦,說到解耦又脫離不了異步。R3e28資訊網——每日最新資訊28at.com

什么是異步呢?假設有個系統需要處理一個長流程,最常見的例子就是下單場景,用戶下單購買商品,后臺服務要在這個下單行為發生后做一系列的事情,要減庫存、加到用戶已購買列表中、發通知、跟蹤訂單進度等。R3e28資訊網——每日最新資訊28at.com

這一系列的動作如果全都同步來做,那響應時間會比較久,而且一旦其中某個環節失敗,將會更加麻煩。R3e28資訊網——每日最新資訊28at.com

所以針對類似的場景,就有了異步處理的思路,在同步響應中只把最重要的動作完成,剩下的都可以異步處理,比如購買行為,收錢和減庫存是最重要的,這兩個成功了就算是購買成功了,剩下的通知、跟蹤進度都可以稍后進行,也就是異步處理。R3e28資訊網——每日最新資訊28at.com

說到此,解耦也就出現了,收錢和減庫存可以是一個線程來做,或者一個單獨的服務來做,發通知又可以是另一個線程或者另一個服務來做,這樣一來,兩個動作、兩個功能就解耦了,發通知的服務掛了不會影響真正的購買行為,而等到發通知服務啟動后,可以再處理歷史數據也沒問題。R3e28資訊網——每日最新資訊28at.com

這個場景下,用到消息隊列再合適不過。而且聽說,這個場景才是消息隊列有價值的地方,也是消息隊列思想的靈魂所在。R3e28資訊網——每日最新資訊28at.com

流量削峰

流量削峰是在高并發情況下,通過消息隊列將大量請求排隊處理,避免系統在短時間內被大量請求壓垮。R3e28資訊網——每日最新資訊28at.com

假設一個系統本來日常只支持1萬并發,但是某個時候突然有大量的用戶進來,流量超過了系統所能承受的最大值,如果不加以控制,那等待系統的只有崩潰。R3e28資訊網——每日最新資訊28at.com

這種情況下,系統可以將處理不了的請求暫時放到消息隊列中,然后在系統所能支持的并發下依次處理隊列中的請求。這樣一來,系統既不會崩潰,也能將請求都一一處理掉。R3e28資訊網——每日最新資訊28at.com

當然了,如果沒有消息隊列,本身系統也可以采取其他的處理措施,比如直接將請求丟棄,或者返回一個固定值。比如某些搶購場景,本來就有數量限制,只有最先進來的請求才能搶到,后面不管再進來多少都搶不到,那后面多余的請求就沒必要處理。R3e28資訊網——每日最新資訊28at.com

日志處理

很多公司都有專門的日志查看平臺,例如 Kibana,公司內所有項目都會歸集到統一的地方,通過界面點點按鈕就能看到不同項目的日志了。R3e28資訊網——每日最新資訊28at.com

這背后的原理就是將用戶行為日志發送到消息隊列,再由專門的日志處理服務進行分析和處理。自從 Kafka 一出來,再用消息隊列傳輸日志就好像被它壟斷了。沒辦法,誰讓人家在這方面有特長呢。R3e28資訊網——每日最新資訊28at.com

分布式事務

分布式事務通俗來說就是要么都成功,要么都不成功。R3e28資訊網——每日最新資訊28at.com

還是拿訂單系統為例,在訂單創建后,通過消息隊列通知庫存系統進行庫存扣減,以保證數據的一致性。R3e28資訊網——每日最新資訊28at.com

下圖是 RocketMQ 中關于分布式事務的流程圖,我們之前的項目中一直用這種方式做分布式事務處理。R3e28資訊網——每日最新資訊28at.com

圖片圖片R3e28資訊網——每日最新資訊28at.com

這是有些消息隊列本身支持的特性,只有本地事務完全成功執行后,才會最終投遞消息,否則消費者是看不到這個消息的。R3e28資訊網——每日最新資訊28at.com

延時任務

比如我們在 12306買票,預訂后鎖票,有30分鐘時間用來付款,這30分鐘內,其他人是沒辦法看到這張票的。如果30分鐘內未付款,那這張票就不屬于你了。R3e28資訊網——每日最新資訊28at.com

這種場景就是延時任務的經典場景,每一個預訂都會有自己的一個任務,這種任務和系統定時在某時某刻的定時任務是完全不一樣的。R3e28資訊網——每日最新資訊28at.com

就是因為每一個預訂都有一個任務,總不能來一個任務就給系統加一個定時任務吧,這不現實。所以這種場景下,用延時隊列就最合適了,有些消息隊列是支持的。R3e28資訊網——每日最新資訊28at.com

在消息生產者投遞消息時,給消息一個延遲時間,只有到了規定的延遲時間后,這個消息才能被消費者消費掉。R3e28資訊網——每日最新資訊28at.com

最后

消息隊列最厲害的地方在于它的思想,而不在于它使用的具體技術。R3e28資訊網——每日最新資訊28at.com

消息隊列的應用場景眾多,但是這么多應用場景中我覺得異步和解耦才是最重要的能力,你覺得呢?R3e28資訊網——每日最新資訊28at.com

本文鏈接:http://www.tebozhan.com/showinfo-26-100337-0.html聽說異步和解耦才是消息隊列最有價值的功能

聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com

上一篇: 介紹 11 個常用的 C++ 代碼

下一篇: 三星 Galaxy Z Flip6 亮相:AI 助力大視野智能外屏,重塑移動生活體驗

標簽:
  • 熱門焦點
Top