springboot高并发下提高吞吐量的实现
公司让做一个全文检索的项目，我使用的是elasticsearch。但是对性能有很高的要求，为了解决性能问题，我简直是寝食难安。
es(elasticsearch)没有使用分布式，单台的。
开发完测试的时候，查询慢，吞吐量低。
网友们建议用异步--使用Callable来实现、webAsyncTask、Deferred方式等，我一一尝试了之后也没有明显效果，使用压测工具发现使用前后没有一点提升。
尝试这些方法花费了我两天的时间！
在不想使用redis缓存的情况下，我想到了多线程抱着试一试的心态。
没想到吞吐量竟然翻了一倍，查询效率也瞬间提升了两个档次，完全达标，所以这里要记录一下。
其实就是一个类，放进去即可。
packagecom.zing.es.sample.config;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
importjava.util.concurrent.ThreadPoolExecutor;
@Configuration
publicclassGlobalConfig{
/**
*默认线程池线程池
*
*@returnExecutor
*/
@Bean
publicThreadPoolTaskExecutordefaultThreadPool(){
ThreadPoolTaskExecutorexecutor=newThreadPoolTaskExecutor();
//核心线程数目
executor.setCorePoolSize(16);
//指定最大线程数
executor.setMaxPoolSize(300);
//队列中最大的数目
executor.setQueueCapacity(50);
//线程名称前缀
executor.setThreadNamePrefix("defaultThreadPool_");
//rejection-policy：当pool已经达到maxsize的时候，如何处理新任务
//CALLER_RUNS：不在新线程中执行任务，而是由调用者所在的线程来执行
//对拒绝task的处理策略
executor.setRejectedExecutionHandler(newThreadPoolExecutor.CallerRunsPolicy());
//线程空闲后的最大存活时间
executor.setKeepAliveSeconds(60);
//加载
executor.initialize();
returnexecutor;
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。