SpringBoot异步调用

SpringBoot异步调用除了异步请求,一般上我们用的比较多的应该是异步调用。通常在开发过程中,会遇到一个方法是和实际业务无关的,没有紧密性的。比如记录日志信息等业务。这个时候正常就是启一个新线程去做一些业务处理,让主线程异步的执行其他业务。何为异步调用说异步调用前,我们说说它对应的同步调用。通常开发过程中,一般上我们都是同步调用,即:程序按定义的顺序依次执行的过程,每一行代码执行过程必须等待上一行代码执行完毕后才…

大家好,又见面了,我是你们的朋友全栈君。

除了异步请求,一般上我们用的比较多的应该是异步调用。通常在开发过程中,会遇到一个方法是和实际业务无关的,没有紧密性的。比如记录日志信息等业务。这个时候正常就是启一个新线程去做一些业务处理,让主线程异步的执行其他业务。

何为异步调用

说异步调用前,我们说说它对应的同步调用。通常开发过程中,一般上我们都是同步调用,即:程序按定义的顺序依次执行的过程,每一行代码执行过程必须等待上一行代码执行完毕后才执行。而异步调用指:程序在执行时,无需等待执行的返回值可继续执行后面的代码。显而易见,同步有依赖相关性,而异步没有,所以异步可并发执行,可提高执行效率,在相同的时间做更多的事情。

题外话:除了异步、同步外,还有一个叫回调。其主要是解决异步方法执行结果的处理方法,比如在希望异步调用结束时返回执行结果,这个时候就可以考虑使用回调机制。

Async异步调用

在SpringBoot中使用异步调用是很简单的,只需要使用@Async注解即可实现方法的异步调用。

注意:需要在启动类加入@EnableAsync使异步调用@Async注解生效。使用@Async很简单,只需要在需要异步执行的方法上加入此注解即可。这里创建一个控制层和一个服务层,进行简单示例下。

@Slf4j
@Service
public class SyncService {
    @Async
    public void asyncEvent() throws InterruptedException {
        //休眠1s
        TimeUnit.SECONDS.sleep(1);
        log.info("异步方法内部线程名称:{}!", Thread.currentThread().getName());
    }
    public void syncEvent() throws InterruptedException {
        TimeUnit.SECONDS.sleep(1);
        log.info("同步方法内部线程名称:{}!", Thread.currentThread().getName());
    }
}
@Slf4j
@RestController
public class AsyncController {
    @Autowired
    private SyncService syncService;

    @GetMapping("/async")
    public String doAsync() throws InterruptedException, ExecutionException {
        long start = System.currentTimeMillis();
        //调用同步方法
        syncService.syncEvent();
        long syncEndTime = System.currentTimeMillis();
        log.info("同步方法用时:{}", syncEndTime - start);
        //调用异步方法
        syncService.asyncEvent();//异步方法无返回值
        long asyncEndTime = System.currentTimeMillis();
        log.info("异步方法用时:{}", asyncEndTime - syncEndTime);
        return "async!!!";
    }

}
@SpringBootApplication
@EnableAsync
public class SpringWebApplication{

    public static void main(String[] args) {
        SpringApplication.run(SpringWebApplication.class, args);
    }
}

应用启动后,可以看见控制台输出:

SpringBoot异步调用

 

可以看出,调用异步方法时,是立即返回的,基本没有耗时。

这里有几点需要注意下:

  1. 在默认情况下,未设置TaskExecutor时,默认是使用SimpleAsyncTaskExecutor这个线程池,但此线程不是真正意义上的线程池,因为线程不重用,每次调用都会创建一个新的线程。可通过控制台日志输出可以看出,每次输出线程名都是递增的。
  2. 调用的异步方法,不能为同一个类的方法,简单来说,因为Spring在启动扫描时会为其创建一个代理类,而同类调用时,还是调用本身的代理类的,所以和平常调用是一样的。其他的注解如@Cache等也是一样的道理,说白了,就是Spring的代理机制造成的。

自定义线程池

前面有提到,在默认情况下,系统使用的是默认的SimpleAsyncTaskExecutor进行线程创建。所以一般上我们会自定义线程池来进行线程的复用。

@Configuration
public class Config {
    /**
     * 配置线程池
     * @return
     */
    @Bean(name = "asyncPoolTaskExecutor")
    public ThreadPoolTaskExecutor asyncThreadPoolTaskExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(20);
        taskExecutor.setMaxPoolSize(200);
        taskExecutor.setQueueCapacity(25);
        taskExecutor.setKeepAliveSeconds(200);
        taskExecutor.setThreadNamePrefix("MyExecutor-");
        // 线程池对拒绝任务(无线程可用)的处理策略,目前只支持AbortPolicy、CallerRunsPolicy;默认为后者
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        taskExecutor.initialize();
        return taskExecutor;
    }
}

