怎么在spring boot高并發(fā)下實現(xiàn)耗時操作?很多新手對此不是很清楚,為了幫助大家解決這個難題,下面小編將為大家詳細講解,有這方面需求的人可以來學習下,希望你能有所收獲。
公司專注于為企業(yè)提供成都網(wǎng)站設(shè)計、成都網(wǎng)站制作、微信公眾號開發(fā)、商城網(wǎng)站定制開發(fā),重慶小程序開發(fā),軟件按需開發(fā)網(wǎng)站等一站式互聯(lián)網(wǎng)企業(yè)服務(wù)。憑借多年豐富的經(jīng)驗,我們會仔細了解各客戶的需求而做出多方面的分析、設(shè)計、整合,為客戶設(shè)計出具風格及創(chuàng)意性的商業(yè)解決方案,創(chuàng)新互聯(lián)建站更提供一系列網(wǎng)站制作和網(wǎng)站推廣的服務(wù)。
高并發(fā)下的耗時操作
高并發(fā)下,就是請求在一個時間點比較多時,很多寫的請求打過來時,你的服務(wù)器承受很大的壓力,當你的一個請求處理時間長時,這些請求將會把你的服務(wù)器線程耗盡,即你的主線程池里的線程將不會再有空閑狀態(tài)的,再打過來的請求,將會是502了。
請求流程圖
http1 http2 http3 thread1 thread2 thread3
解決方案
使用DeferredResult來實現(xiàn)異步的操作,當一個請求打過來時,先把它放到一個隊列時,然后在后臺有一個訂閱者,有相關(guān)主題的消息發(fā)過來時,這個訂閱者就去消費它,這一步可以是分布式的,比如一個秒殺場景,當N多的請求打過來時,有一些請求命中后,它們進行寫操作,這時寫操作壓力很大,1個請求可以要處理3秒,對于高并發(fā)場景這是不能容許的,因為你這樣占用的服務(wù)器線程資源太長了,很快你的服務(wù)器就沒有可用的線程資源了,這時就可以用到DeferredResult這處理。
代碼實現(xiàn)
建立訂單的接口,只負責簡單的校驗和事件的發(fā)布
/** * 異步建立高并發(fā)的訂單. * * @return */ @GetMapping("/create-order") public DeferredResult
異步的訂單處理核心邏輯,也是耗時的操作
@Component @EnableAsync public class OrderListener { static Logger logger = LoggerFactory.getLogger(OrderListener.class); /** * 事實上它是一個訂單隊列的消費者,在后臺寫訂單,本例使用簡單的事件監(jiān)聽器實現(xiàn)異步處理的功能. * * @return */ @EventListener @Async public String processOrder(DeferredResultdeferredResult) throws InterruptedException { logger.info("處理訂單并返回到對應(yīng)的Http上下文"); String order = UUID.randomUUID().toString(); Thread.sleep(2000);//假設(shè)處理數(shù)據(jù)需要5秒,前端需要阻塞5秒,但http主線程已經(jīng)釋放了,比較適合IO密集型場合 //當設(shè)置之后,create-order將成功響應(yīng) deferredResult.setResult(order); return order; } }
看完上述內(nèi)容是否對您有幫助呢?如果還想對相關(guān)知識有進一步的了解或閱讀更多相關(guān)文章,請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝您對創(chuàng)新互聯(lián)的支持。