spring boot高并發(fā)下耗時(shí)操作的實(shí)現(xiàn)方法
高并發(fā)下的耗時(shí)操作
高并發(fā)下,就是請求在一個(gè)時(shí)間點(diǎn)比較多時(shí),很多寫的請求打過來時(shí),你的服務(wù)器承受很大的壓力,當(dāng)你的一個(gè)請求處理時(shí)間長時(shí),這些請求將會(huì)把你的服務(wù)器線程耗盡,即你的主線程池里的線程將不會(huì)再有空閑狀態(tài)的,再打過來的請求,將會(huì)是502了。
請求流程圖
http1 http2 http3 thread1 thread2 thread3
解決方案
使用DeferredResult來實(shí)現(xiàn)異步的操作,當(dāng)一個(gè)請求打過來時(shí),先把它放到一個(gè)隊(duì)列時(shí),然后在后臺有一個(gè)訂閱者,有相關(guān)主題的消息發(fā)過來時(shí),這個(gè)訂閱者就去消費(fèi)它,這一步可以是分布式的,比如一個(gè)秒殺場景,當(dāng)N多的請求打過來時(shí),有一些請求命中后,它們進(jìn)行寫操作,這時(shí)寫操作壓力很大,1個(gè)請求可以要處理3秒,對于高并發(fā)場景這是不能容許的,因?yàn)槟氵@樣占用的服務(wù)器線程資源太長了,很快你的服務(wù)器就沒有可用的線程資源了,這時(shí)就可以用到DeferredResult這處理。
代碼實(shí)現(xiàn)
建立訂單的接口,只負(fù)責(zé)簡單的校驗(yàn)和事件的發(fā)布
/** * 異步建立高并發(fā)的訂單. * * @return */ @GetMapping("/create-order") public DeferredResult<Object> createOrder() { DeferredResult<Object> deferredResult = new DeferredResult<>((long) 3000, "error order"); logger.info("發(fā)布建立訂單的事件"); applicationEventPublisher.publishEvent(deferredResult); return deferredResult; }
異步的訂單處理核心邏輯,也是耗時(shí)的操作
@Component @EnableAsync public class OrderListener { static Logger logger = LoggerFactory.getLogger(OrderListener.class); /** * 事實(shí)上它是一個(gè)訂單隊(duì)列的消費(fèi)者,在后臺寫訂單,本例使用簡單的事件監(jiān)聽器實(shí)現(xiàn)異步處理的功能. * * @return */ @EventListener @Async public String processOrder(DeferredResult<Object> deferredResult) throws InterruptedException { logger.info("處理訂單并返回到對應(yīng)的Http上下文"); String order = UUID.randomUUID().toString(); Thread.sleep(2000);//假設(shè)處理數(shù)據(jù)需要5秒,前端需要阻塞5秒,但http主線程已經(jīng)釋放了,比較適合IO密集型場合 //當(dāng)設(shè)置之后,create-order將成功響應(yīng) deferredResult.setResult(order); return order; } }
測試結(jié)果
當(dāng)請求/create-order后,服務(wù)器在處理2秒后,返回結(jié)果,而spring后臺真正做的是,線程1在事件發(fā)布后,它成為空閑狀態(tài),其它請求可以復(fù)用它,當(dāng)processOrder后臺處理結(jié)果后,spring又會(huì)用線程池中拿一個(gè)新的線程處理剩下的邏輯!
總結(jié)
以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,謝謝大家對腳本之家的支持。
相關(guān)文章
jvm之java類加載機(jī)制和類加載器(ClassLoader)的用法
這篇文章主要介紹了jvm之java類加載機(jī)制和類加載器(ClassLoader)的用法,具有很好的參考價(jià)值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-09-09spring boot使用properties定義短信模板的方法教程
這篇文章主要給大家介紹了關(guān)于spring boot使用properties定義短信模板的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2018-01-01SpringBoot v2.2以上重復(fù)讀取Request Body內(nèi)容的解決方案
這篇文章主要介紹了SpringBoot v2.2以上重復(fù)讀取Request Body內(nèi)容的解決方案,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-10-10mybatis?plus框架@TableField注解不生效問題及解決方案
最近遇到一個(gè)mybatis plus的問題,@TableField注解不生效,導(dǎo)致查出來的字段反序列化后為空,今天通過本文給大家介紹下mybatis?plus框架的@TableField注解不生效問題總結(jié),需要的朋友可以參考下2022-03-03Spring Boot 2.4 對多環(huán)境配置的支持更改示例代碼
這篇文章主要介紹了Spring Boot 2.4 對多環(huán)境配置的支持更改,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-12-12springCloud gateWay 統(tǒng)一鑒權(quán)的實(shí)現(xiàn)代碼
這篇文章主要介紹了springCloud gateWay 統(tǒng)一鑒權(quán)的實(shí)現(xiàn)代碼,統(tǒng)一鑒權(quán)包括鑒權(quán)邏輯和代碼實(shí)現(xiàn),本文給大家介紹的非常詳細(xì),需要的朋友可以參考下2022-02-02