快捷導(dǎo)航

spring boot高并發(fā)下耗時(shí)操作的實(shí)現(xiàn)方法

更新時(shí)間：2019年11月18日 08:31:09 作者：張占嶺

這篇文章主要給大家介紹了關(guān)于spring boot高并發(fā)下耗時(shí)操作的實(shí)現(xiàn)方法，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用spring boot具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

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

高并發(fā)下，就是請(qǐng)求在一個(gè)時(shí)間點(diǎn)比較多時(shí)，很多寫的請(qǐng)求打過(guò)來(lái)時(shí)，你的服務(wù)器承受很大的壓力，當(dāng)你的一個(gè)請(qǐng)求處理時(shí)間長(zhǎng)時(shí)，這些請(qǐng)求將會(huì)把你的服務(wù)器線程耗盡，即你的主線程池里的線程將不會(huì)再有空閑狀態(tài)的，再打過(guò)來(lái)的請(qǐng)求，將會(huì)是502了。

請(qǐng)求流程圖

http1    http2        http3
thread1  thread2      thread3

解決方案

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

代碼實(shí)現(xiàn)

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

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

@Component
@EnableAsync
public class OrderListener {

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

  /**
   * 事實(shí)上它是一個(gè)訂單隊(duì)列的消費(fèi)者，在后臺(tái)寫訂單，本例使用簡(jiǎn)單的事件監(jiān)聽器實(shí)現(xiàn)異步處理的功能.
   *
   * @return
   */
  @EventListener
  @Async
  public String processOrder(DeferredResult<Object> 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密集型場(chǎng)合
    //當(dāng)設(shè)置之后，create-order將成功響應(yīng)
    deferredResult.setResult(order);
    return order;
  }
}

測(cè)試結(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è)新的線程處理剩下的邏輯！

總結(jié)

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，謝謝大家對(duì)腳本之家的支持。

您可能感興趣的文章: