脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → SpringBoot实现异步调用

SpringBoot实现异步调用的全过程

 更新时间：2025年12月26日 08:47:11   作者：百***5588  
文章介绍了在Java的SpringBoot中实现异步请求和异步调用的方法,包括使用`@Async`注解、Java原生线程池和Spring的`TaskExecutor`,文章还讨论了何时使用异步请求和不同异步处理方式的优缺点

在Java中使用Spring Boot实现异步请求和异步调用是一个常见的需求，可以提高应用程序的性能和响应能力。

以下是实现这两种异步操作的基本方法：

一、异步请求（Asynchronous Request）

异步请求允许客户端发送请求后立即返回，而不需要等待服务器处理完成，异步调用允许在服务端异步执行方法，不阻塞主线程。

二、在 Spring Boot 中，实现异步调用主要有以下几种方法：

1. 使用 @Async 注解

步骤

  1. 启用异步支持：在主类上添加 @EnableAsync。
  2. 定义异步方法：在需要异步执行的方法上使用 @Async 注解。
  3. 自定义线程池（可选）：提高异步任务的线程管理效率，以便异步方法能够在独立的线程中执行

示例代码

主类：

package com.work;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;
@SpringBootApplication(scanBasePackages = {"com.work.*"})
@EnableAsync
//@EnableScheduling
public class SpringBootWorkApplication {
	public static void main(String[] args) {
		SpringApplication.run(SpringBootWorkApplication.class, args);
	}
}

异步方法：

package com.work.service;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
/**
 * 异步调用service
 * @author summer
 */
@Service
@Slf4j
public class AsyncService {
    /**
	 * 使用 @Async 注解 实现异步调用
	 * taskExecutor为自定义线程池，指定自定义线程池
	 * @return
	 * @throws InterruptedException
	 */
	@Async("taskExecutor")
    public void async(){
		log.info("async异步任务开始: " + Thread.currentThread().getName());
		try {
			// 模拟耗时操作(实际工作中，此处写业务逻辑处理)  
			Thread.sleep(30000); 
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
		log.info("async异步任务完成");
    }
}

自定义线程池（可选）

package com.work.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.TaskExecutor;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/**
 * 自定义异步线程执行线程池
 * @author summer
 *
 */
@Configuration
public class ExecutorConfig {

    @Bean(name = "taskExecutor")
    public TaskExecutor  taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(50);
        executor.setThreadNamePrefix("TaskExecutor-");
        executor.initialize();
        return executor;
    }
}

在 @Async("taskExecutor") 中指定自定义线程池。

调用

package com.work.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.work.common.result.CommonResult;
import com.work.service.AsyncService;
import lombok.extern.slf4j.Slf4j;

/**
 * 测试异步执行Controller
 * @author summer
 *
 */
@RestController
@RequestMapping("/async")
@Slf4j
public class AsyncTestController {
	
	@Autowired
	private AsyncService asyncService;
	
	@GetMapping("/async")
	public CommonResult<String> async() {
		asyncService.async();
		log.info("async异步任务调用成功");
		return CommonResult.success("async异步任务调用成功");
	}
}

异步方法休眠30秒，可以看到控制台打印的日志

线程池配置建议

  • CPU 密集型任务：建议核心线程数为 CPU 核心数的 n 倍，最大线程数为核心线程数的 2 倍。
  • IO 密集型任务：建议核心线程数设置为较大的值，最大线程数可以为核心线程数的 2 倍甚至更多。

合理配置线程池可以避免线程饥饿和死锁等问题，提升系统的吞吐量。

2. 使用 Java 原生线程池

Spring 提供线程池，但可以直接使用 Java 原生的线程池来实现异步。

示例代码：

package com.work.service;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;

/**
 * 异步调用service
 * @author summer
 *
 */
@Service
@Slf4j
public class AsyncService{
	
	/**
	 * 使用 Java 原生线程池来实现异步调用
	 */
	public void asyncThreadPool() {
		ThreadPoolExecutor pool=new ThreadPoolExecutor(5, 10, 
				2, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(100),new ThreadPoolExecutor.CallerRunsPolicy());
		pool.execute(() -> {
			log.info("asyncThreadPool异步任务开始: " + Thread.currentThread().getName());
            try {
            	// 模拟耗时操作(实际工作中，此处写业务逻辑处理)  
                Thread.sleep(30000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            log.info("asyncThreadPool异步任务完成");
        });
    }
}

调用：

package com.work.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.work.common.result.CommonResult;
import com.work.service.AsyncService;
import lombok.extern.slf4j.Slf4j;

/**
 * 测试异步执行Controller
 * @author summer
 *
 */
@RestController
@RequestMapping("/async")
@Slf4j
public class AsyncTestController {
	@Autowired
	private AsyncService asyncService;
	
	@GetMapping("/asyncThreadPool")
	public CommonResult<String> asyncThreadPool() {
		asyncService.asyncThreadPool();
		log.info("asyncThreadPool异步任务调用成功");
		return CommonResult.success("asyncThreadPool异步任务调用成功");
	}
}

异步方法休眠30秒，可以看到控制台打印的日志

3. 使用 Spring 的 TaskExecutor

TaskExecutor 是 Spring 提供的抽象接口，适合用来执行异步任务。

配置 TaskExecutor：

package com.work.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.TaskExecutor;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/**
 * 自定义异步线程执行线程池
 * @author summer
 *
 */
@Configuration
public class ExecutorConfig {

    @Bean(name = "taskExecutor")
    public TaskExecutor  taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(50);
        executor.setThreadNamePrefix("TaskExecutor-");
        executor.initialize();
        return executor;
    }
}

示例代码：

package com.work.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
/**
 * 异步调用service
 * @author summer
 *
 */
@Service
@Slf4j
public class AsyncService{
	@Autowired
	private TaskExecutor taskExecutor;
	
