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

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

怎么在springboot高并發(fā)下實現(xiàn)耗時操作

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

公司專注于為企業(yè)提供成都網(wǎng)站設(shè)計、成都網(wǎng)站制作、微信公眾號開發(fā)、商城網(wǎng)站定制開發(fā)重慶小程序開發(fā),軟件按需開發(fā)網(wǎng)站等一站式互聯(lián)網(wǎng)企業(yè)服務(wù)。憑借多年豐富的經(jīng)驗,我們會仔細了解各客戶的需求而做出多方面的分析、設(shè)計、整合,為客戶設(shè)計出具風格及創(chuàng)意性的商業(yè)解決方案,創(chuàng)新互聯(lián)建站更提供一系列網(wǎng)站制作和網(wǎng)站推廣的服務(wù)。

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

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

請求流程圖

http1    http2        http3
thread1  thread2      thread3

解決方案

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

代碼實現(xià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;
  }

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

@Component
@EnableAsync
public class OrderListener {

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

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

看完上述內(nèi)容是否對您有幫助呢?如果還想對相關(guān)知識有進一步的了解或閱讀更多相關(guān)文章,請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝您對創(chuàng)新互聯(lián)的支持。


文章名稱:怎么在springboot高并發(fā)下實現(xiàn)耗時操作
分享鏈接:http://weahome.cn/article/gepdoo.html

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部