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; } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
相关文章
MyBatis写入Json字段以及Json字段转对象示例详解
这篇文章主要给大家介绍了关于MyBatis写入Json字段以及Json字段转对象的相关资料,文中通过实例代码介绍的非常详细,对大家的学习或者工作具有一定的参考借鉴价值,需要的朋友可以参考下2023-07-07Spring Boot深入排查 java.lang.ArrayStoreException异常
这篇文章介绍了Spring Boot深入排查 java.lang.ArrayStoreException异常,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2021-12-12Spring Boot2配置Swagger2生成API接口文档详情
这篇文章主要介绍了Spring Boot2配置Swagger2生成API接口文档详情,文章围绕主题展开详细的内容介绍,具有一定的参考价值,需要的小伙伴可以参考一下2022-09-09使用IDEA启动项目遇见ClassNotFoundException的解决方案
这篇文章主要介绍了使用IDEA启动项目遇见ClassNotFoundException的正确解决方案,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-06-06
最新评论