SpringBoot异步调用方法实现场景代码实例
作者:Erneste 发布时间:2023-10-23 14:14:23
标签:Spring,Boot,异步,调用,场景
一、背景
项目中肯定会遇到异步调用其他方法的场景,比如有个计算过程,需要计算很多个指标的值,但是每个指标计算的效率快慢不同,如果采用同步执行的方式,运行这一个过程的时间是计算所有指标的时间之和。比如:
方法A:计算指标x,指标y,指标z的值,其中计算指标x需要1s,计算指标y需要2s,指标z需要3s。最终执行完方法A就是5s。
现在用异步的方式优化一下
方法A异步调用方法B,方法C,方法D,方法B,方法C,方法D分别计算指标x,指标y,指标z的值,那么最终执行完方法A的时间则是3s。
还有一种用途是当一个业务里面需要多个请求时,这时候异步并发请求所得到的回报远远是物有所值的。因为他是异步执行的,话不多说,一下是在springBoot里面使用并发请求;
二、spring boot中异步并发使用
2.1、appllication.yml
#****************集成Async线程池开始*******************
async: # Async线程池 配置
executor:
corepoolsize: 20
maxpoolsize: 25
queuecapacity: 40
keepaliveseconds: 200
threadnameprefix: appasync
awaitterminationseconds: 60
#*****************集成Async线程池结束******************
2.2、配置线程池
@Configuration
@EnableAsync
public class ExecutorConfig {
@Value("${async.executor.corepoolsize}")
private Integer corePoolSize;
@Value("${async.executor.maxpoolsize}")
private Integer maxPoolSize;
@Value("${async.executor.queuecapacity}")
private Integer queueCapacity;
@Value("${async.executor.keepaliveseconds}")
private Integer keepAliveSeconds;
@Value("${async.executor.threadnameprefix}")
private String threadNamePrefix;
@Value("${async.executor.awaitterminationseconds}")
private Integer awaitTerminationSeconds;
/**
* 线程池
*
* @return
*/
@Bean(name = "asyncExecutor")
public Executor asyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 基础线程数 corePoolSize: 10
executor.setCorePoolSize(corePoolSize);
// 最大线程数 maxPoolSize: 15
executor.setMaxPoolSize(maxPoolSize);
// 队列长度 queueCapacity: 25
executor.setQueueCapacity(queueCapacity);
// 线程池维护线程所允许的空闲时间,单位为秒 keepAliveSeconds: 200
executor.setKeepAliveSeconds(keepAliveSeconds);
// 线程名字 threadNamePrefix: appasync
executor.setThreadNamePrefix(threadNamePrefix);
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 等待所有任务都完成再继续销毁其他的Bean
executor.setWaitForTasksToCompleteOnShutdown(true);
// 线程池中任务的等待时间,如果超过这个时候还没有销毁就强制销毁,以确保应用最后能够被关闭,而不是阻塞住
executor.setAwaitTerminationSeconds(awaitTerminationSeconds);
executor.initialize();
return executor;
}
}
2.3、线程池监控(这个可有可无,主要是为了对线程池参数及时的调优)
@RestController
@Slf4j
@RequestMapping("/pubapi/asyncExecutor")
public class AsyncExecutorController extends BaseController {
@Resource(name = "asyncExecutor")
private Executor asyncExecutor;
@PostMapping("/monitor")public ResultBean<Map<String, Object>> getAsyncExecutorData() {
ResultBean<Map<String, Object>> resultBean = ResultBeanUtil.error500();
if (asyncExecutor == null) {
return resultBean;
}
try {
ThreadPoolTaskExecutor executorTask = (ThreadPoolTaskExecutor) asyncExecutor;
ThreadPoolExecutor executor = executorTask.getThreadPoolExecutor();
// 当前排队线程数
int queueSize = executor.getQueue().size();
// 当前活动线程数
int activeCount = executor.getActiveCount();
// 执行完线程数
long completedThreadCount = executor.getCompletedTaskCount();
// 总线程数
long taskCount = executor.getTaskCount();
// 初始线程数
int poolSize = executor.getPoolSize();
// 核心线程数
int corePoolSize = executor.getCorePoolSize();
// 线程池是否终止
boolean isTerminated = executor.isTerminated();
// 线城池是否关闭
boolean isShutdown = executor.isShutdown();
// 线程空闲时间
long keepAliveTime = executor.getKeepAliveTime(TimeUnit.MILLISECONDS);
// 最大允许线程数
long maximumPoolSize = executor.getMaximumPoolSize();
// 线程池中存在的最大线程数
long largestPoolSize = executor.getLargestPoolSize();
Map<String, Object> threadPoolData = new HashMap<>(18);
threadPoolData.put("当前排队线程数", queueSize);
threadPoolData.put("当前活动线程数", activeCount);
threadPoolData.put("执行完线程数", completedThreadCount);
threadPoolData.put("总线程数", taskCount);
threadPoolData.put("初始线程数", poolSize);
threadPoolData.put("核心线程数", corePoolSize);
threadPoolData.put("线程池是否终止", isTerminated);
threadPoolData.put("线城池是否关闭", isShutdown);
threadPoolData.put("线程空闲时间", keepAliveTime);
threadPoolData.put("最大允许线程数", maximumPoolSize);
threadPoolData.put("线程池中存在的最大线程数", largestPoolSize);
InetAddress inetAddress = IdWorker.getLocalHostLANAddress();
Map<String, Object> resultData = new HashMap<>(4);
resultData.put("ip", inetAddress.getHostAddress());
resultData.put("threadPoolData", threadPoolData);
resultBean = ResultBeanUtil.success("请求成功!", resultData);
} catch (Exception e) {
e.printStackTrace();
}
return resultBean;
}
}
2.4、代码中使用
public void getMap(){
/**
* 先将耗时的、相互之间无依赖的操作先执行,由于其执行结果暂时不是特别关注,所以
*/
Future<String> futureA = functionA();
Future<String> futureB = functionB();
/**
* 执行其他的操作,其实functionA(),functionB()也在工作
*/
aaa();
/**
* 获取异步的结果,然后计算
*/
try {
String resultA =futureA.get();
String resuleB = futureB.get();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
public Future<String> functionA (){
Future<String> future = null;
try {
Thread.sleep(5000);
future = new AsyncResult<String>("functionA");
} catch (InterruptedException e) {
e.printStackTrace();
}
return future;
}
public Future<String> functionB (){
Future<String> future = null;
try {
Thread.sleep(3000);
future = new AsyncResult<String>("functionB");
} catch (InterruptedException e) {
e.printStackTrace();
}
return future;
}
public void aaa(){
System.out.println("我是");
}
来源:https://www.cnblogs.com/DDgougou/p/11964425.html
0
投稿
猜你喜欢
- 一、前言Hello,又见面了,今天分享如何使用Unity制作计算器,难度中等,可以用来学习,或者当成其他项目的小组件导入。当然,也可以导出来
- 集成配置步骤步骤1:加入 Maven 相关依赖<!-- 指定 Springboot 版本 --><parent> &
- 本文介绍了如何使用Spring Security OAuth2构建一个授权服务器来验证用户身份以提供access_token,并使用这个ac
- 简单的理解,MyBatis逆向工程,就是通过相应插件,自动生成MyBatis数据库连接的一些文件。mybatis需要编写sql语句,myba
- 一、什么是并查集对于一种数据结构,肯定是有自己的应用场景和特性,那么并查集是处理什么问题的呢?并查集是一种树型的数据结构,用于处理一些不相交
- 在Spring Boot Actuator中提供很多像health、metrics等实时监控接口,可以方便我们随时跟踪服务的性能指标。Spr
- 前言本文将带您了解在 Flutter 中制作翻转卡片动画的两个完整示例。第一个示例从头开始实现,第二个示例使用第三方包。闲话少说,让我们动手
- Java 虚拟机在执行Java程序的过程中会把它所管理的内存划分为若干个不同的数据区域,这些区域都有各自的用途,如图所示:程序计数器程序计数
- 在整合SpringBoot和Mybatis-plus时,想写自定义的sql,所以创建了Mapper.xml文件,但是启动后却老是报错:org
- AOP是Spring中的面向切面的编程,这里简单感受一下如何在xml文件中配置一个切面。如上图所示,配置一个切面的主要思路有以下几个步骤。1
- 包括了写入和读取功能. 写入的时候, 如果文件不存在会自动创建. 如果对应的键已经存在, 则自动覆盖它的值. 读取的时候, 如果对应的文件不
- 本文为大家分享了Java多线程实现Runnable方式的具体方法,供大家参考,具体内容如下(一)步骤 1.定义实现Runnable
- 寻找到application.yml的读取的操作。从spring.factories 中查看到# Application Listeners
- 1. 调试追踪代码: public static void enterTryMethod() { S
- 在spring中有很多以XXXAware命名的接口,很多人也不清楚这些接口都是做什么用的,这篇文章将描述常用的一些接口。一,Applicat
- 简述最近做的公司项目,图片比较多,不想给其存储到自己服务器上,就买了阿里云的OSS服务器来哦进行存储,其实集成第三方平台,一般没什么难度,当
- 1. 使用方法首先从http://repo1.maven.org/maven2/com/alibaba/druid/&
- 前言现在开发大部分都是服务化或者微服务,数据交换都是跨服务的,这里记录java调取其他接口的方法,下面话不多说了,来一起看看详细的介绍吧。j
- 骑缝章是用于往来业务合同,以确保合同真实、有效的印章加盖方法,是一种防范风险的重要方式。在Java程序中,可以通过使用工具来辅助加盖这种骑缝
- 序言springboot框架价值,可以简单快速的构建独立的spring生产级别应用。springboot主要有以下的特性:1.创建独立的Sp