springboot高并发下提高吞吐量的实现

软件发布|下载排行|最新软件

当前位置:首页IT学院IT技术

springboot高并发下提高吞吐量的实现

  2021-04-02 我要评论

公司让做一个全文检索的项目,我使用的是elasticsearch。但是对性能有很高的要求,为了解决性能问题,我简直是寝食难安。

es(elasticsearch)没有使用分布式,单台的。

开发完测试的时候,查询慢,吞吐量低。

网友们建议用异步--使用Callable来实现、webAsyncTask、Deferred方式等,我一一尝试了之后也没有明显效果,使用压测工具发现使用前后没有一点提升。

尝试这些方法花费了我两天的时间!

在不想使用redis缓存的情况下,我想到了多线程抱着试一试的心态。

没想到吞吐量竟然翻了一倍,查询效率也瞬间提升了两个档次,完全达标,所以这里要记录一下。

其实就是一个类,放进去即可。

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 {
 
 /**
   * 默认线程池线程池
   *
   * @return Executor
   */
  @Bean
  public ThreadPoolTaskExecutor defaultThreadPool() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    //核心线程数目
    executor.setCorePoolSize(16);
    //指定最大线程数
    executor.setMaxPoolSize(300);
    //队列中最大的数目
    executor.setQueueCapacity(50);
    //线程名称前缀
    executor.setThreadNamePrefix("defaultThreadPool_");
    //rejection-policy:当pool已经达到max size的时候,如何处理新任务
    //CALLER_RUNS:不在新线程中执行任务,而是由调用者所在的线程来执行
    //对拒绝task的处理策略
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    //线程空闲后的最大存活时间
    executor.setKeepAliveSeconds(60);
    //加载
    executor.initialize();
    return executor;
  }
}
您可能感兴趣的文章:

Copyright 2022 版权所有 软件发布 访问手机版

声明:所有软件和文章来自软件开发商或者作者 如有异议 请与本站联系 联系我们