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

小編給大家分享一下Springboot如何實現(xiàn)高并發(fā)下耗時操作，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

高并發(fā)下的耗時操作

高并發(fā)下，就是請求在一個時間點比較多時，很多寫的請求打過來時，你的服務(wù)器承受很大的壓力，當(dāng)你的一個請求處理時間長時，這些請求將會把你的服務(wù)器線程耗盡，即你的主線程池里的線程將不會再有空閑狀態(tài)的，再打過來的請求，將會是502了。加q群：478052716 免費領(lǐng)取（Java架構(gòu)資料，視頻資料，BATJ面試資料）

請求流程圖

http1 http2 http3
thread1 thread2 thread3

解決方案

使用 DeferredResult 來實現(xiàn)異步的操作，當(dāng)一個請求打過來時，先把它放到一個隊列時，然后在后臺有一個訂閱者，有相關(guān)主題的消息發(fā)過來時，這個訂閱者就去消費它，這一步可以是分布式的，比如一個秒殺場景，當(dāng)N多的請求打過來時，有一些請求命中后，它們進行寫操作，這時寫操作壓力很大，1個請求可以要處理3秒，對于高并發(fā)場景這是不能容許的，因為你這樣占用的服務(wù)器線程資源太長了，很快你的服務(wù)器就沒有可用的線程資源了，這時就可以用到DeferredResult這處理。

代碼實現(xiàn)

建立訂單的接口，只負(fù)責(zé)簡單的校驗和事件的發(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;
 }

異步的訂單處理核心邏輯，也是耗時的操作

@Component
@EnableAsync
public class OrderListener {
 static Logger logger = LoggerFactory.getLogger(OrderListener.class);
 /**
 * 事實上它是一個訂單隊列的消費者，在后臺寫訂單，本例使用簡單的事件監(jiān)聽器實現(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又會用線程池中拿一個新的線程處理剩下的邏輯！

以上是“Springboot如何實現(xiàn)高并發(fā)下耗時操作”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道！