	/**
	 * 使用 Spring 的 TaskExecutor 来实现异步调用
	 */
	public void asyncExecutor() {
        taskExecutor.execute(() -> {
        	log.info("asyncExecutor异步任务开始:" + Thread.currentThread().getName());
            try {
            	// 模拟耗时操作(实际工作中，此处写业务逻辑处理)  
                Thread.sleep(30000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            log.info("asyncExecutor异步任务完成");
        });
    }
}

调用：

package com.work.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.work.common.result.CommonResult;
import com.work.service.AsyncService;
import lombok.extern.slf4j.Slf4j;

/**
 * 测试异步执行Controller
 * @author summer
 *
 */
@RestController
@RequestMapping("/async")
@Slf4j
public class AsyncTestController {
	@Autowired
	private AsyncService asyncService;
	
	@GetMapping("/asyncExecutor")
	public CommonResult<String> asyncExecutor() {
		asyncService.asyncExecutor();
		log.info("asyncExecutor异步任务调用成功");
		return CommonResult.success("asyncExecutor异步任务调用成功");
	}
}

异步方法休眠30秒，可以看到控制台打印的日志

三、什么时候使用异步请求

异步请求在以下情况下特别有用：

  • 长时间运行的任务：例如文件上传、复杂计算、大量数据处理等。
  • I/O操作：例如数据库查询、调用外部API、文件读写等。
  • 资源密集型任务：例如图像处理、视频编码等。

四、总结

方法、优点、缺点

@Async 注解

  • 简单易用，与 Spring 集成良好
  • 需要 Spring 容器管理的 Bean 才能生效

ExecutorService

  • 更底层、更灵活
  • 手动管理线程池

TaskExecutor

  • Spring 提供的抽象，方便扩展
  • 配置稍显复杂

这些示例展示了如何在Spring Boot中实现异步请求和异步调用。Spring Boot提供了`@Async`注解和`Java原生线程池`、`TaskExecutor`来实现这一功能，提高了应用程序的并发处理能力，开发者可以根据不同的需求选择合适的异步处理方式。

合理配置线程池，以确保最佳性能和资源利用，正确处理异步任务中的异常，以及在合适的场景中应用异步处理技术，是开发高性能应用的关键。

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • Spring boot 4 搞懂MyBatis-Plus的用法解析

    Spring boot 4 搞懂MyBatis-Plus的用法解析

    MyBatis-Plus是MyBatis的增强工具,提供了CRUD操作和自动填充等功能,通过继承BaseMapper接口,可以快速实现数据库操作,MyBatis-Plus提供了多种插件,如分页、乐观锁、多租户等,以增强系统的功能和性能,本文介绍Spring boot 4 搞懂MyBatis-Plus的用法,感兴趣的朋友一起看看吧
    2026-01-01
  • SpringBoot整合RabbitMQ的5种模式的注解绑定详解

    SpringBoot整合RabbitMQ的5种模式的注解绑定详解

    这篇文章主要介绍了SpringBoot整合RabbitMQ的5种模式的注解绑定详解,RabbitMQ 是一个消息中间件,它接收消息并且转发,是"消费-生产者模型"的一个典型的代表,一端往消息队列中不断的写入消息,而另一端则可以读取或者订阅队列中的消息,需要的朋友可以参考下
    2024-01-01
  • SpringCloud-Gateway转发WebSocket失败问题及解决

    SpringCloud-Gateway转发WebSocket失败问题及解决

    这篇文章主要介绍了SpringCloud-Gateway转发WebSocket失败问题及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-09-09
  • Java高效利用异常处理的技巧总结

    Java高效利用异常处理的技巧总结

    这篇文章主要为大家详细介绍了Java如何高效利用异常处理,从而达到优化代码的效果,文中的示例代码讲解详细,感兴趣的小伙伴可以学习一下
    2023-09-09
  • java压缩文件与删除文件的示例代码

    java压缩文件与删除文件的示例代码

    这篇文章主要介绍了java压缩文件与删除文件的示例代码，代码简单易懂，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-08-08
  • Java中ZIP文件中文乱码问题的解决指南

    Java中ZIP文件中文乱码问题的解决指南

    文章介绍Java文件压缩解压中处理中文乱码的解决方案,包括指定UTF-8编码、使用缓冲流及Ant工具配置,确保文件名和内容正确显示,避免因字符集不一致导致的乱码问题,本文结合示例代码给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧
    2025-09-09
  • Java中用户向系统传递参数的三种基本方式实例分享

    Java中用户向系统传递参数的三种基本方式实例分享

    这篇文章主要介绍了Java中用户向系统传递参数的三种基本方式实例，有需要的朋友可以参考一下
    2014-01-01
  • springboot业务功能实战之告别轮询websocket的集成使用

    springboot业务功能实战之告别轮询websocket的集成使用

    WebSocket使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据,下面这篇文章主要给大家介绍了关于springboot业务功能实战之告别轮询websocket的集成使用,需要的朋友可以参考下
    2022-10-10
  • DoytoQuery中的分页排序方案示例详解

    DoytoQuery中的分页排序方案示例详解

    这篇文章主要为大家介绍了DoytoQuery中的分页排序方案示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2022-12-12
  • Spring整合消息队列RabbitMQ流程

    Spring整合消息队列RabbitMQ流程

    Spring整合RabbitMQ很容易，但是整合的目的是为了使用，那要使用RabbitMQ就要对其有一定的了解，不然容易整成一团浆糊。因为说到底，Spring只是在封装RabbitMQ的API，让其更容易使用而已，废话不多说，让我们一起整它
    2023-03-03

最新评论