springboot高并发下提高吞吐量的实现
82 浏览量
2020-08-25
09:45:19
上传
评论 3
收藏 51KB PDF 举报
springboot高并发下提高吞吐量的实现高并发下提高吞吐量的实现
主要介绍了springboot高并发下提高吞吐量的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作
具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
公司让做一个全文检索的项目，我使用的是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;
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。
资源评论
weixin_38689041
- 粉丝: 1
- 资源: 963
最新资源
- 基础算法-python爬楼梯问题
- 某音Web端参数X-Bogus获取算法（逆向分析）
- 头歌答案 C语言程序设计实践 实验二 数据类型与基本操作（1）
- java高校实习生管理系统设计和实现springboot+vue毕业设计源码+数据库mysql代码.rar
- springboot+vue.js辽B代驾管理系统java毕业设计源码+数据库代码.rar
- OceanBase OBCA初级考试认证资料
- java可信捐赠管理系统的设计与开发springboot+vue毕业设计源码+数据库代码.rar
- vue基于Springboot的网上宠物店系统的设计与实现java毕业设计源码+数据库代码.rar
- OceanBase OBCA 部分题目
- vue基于springboot的七彩云南文化旅游网站的设计与实现java毕业设计源码代码+数据库.rar
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