此时,使用的是就只需要在@Async加入线程池名称即可:

@Async("asyncPoolTaskExecutor")
public void asyncEvent() throws InterruptedException {
    //休眠1s
    TimeUnit.SECONDS.sleep(1);
    log.info("异步方法内部线程名称:{}!", Thread.currentThread().getName());
}

这里简单说明下,关于ThreadPoolTaskExecutor参数说明:

  1. corePoolSize:线程池维护线程的最少数量
  2. keepAliveSeconds:允许的空闲时间,当超过了核心线程数之外的线程在空闲时间到达之后会被销毁
  3. maxPoolSize:线程池维护线程的最大数量,只有在缓冲队列满了之后才会申请超过核心线程数的线程
  4. queueCapacity:缓存队列
  5. rejectedExecutionHandler:线程池对拒绝任务(无线程可用)的处理策略。这里采用了CallerRunsPolicy策略,当线程池没有处理能力的时候,该策略会直接在 execute 方法的调用线程中运行被拒绝的任务;如果执行程序已关闭,则会丢弃该任务。还有一个是AbortPolicy策略:处理程序遭到拒绝将抛出运行时RejectedExecutionException。

而在一些场景下,若需要在关闭线程池时等待当前调度任务完成后才开始关闭,可以通过简单的配置,进行优雅的停机策略配置。关键就是通过setWaitForTasksToCompleteOnShutdown(true)和setAwaitTerminationSeconds方法。

  • setWaitForTasksToCompleteOnShutdown:表明等待所有线程执行完,默认为false。
  • setAwaitTerminationSeconds:等待的时间,因为不能无限的等待下去。

所以,线程池完整配置为:

@Bean(name = "asyncPoolTaskExecutor")
    public ThreadPoolTaskExecutor asyncThreadPoolTaskExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(20);
        taskExecutor.setMaxPoolSize(200);
        taskExecutor.setQueueCapacity(25);
        taskExecutor.setKeepAliveSeconds(200);
        taskExecutor.setThreadNamePrefix("MyExecutor-");
        // 线程池对拒绝任务(无线程可用)的处理策略,目前只支持AbortPolicy、CallerRunsPolicy;默认为后者
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //调度器shutdown被调用时等待当前被调度的任务完成
        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
        //等待时长
        taskExecutor.setAwaitTerminationSeconds(60);
        taskExecutor.initialize();
        return taskExecutor;
    }

配置默认的线程池

如果我们想使用默认的线程池,但是只是想修改默认线程池的配置,那怎么做呢,此时我们需要实现AsyncConfigurer类,示例代码如下:

@Configuration
@EnableAsync
public class TaskExecutorConfig implements AsyncConfigurer {
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return null;
    }
    /**
     * 配置线程池
     * @return
     */

    public ThreadPoolTaskExecutor getAsyncExecutor() {
       ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(20);
        taskExecutor.setMaxPoolSize(200);
        taskExecutor.setQueueCapacity(25);
        taskExecutor.setKeepAliveSeconds(200);
        taskExecutor.setThreadNamePrefix("MyExecutor-");//线程名称前缀
        // 线程池对拒绝任务(无线程可用)的处理策略,目前只支持AbortPolicy、CallerRunsPolicy;默认为后者
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //调度器shutdown被调用时等待当前被调度的任务完成
        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
        //等待时长
        taskExecutor.setAwaitTerminationSeconds(60);
        taskExecutor.initialize();
        return taskExecutor;
    }

}

异步回调及超时处理

对于一些业务场景下,需要异步回调的返回值时,就需要使用异步回调来完成了。主要就是通过Future进行异步回调。

@Async
public Future<String> asyncEventWithReturn() throws InterruptedException {
    //休眠1s
    TimeUnit.SECONDS.sleep(1);
    log.info("异步方法内部线程名称:{}!", Thread.currentThread().getName());
    return new AsyncResult<>("异步方法有返回值");
}

其中AsyncResult是Spring提供的一个Future接口的子类。

然后通过isDone方法,判断是否已经执行完毕。

