머리말
동기 프로그래밍: 동기 프로그래밍에서는 작업이 한 번에 하나씩 실행되며, 하나의 작업이 완료되어야 다음 작업이 차단 해제됩니다.
비동기 프로그래밍: 비동기 프로그래밍에서는 여러 작업을 동시에 수행할 수 있습니다. 이전 작업이 완료되기 전에 다른 작업으로 이동할 수 있습니다.
Spring Boot
에서는 @Async
주석을 사용하여 비동기 동작을 구현할 수 있습니다. Spring Boot
中,我们可以使用@Async
注解来实现异步行为。
实现步骤
1.定义一个异步服务接口AsyncService.java
public interface AsyncService { void asyncMethod() throws InterruptedException; Future<String> futureMethod() throws InterruptedException; }
2.实现定义的接口AsyncServiceImpl.java
@Service @Slf4j public class AsyncServiceImpl implements AsyncService { @Async @Override public void asyncMethod() throws InterruptedException { Thread.sleep(3000); log.info("Thread: [{}], Calling other service..", Thread.currentThread().getName()); } @Async @Override public Future<String> futureMethod() throws InterruptedException { Thread.sleep(5000); log.info("Thread: [{}], Calling other service..", Thread.currentThread().getName()); return new AsyncResult<>("task Done"); } }
AsyncServiceImpl
是一个spring
管理的bean
。您的异步方法必须是公共的,而且是被
@Async
注解修饰。返回类型被限制为
void
或Future
。
3.定义一个控制器AsyncController.java
@EnableAsync @RestController @Slf4j public class AsyncController { @Autowired AsyncService asyncService; @GetMapping("/async") public String asyncCallerMethod() throws InterruptedException { long start = System.currentTimeMillis(); log.info("call async method, thread name: [{}]", Thread.currentThread().getName()); asyncService.asyncMethod(); String response = "task completes in :" + (System.currentTimeMillis() - start) + "milliseconds"; return response; } @GetMapping("/asyncFuture") public String asyncFuture() throws InterruptedException, ExecutionException { long start = System.currentTimeMillis(); log.info("call async method, thread name: [{}]", Thread.currentThread().getName()); Future<String> future = asyncService.futureMethod(); // 阻塞获取结果 String taskResult = future.get(); String response = taskResult + "task completes in :" + (System.currentTimeMillis() - start) + "milliseconds"; return response; } }
关键点,需要添加启用异步的注解
@EnableAsync
,当然这个注解加在其他地方也ok得。当外部调用该接口时,
asyncMethod()
将由默认任务执行程序创建的另一个线程执行,主线程不需要等待完成异步方法执行。
4.运行一下
现在我们运行一下看看,是不是异步返回的。
可以看到调用/async
接口,最终一步调用了方法。
调用/asyncFuture
,发现返回5秒多,难道不是异步的吗?其实也是异步的,看日志可以看出来,只不过我们返回的是Future
,调用Futrue.get()
是阻塞的。
自定义异步任务执行器和异常处理
我们现在看看如果异常方法中报错了会怎么样?修改异步代码如下所示,会抛运行时异常:
再次执行异步接口,如下所示,会使用默认的线程池和异常处理。
我们也可以自定义异步方法的处理异常和异步任务执行器,我们需要配置 AsyncUncaughtExceptionHandler
,如下代码所示:
@Configuration public class AsynConfiguration extends AsyncConfigurerSupport { @Override public Executor getAsyncExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(3); executor.setMaxPoolSize(4); executor.setThreadNamePrefix("asyn-task-thread-"); executor.setWaitForTasksToCompleteOnShutdown(true); executor.initialize(); return executor; } @Override public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() { return new AsyncUncaughtExceptionHandler() { @Override public void handleUncaughtException(Throwable ex, Method method, Object... params) { System.out.println("Exception: " + ex.getMessage()); System.out.println("Method Name: " + method.getName()); ex.printStackTrace(); } }; } }
再次运行,得到的结果如下:
@Async如何工作的
必须通过使用 @EnableAsync
注解注解主应用程序类或任何直接或间接异步方法调用程序类来启用异步支持。主要通过代理模式实现,默认模式是 Proxy
,另一种是 AspectJ
。代理模式只允许通过代理拦截调用。永远不要从定义它的同一个类调用异步方法,它不会起作用。
当使用 @Async
对方法进行注解时,它会根据“proxyTargetClass
”属性为该对象创建一个代理。当 spring
执行这个方法时,默认情况下它会搜索关联的线程池定义。上下文中唯一的 spring
框架 TaskExecutor bean
或名为“taskExecutor
”的 Executor bean
。如果这两者都不可解析,默认会使用spring框架SimpleAsyncTaskExecutor
AsyncService.java
🎜rrreee🎜2를 정의합니다. 정의된 인터페이스 AsyncServiceImpl.java
🎜rrreee🎜🎜🎜 AsyncServiceImpl
은 spring
에서 관리하는 bean
입니다. 🎜🎜🎜🎜비동기 메서드는 공개되어야 하며 @Async
주석으로 장식되어야 합니다. 🎜🎜🎜🎜반환 유형은 void
또는 Future
로 제한됩니다. 🎜🎜🎜🎜3. 컨트롤러 정의 AsyncController.java
🎜rrreee🎜🎜🎜핵심은 비동기 @EnableAsync
를 활성화하는 주석을 추가하는 것입니다. 다른 곳에 추가되었습니다. 장소는 괜찮습니다. 🎜🎜🎜🎜이 인터페이스가 외부에서 호출되면 asyncMethod()
는 기본 작업 실행자가 생성한 다른 스레드에 의해 실행되며, 메인 스레드는 비동기 메서드가 완료될 때까지 기다릴 필요가 없습니다. 실행. 🎜🎜🎜🎜4. 실행해 보세요🎜🎜이제 실행하여 비동기적으로 반환되는지 확인해 보겠습니다. 🎜🎜

/async인터페이스, 마지막 단계에서는 메서드를 호출합니다. 🎜🎜<img src="/static/imghwm/default1.png" data-src="https://img.php.cn/upload/article/000/887/227/168390024926989.png?x-oss-process=image/resize,p_40" class="lazy" alt="SpringBoot가 비동기 호출을 우아하게 구현하는 방법">🎜🎜<img src="https://img.php.cn/upload/article/000/887/227/168390024955556.png" alt="SpringBoot가 비동기 호출을 우아하게 구현하는 방법">🎜🎜 <code>/asyncFuture
를 호출하고 반환이 5초 이상인 것을 발견했습니다. 비동기적이지 않나요? 실제로 로그에서 볼 수 있듯이 비동기식이기도 하지만 우리가 반환하는 것은 Future
이고 Futrue.get()
호출은 차단됩니다. 🎜🎜맞춤형 비동기 작업 실행기 및 예외 처리🎜🎜이제 예외 메서드에서 오류가 보고되면 어떻게 되는지 볼까요? 다음과 같이 비동기 코드를 수정하면 런타임 예외가 발생합니다. 🎜🎜
AsyncUncaughtExceptionHandler
를 구성해야 합니다. 🎜rrreee🎜다시 실행하면 결과는 다음과 같습니다. 🎜🎜
@를 사용하여 EnableAsync
주석은 기본 애플리케이션 클래스나 직접 또는 간접 비동기 메서드 호출자 클래스에 주석을 달아 비동기 지원을 활성화합니다. 주로 Proxy 모드를 통해 구현됩니다. 기본 모드는 Proxy
이고, 다른 모드는 AspectJ
입니다. 프록시 모드에서는 프록시를 통해서만 통화를 가로챌 수 있습니다. 정의된 동일한 클래스에서 비동기 메서드를 호출하지 마십시오. 작동하지 않습니다. 🎜🎜@Async
로 메서드에 주석을 추가하면 "proxyTargetClass
" 속성을 기반으로 개체에 대한 프록시가 생성됩니다. spring
이 이 메서드를 실행할 때 기본적으로 관련 스레드 풀 정의를 검색합니다. 컨텍스트에서 "taskExecutor
"라는 이름의 유일한 spring
프레임워크 TaskExecutor bean
또는 Executor bean
. 둘 다 해결할 수 없는 경우 기본적으로 스프링 프레임워크 SimpleAsyncTaskExecutor
가 사용되어 비동기 메서드 실행을 처리합니다. 🎜위 내용은 SpringBoot가 비동기 호출을 우아하게 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

이 기사에서는 Java 프로젝트 관리, 구축 자동화 및 종속성 해상도에 Maven 및 Gradle을 사용하여 접근 방식과 최적화 전략을 비교합니다.

이 기사에서는 Maven 및 Gradle과 같은 도구를 사용하여 적절한 버전 및 종속성 관리로 사용자 정의 Java 라이브러리 (JAR Files)를 작성하고 사용하는 것에 대해 설명합니다.

이 기사는 카페인 및 구아바 캐시를 사용하여 자바에서 다단계 캐싱을 구현하여 응용 프로그램 성능을 향상시키는 것에 대해 설명합니다. 구성 및 퇴거 정책 관리 Best Pra와 함께 설정, 통합 및 성능 이점을 다룹니다.

이 기사는 캐싱 및 게으른 하중과 같은 고급 기능을 사용하여 객체 관계 매핑에 JPA를 사용하는 것에 대해 설명합니다. 잠재적 인 함정을 강조하면서 성능을 최적화하기위한 설정, 엔티티 매핑 및 모범 사례를 다룹니다. [159 문자]

Java의 클래스 로딩에는 부트 스트랩, 확장 및 응용 프로그램 클래스 로더가있는 계층 적 시스템을 사용하여 클래스로드, 링크 및 초기화 클래스가 포함됩니다. 학부모 위임 모델은 핵심 클래스가 먼저로드되어 사용자 정의 클래스 LOA에 영향을 미치도록합니다.


핫 AI 도구

Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool
무료로 이미지를 벗다

Clothoff.io
AI 옷 제거제

AI Hentai Generator
AI Hentai를 무료로 생성하십시오.

인기 기사

뜨거운 도구

에디트플러스 중국어 크랙 버전
작은 크기, 구문 강조, 코드 프롬프트 기능을 지원하지 않음

WebStorm Mac 버전
유용한 JavaScript 개발 도구

안전한 시험 브라우저
안전한 시험 브라우저는 온라인 시험을 안전하게 치르기 위한 보안 브라우저 환경입니다. 이 소프트웨어는 모든 컴퓨터를 안전한 워크스테이션으로 바꿔줍니다. 이는 모든 유틸리티에 대한 액세스를 제어하고 학생들이 승인되지 않은 리소스를 사용하는 것을 방지합니다.

SublimeText3 영어 버전
권장 사항: Win 버전, 코드 프롬프트 지원!

스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경
