www.久久久久|狼友网站av天堂|精品国产无码a片|一级av色欲av|91在线播放视频|亚洲无码主播在线|国产精品草久在线|明星AV网站在线|污污内射久久一区|婷婷综合视频网站

當(dāng)前位置:首頁 > 公眾號精選 > 架構(gòu)師社區(qū)
[導(dǎo)讀]我們的支付場景下,要求消費的業(yè)務(wù)消息絕不能丟失,且能充分利用高規(guī)格的服務(wù)器的性能,比如用線程池對業(yè)務(wù)消息進(jìn)行快速處理。

背景

我們的支付場景下,要求消費的業(yè)務(wù)消息絕不能丟失,且能充分利用高規(guī)格的服務(wù)器的性能,比如用線程池對業(yè)務(wù)消息進(jìn)行快速處理。有同學(xué)可能沒太理解這個問題有啥不好處理,讓我一步步分析下。

MQ的優(yōu)勢和缺點

MQ是我們在應(yīng)對高并發(fā)場景最常用的一種措施,它可以幫我們對業(yè)務(wù)解耦、對流程異步化以及削峰填谷的妙用。

但是,由于引入了這一額外的中間件,也增加了系統(tǒng)的復(fù)雜度和不穩(wěn)定因素。

消息可靠性的應(yīng)對

消息的可靠性保證需要從消息流轉(zhuǎn)的每個環(huán)節(jié)進(jìn)行保障,比如生產(chǎn)端的事務(wù)型消息,broker的實時刷盤持久化,消費端的手動ACK 。

這里,我們對生產(chǎn)端和存儲端的保障措施不作討論,重點關(guān)注消費端的手動ACK機制。

手動ACK的問題

手動ACK可以保證消息一定被消費,但是需要確保手動ACK的順序和消息順序一致,為什么?

消息隊列之所以性能高處理快,是因為采用了文件順序讀寫方式,系統(tǒng)在拉取消息進(jìn)行消費時,是按順序文件的offset進(jìn)行拉取的,如果commit offset的順序錯亂,會使得服務(wù)端的消息狀態(tài)錯亂,比如消息重發(fā)。

因此,如果我們在本地啟動了線程池,對消息進(jìn)行拉取處理,由于各線程的處理速度不一定一致,所以無法保證各線程處理完之后對各自消息的ACK操作是順序的,怎么辦,難道只能同步拉消費取然后ACK么。

解決方案

最不濟,可以提交一批任務(wù),批量等待統(tǒng)一提交。不過總覺得不優(yōu)雅。

某次看JUC中的AQS的時候,啟發(fā)了我。

我們平時用的類似CountDownLauch這些并發(fā)工具類,不也是處理的多線程協(xié)作的問題么。

我們的場景完全沒有AQS復(fù)雜,借鑒它的思路,應(yīng)該是沒有問題的。

  1. 創(chuàng)建雙端隊列,隊列節(jié)點中需要維護(hù)自身處理狀態(tài)state,和對應(yīng)msg的offset。
  2. 服務(wù)從消息中心拉取消息,在提交本地線程池執(zhí)行之前,先入隊列。
  3. 消息消費完之后,通知隊列中對應(yīng)的節(jié)點,更新狀態(tài)為完成。
  4. 隊列頭被更新后出隊列,提交offset,并判斷新的隊列頭的狀態(tài),直到遇到state是未完成的head時阻塞。undefined

方案解析

該方案可以有效利用本地線程的資源,并行的處理,并通過隊列和異步通知機制保證最終commit offset時有序。

在最差情況下(即head節(jié)點對應(yīng)的msg最后一個被處理完),相當(dāng)于等待一批線程處理完成后統(tǒng)一提交。除此之外等待性能都要更優(yōu)。

異步通知的實現(xiàn)

public class MSGFuture { /*全局變量,存放msg對應(yīng)的future對象*/ private static final Map FUTURES = new ConcurrentHashMap(); /*全局不變唯一標(biāo)識*/ private final long id; /*最長等待時間*/ private final int timeout; /*并發(fā)鎖*/ private final Lock lock = new ReentrantLock(); /*通知條件*/ private final Condition done = lock.newCondition(); /*開始時間*/ private final long start = System.currentTimeMillis(); /*業(yè)務(wù)結(jié)果*/ private volatile Object response;
}
//構(gòu)造函數(shù) public MSGFuture(Request request, int timeout) { /*全局自增ID*/ this.id = request.getrId(); /*超時時間*/ this.timeout = timeout > 0 ? timeout : 1000; /*放入全局變量*/ FUTURES.put(id, this);
}
//業(yè)務(wù)處理結(jié)果更新 public static void received(long id, Object response) {

        MSGFuture future = FUTURES.remove(id); if (future != null) {
            future.doReceived(response);
        } else {
            logger.warn("response return timeout,id:"+id);
        }

    }
//結(jié)果更新,通知等待條件 private void doReceived(Object res) {
        lock.lock(); try {
            response = res;
            done.signal();
        } finally {
            lock.unlock();
        }
    }
