快捷導(dǎo)航

springboot高并發(fā)下提高吞吐量的實(shí)現(xiàn)

更新時(shí)間：2019年11月18日 09:23:57 作者：bokestudy

這篇文章主要介紹了springboot高并發(fā)下提高吞吐量的實(shí)現(xiàn)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

公司讓做一個(gè)全文檢索的項(xiàng)目，我使用的是elasticsearch。但是對(duì)性能有很高的要求，為了解決性能問(wèn)題，我簡(jiǎn)直是寢食難安。

es(elasticsearch)沒(méi)有使用分布式，單臺(tái)的。

開(kāi)發(fā)完測(cè)試的時(shí)候，查詢(xún)慢，吞吐量低。

網(wǎng)友們建議用異步--使用Callable來(lái)實(shí)現(xiàn)、webAsyncTask、Deferred方式等，我一一嘗試了之后也沒(méi)有明顯效果，使用壓測(cè)工具發(fā)現(xiàn)使用前后沒(méi)有一點(diǎn)提升。

嘗試這些方法花費(fèi)了我兩天的時(shí)間！

在不想使用redis緩存的情況下，我想到了多線程抱著試一試的心態(tài)。

沒(méi)想到吞吐量竟然翻了一倍，查詢(xún)效率也瞬間提升了兩個(gè)檔次，完全達(dá)標(biāo)，所以這里要記錄一下。

其實(shí)就是一個(gè)類(lèi)，放進(jìn)去即可。

package com.zing.es.sample.config;
 
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
import java.util.concurrent.ThreadPoolExecutor;
 
@Configuration
public class GlobalConfig {
 
 /**
   * 默認(rèn)線程池線程池
   *
   * @return Executor
   */
  @Bean
  public ThreadPoolTaskExecutor defaultThreadPool() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    //核心線程數(shù)目
    executor.setCorePoolSize(16);
    //指定最大線程數(shù)
    executor.setMaxPoolSize(300);
    //隊(duì)列中最大的數(shù)目
    executor.setQueueCapacity(50);
    //線程名稱(chēng)前綴
    executor.setThreadNamePrefix("defaultThreadPool_");
    //rejection-policy：當(dāng)pool已經(jīng)達(dá)到max size的時(shí)候，如何處理新任務(wù)
    //CALLER_RUNS：不在新線程中執(zhí)行任務(wù)，而是由調(diào)用者所在的線程來(lái)執(zhí)行
    //對(duì)拒絕task的處理策略
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    //線程空閑后的最大存活時(shí)間
    executor.setKeepAliveSeconds(60);
    //加載
    executor.initialize();
    return executor;
  }
}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: