springboot高并发下提高吞吐量的实现_springboot提高并发,springboot增加并发量 - CSDN文库

springboot高并发

155 浏览量更新于2023-03-16 评论 3 收藏 51KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

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;

}

}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余0页未读，立即下载

评论0

weixin_38689041

粉丝: 1
资源: 963

会员权益专享

图片转文字

全年可省5，000元立即开通

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