@Slf4j
@RestController
public class AsyncController {
    @Autowired
    private SyncService syncService;

@GetMapping("/async_return")
public String doAsyncWithReturn() throws InterruptedException, ExecutionException {
    long start = System.currentTimeMillis();
    //调用同步方法
    syncService.syncEvent();
    long syncEndTime = System.currentTimeMillis();
    log.info("同步方法用时:{}", syncEndTime - start);
    //调用异步方法
    // 异步方法有返回值
    Future<String> doFutrue = syncService.asyncEventWithReturn();
    while (true) {
        //判断异步任务是否完成
        if (doFutrue.isDone()) {
            log.info("异步回调结果:" + doFutrue.get());
            break;
        }
        Thread.sleep(100);
    }
    long endTime = System.currentTimeMillis();
    log.info("异步方法用时:{}", endTime - syncEndTime);
    return doFutrue.get();
}

}

所以,当某个业务功能可以同时拆开一起执行时,可利用异步回调机制,可有效的减少程序执行时间,提高效率。

超时处理

对于一些需要异步回调的函数,不能无期限的等待下去,所以一般上需要设置超时时间,超时后可将线程释放,而不至于一直堵塞而占用资源。

对于Future配置超时,很简单,通过get方法即可,具体如下:

//get方法会一直堵塞,直到等待执行完成才返回

//get(long timeout, TimeUnit unit) 在设置时间类未返回结果,会直接排除异常TimeoutException,messages为null

String result = doFutrue.get(60, TimeUnit.SECONDS);//60s

超时后,会抛出异常TimeoutException类,此时可进行统一异常捕获即可。

 

参考:

https://blog.csdn.net/liuchuanhong1/article/details/64132520

https://my.oschina.net/xiedeshou/blog/1929325

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/157453.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • C语言实现-航空订票系统(飞机订票系统)单机版&联网版「建议收藏」

    C语言实现-航空订票系统(飞机订票系统)单机版&联网版「建议收藏」操作系统:Windows下运行。如果需要在Linux运行,则需要修改删除conio.h,自己写个头文件获取键盘输入。我已经写好了getch.h文件,需要将其导入使用。开发环境:CodeBlocks开发语言:C实现功能:登录,订票,退票数据存储:文本读写涉及文件:相关文件下载:码云:传送门GitHub:传送门相关图片(仅供参考):程序是没有涉及旅行社的ER…

  • 华为手机解锁码计算工具_华为高通全系列手机解锁工具

    华为手机解锁码计算工具_华为高通全系列手机解锁工具华为手机要解锁这个是真的是一个很头痛的问题,一是要申请解锁码二是要用一个特殊的解锁工具,可是现在好了,一键获取解锁码、解锁工具已经问世。华为高通全系列手机解锁工具可以在线获取解锁码,并直接开启解锁。适用于华为高通系列手机,这句话意思是说,这个解锁工具不只是适用于华为C8816电信版的解锁还适合华为大多数使用高通处理器的手机解锁。希望大家一次解锁成功!工具说明:(1)仅支持华为部分高通系列机型…

  • 博弈论案例分析题及答案_微软技术支持面试题

    博弈论案例分析题及答案_微软技术支持面试题相信下面这个问题很多人都见过,博弈论中经典案例–“强盗分金”,测试一下自己的逻辑是否正确五个海盗抢到了100颗宝石,每一颗都一样大小和价值连城。他们决定这么分:  抽签决定自己的号码(1、2、3、4、5)  首先,由1号提出分配方案,然后大家表决,当且仅当超过半数的人同意时,按照他的方案  进行分配,否则将被扔进大海喂鲨鱼  如果1号死后,…

    2022年10月16日
  • 网站优化工具-YUI Compressor「建议收藏」

    网站优化工具-YUI Compressor「建议收藏」一、简介YUICompressor,专用于压缩js和css文件,可以有效降低js和css文件占用的空间;如,将使用YUICompressor压缩过的js和css文件部署到网站的生产环境,有效降低浏览器下载相关资源的时延,提升用户体验。二、压缩工具YUI-Compressor英文官网:http://yui.github.io/yuicompressor/GitHub-YUI:https://github.com/yui/yuicompressor在线YUI:http://ganquan.inf

  • pycharm 字体设置「建议收藏」

    pycharm 字体设置「建议收藏」pycharm字体设置

  • APAP论文阅读笔记[通俗易懂]

    APAP论文阅读笔记[通俗易懂]As-Projective-As-PossibleImageStitchingwithMovingDLT论文阅读笔记论文和代码可以在这个网址找到:https://cs.adelaide.edu.au/~tjchin/apap/一、全文翻译题目:使用移动DLT进行尽可能投影的图像拼接摘要:我们专注于图像拼接的任务,通常通过估计投影扭曲来解决这一问题——当场景是平面的或当视图完全因旋转而不同时,该模型是合理的。这样的条件在实践中很容易被违反,这就产生了使用重影人工制品的缝合结果,这就需要使用去

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号