真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

Springboot如何實(shí)現(xiàn)高并發(fā)下耗時(shí)操作

小編給大家分享一下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 createOrder() {
 DeferredResult 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)者,在后臺(tái)寫訂單,本例使用簡單的事件監(jiān)聽器實(shí)現(xiàn)異步處理的功能.
 *
 * @return
 */
 @EventListener
 @Async
 public String processOrder(DeferredResult deferredResult) 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è)資訊頻道!


網(wǎng)頁標(biāo)題:Springboot如何實(shí)現(xiàn)高并發(fā)下耗時(shí)操作
瀏覽路徑:http://weahome.cn/article/pccjhh.html

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部