//異步等待獲取結(jié)果 public Object get(int timeout) throws TimeoutException { if (!isDone()) { long start = System.currentTimeMillis();
            lock.lock(); try { while (!isDone()) {
                    done.await(timeout, TimeUnit.MILLISECONDS); if (isDone() || System.currentTimeMillis() - start > timeout) { break;
                    }
                }
            } catch (InterruptedException e) { throw new RuntimeException(e);
            } finally {
                lock.unlock();
            } if (!isDone()) { throw new TimeoutException();
            }
        } return returnFromResponse();
    }

總結(jié)

看到這里,有同學(xué)會說,這個和AQS有啥關(guān)系呀~

其實,只是處理思路的一種借鑒,比如state狀態(tài),比如鎖機制和通知等待。既然都是多線程任務(wù)協(xié)調(diào),那總有相似之處。

總之一句話,別說背八股文沒用,多多了解會有大幫助~


免責(zé)聲明:本文內(nèi)容由21ic獲得授權(quán)后發(fā)布,版權(quán)歸原作者所有,本平臺僅提供信息存儲服務(wù)。文章僅代表作者個人觀點,不代表本平臺立場,如有問題,請聯(lián)系我們,謝謝!

本站聲明: 本文章由作者或相關(guān)機構(gòu)授權(quán)發(fā)布,目的在于傳遞更多信息,并不代表本站贊同其觀點,本站亦不保證或承諾內(nèi)容真實性等。需要轉(zhuǎn)載請聯(lián)系該專欄作者,如若文章內(nèi)容侵犯您的權(quán)益,請及時聯(lián)系本站刪除。
換一批
延伸閱讀

9月2日消息,不造車的華為或?qū)⒋呱龈蟮莫毥谦F公司,隨著阿維塔和賽力斯的入局,華為引望愈發(fā)顯得引人矚目。

關(guān)鍵字: 阿維塔 塞力斯 華為

加利福尼亞州圣克拉拉縣2024年8月30日 /美通社/ -- 數(shù)字化轉(zhuǎn)型技術(shù)解決方案公司Trianz今天宣布,該公司與Amazon Web Services (AWS)簽訂了...

關(guān)鍵字: AWS AN BSP 數(shù)字化

倫敦2024年8月29日 /美通社/ -- 英國汽車技術(shù)公司SODA.Auto推出其旗艦產(chǎn)品SODA V,這是全球首款涵蓋汽車工程師從創(chuàng)意到認(rèn)證的所有需求的工具,可用于創(chuàng)建軟件定義汽車。 SODA V工具的開發(fā)耗時1.5...

關(guān)鍵字: 汽車 人工智能 智能驅(qū)動 BSP

北京2024年8月28日 /美通社/ -- 越來越多用戶希望企業(yè)業(yè)務(wù)能7×24不間斷運行,同時企業(yè)卻面臨越來越多業(yè)務(wù)中斷的風(fēng)險,如企業(yè)系統(tǒng)復(fù)雜性的增加,頻繁的功能更新和發(fā)布等。如何確保業(yè)務(wù)連續(xù)性,提升韌性,成...

關(guān)鍵字: 亞馬遜 解密 控制平面 BSP

8月30日消息,據(jù)媒體報道,騰訊和網(wǎng)易近期正在縮減他們對日本游戲市場的投資。

關(guān)鍵字: 騰訊 編碼器 CPU

8月28日消息,今天上午,2024中國國際大數(shù)據(jù)產(chǎn)業(yè)博覽會開幕式在貴陽舉行,華為董事、質(zhì)量流程IT總裁陶景文發(fā)表了演講。

關(guān)鍵字: 華為 12nm EDA 半導(dǎo)體

8月28日消息,在2024中國國際大數(shù)據(jù)產(chǎn)業(yè)博覽會上,華為常務(wù)董事、華為云CEO張平安發(fā)表演講稱,數(shù)字世界的話語權(quán)最終是由生態(tài)的繁榮決定的。

關(guān)鍵字: 華為 12nm 手機 衛(wèi)星通信

要點: 有效應(yīng)對環(huán)境變化,經(jīng)營業(yè)績穩(wěn)中有升 落實提質(zhì)增效舉措,毛利潤率延續(xù)升勢 戰(zhàn)略布局成效顯著,戰(zhàn)新業(yè)務(wù)引領(lǐng)增長 以科技創(chuàng)新為引領(lǐng),提升企業(yè)核心競爭力 堅持高質(zhì)量發(fā)展策略,塑強核心競爭優(yōu)勢...

關(guān)鍵字: 通信 BSP 電信運營商 數(shù)字經(jīng)濟

北京2024年8月27日 /美通社/ -- 8月21日,由中央廣播電視總臺與中國電影電視技術(shù)學(xué)會聯(lián)合牽頭組建的NVI技術(shù)創(chuàng)新聯(lián)盟在BIRTV2024超高清全產(chǎn)業(yè)鏈發(fā)展研討會上宣布正式成立。 活動現(xiàn)場 NVI技術(shù)創(chuàng)新聯(lián)...

關(guān)鍵字: VI 傳輸協(xié)議 音頻 BSP

北京2024年8月27日 /美通社/ -- 在8月23日舉辦的2024年長三角生態(tài)綠色一體化發(fā)展示范區(qū)聯(lián)合招商會上,軟通動力信息技術(shù)(集團(tuán))股份有限公司(以下簡稱"軟通動力")與長三角投資(上海)有限...

關(guān)鍵字: BSP 信息技術(shù)
關(guān)閉
關(guān)閉