springboot~高併發下耗時操做的實現

高併發下的耗時操做

高併發下，就是請求在一個時間點比較多時，不少寫的請求打過來時，你的服務器承受很大的壓力，當你的一個請求處理時間長時，這些請求將會把你的服務器線程耗盡，即你的主線程池裏的線程將不會再有空閒狀態的，再打過來的請求，將會是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;
    }
}

測試結果

當請求/create-order後，服務器在處理2秒後，返回結果，而spring後臺真正作的是，線程1在事件發佈後，它成爲空閒狀態，其它請求能夠複用它，當processOrder後臺處理結果後，spring又會用線程池中拿一個新的線程處理剩下的邏輯！