小編給大家分享一下Springboot如何實(shí)現(xiàn)高并發(fā)下耗時(shí)操作,相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!
創(chuàng)新互聯(lián)建站于2013年開始,是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司,擁有項(xiàng)目做網(wǎng)站、成都做網(wǎng)站網(wǎng)站策劃,項(xiàng)目實(shí)施與項(xiàng)目整合能力。我們以讓每一個(gè)夢(mèng)想脫穎而出為使命,1280元龍勝做網(wǎng)站,已為上家服務(wù),為龍勝各地企業(yè)和個(gè)人服務(wù),聯(lián)系電話:13518219792
高并發(fā)下的耗時(shí)操作
高并發(fā)下,就是請(qǐng)求在一個(gè)時(shí)間點(diǎn)比較多時(shí),很多寫的請(qǐng)求打過來時(shí),你的服務(wù)器承受很大的壓力,當(dāng)你的一個(gè)請(qǐng)求處理時(shí)間長時(shí),這些請(qǐng)求將會(huì)把你的服務(wù)器線程耗盡,即你的主線程池里的線程將不會(huì)再有空閑狀態(tài)的,再打過來的請(qǐng)求,將會(huì)是502了。加q群:478052716 免費(fèi)領(lǐng)取(Java架構(gòu)資料,視頻資料,BATJ面試資料)
請(qǐng)求流程圖
http1 http2 http3 thread1 thread2 thread3
解決方案
使用 DeferredResult 來實(shí)現(xiàn)異步的操作,當(dāng)一個(gè)請(qǐng)求打過來時(shí),先把它放到一個(gè)隊(duì)列時(shí),然后在后臺(tái)有一個(gè)訂閱者,有相關(guān)主題的消息發(fā)過來時(shí),這個(gè)訂閱者就去消費(fèi)它,這一步可以是分布式的,比如一個(gè)秒殺場景,當(dāng)N多的請(qǐng)求打過來時(shí),有一些請(qǐng)求命中后,它們進(jìn)行寫操作,這時(shí)寫操作壓力很大,1個(gè)請(qǐng)求可以要處理3秒,對(duì)于高并發(fā)場景這是不能容許的,因?yàn)槟氵@樣占用的服務(wù)器線程資源太長了,很快你的服務(wù)器就沒有可用的線程資源了,這時(shí)就可以用到DeferredResult這處理。
代碼實(shí)現(xiàn)
建立訂單的接口,只負(fù)責(zé)簡單的校驗(yàn)和事件的發(fā)布
/** * 異步建立高并發(fā)的訂單. * * @return */ @GetMapping("/create-order") public DeferredResult
異步的訂單處理核心邏輯,也是耗時(shí)的操作
@Component @EnableAsync public class OrderListener { static Logger logger = LoggerFactory.getLogger(OrderListener.class); /** * 事實(shí)上它是一個(gè)訂單隊(duì)列的消費(fèi)者,在后臺(tái)寫訂單,本例使用簡單的事件監(jiān)聽器實(shí)現(xiàn)異步處理的功能. * * @return */ @EventListener @Async public String processOrder(DeferredResultdeferredResult) throws InterruptedException { logger.info("處理訂單并返回到對(duì)應(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)請(qǐng)求/create-order后,服務(wù)器在處理2秒后,返回結(jié)果,而spring后臺(tái)真正做的是,線程1在事件發(fā)布后,它成為空閑狀態(tài),其它請(qǐng)求可以復(fù)用它,當(dāng)processOrder后臺(tái)處理結(jié)果后,spring又會(huì)用線程池中拿一個(gè)新的線程處理剩下的邏輯!
以上是“Springboot如何實(shí)現(xiàn)高并發(fā)下耗時(shí)操作”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對(duì)大家有所幫助,如果還想學(xué)習(xí)更多知識(shí),歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道!