怎么在spring boot高并發下實現耗時操作

怎么在spring boot高并發下實現耗時操作？很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。

高并發下的耗時操作

高并發下，就是請求在一個時間點比較多時，很多寫的請求打過來時，你的服務器承受很大的壓力，當你的一個請求處理時間長時，這些請求將會把你的服務器線程耗盡，即你的主線程池里的線程將不會再有空閑狀態的，再打過來的請求，將會是502了。

請求流程圖

http1    http2        http3
thread1  thread2      thread3

解決方案

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

代碼實現

建立訂單的接口，只負責簡單的校驗和事件的發布

  /**
   * 異步建立高并發的訂單.
   *
   * @return
   */
  @GetMapping("/create-order")
  public DeferredResult<Object> createOrder() {
    DeferredResult<Object> deferredResult = new DeferredResult<>((long) 3000, "error order");
    logger.info("發布建立訂單的事件");
    applicationEventPublisher.publishEvent(deferredResult);
    return deferredResult;
  }

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

@Component
@EnableAsync
public class OrderListener {

  static Logger logger = LoggerFactory.getLogger(OrderListener.class);

  /**
   * 事實上它是一個訂單隊列的消費者，在后臺寫訂單，本例使用簡單的事件監聽器實現異步處理的功能.
   *
   * @return
   */
  @EventListener
  @Async
  public String processOrder(DeferredResult<Object> deferredResult) throws InterruptedException {
    logger.info("處理訂單并返回到對應的Http上下文");
    String order = UUID.randomUUID().toString();
    Thread.sleep(2000);//假設處理數據需要5秒，前端需要阻塞5秒，但http主線程已經釋放了，比較適合IO密集型場合
    //當設置之后，create-order將成功響應
    deferredResult.setResult(order);
    return order;
  }
}

看完上述內容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業資訊頻道，感謝您對億速云的支持。