Spring调用方法捕获@async方法引发的异常

Question

TestController使用一个TestService，它有一个Spring@async asyncComp.getGood（s）方法。当输入字符串不是“good”时，会引发异常。TestController将获得异常，在其余响应中，状态500内部服务器错误。我找不到我项目的确切代码，但找到了一些关于使用CompletableFuture的想法。在答案区域，我发布了我写的作为测试应用程序的内容，它以我想要的方式工作。

Answer 1

这是我的测试代码，它允许控制器获取异步方法引发的异常。

@SpringBootApplication
public class AsyncApplication {

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

}

@Configuration
@EnableAsync()
@ComponentScan
public class SpringAsyncConfig implements AsyncConfigurer {
    @Bean(name = "threadPoolTaskExecutor")
    public Executor threadPoolTaskExecutor() {
        return new ThreadPoolTaskExecutor();
    }

    @Override
    public Executor getAsyncExecutor() {
        return new SimpleAsyncTaskExecutor();
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new CustomAsyncExceptionHandler();
    }
}

@RestController
public class TestController {
   
    @Autowired
    TestService service; 
    
    @GetMapping("/test")
    public String test() throws Exception {
        return service.getGood("bad");
        
    }
    
}

@Service
public class TestService {
    
    @Autowired
    AsyncComponent asyncComp;
    
    public String getGood(String s) throws Exception {
        
            CompletableFuture<String> result = asyncComp.getGood(s);
            return result.get();
        
    }
    

}

@Component
public class AsyncComponent {

    
    @Async
    public CompletableFuture<String> getGood(String s) throws Exception {
        if (s.equalsIgnoreCase("good")) {
            return CompletableFuture.completedFuture(s);
        } else {
            throw new Exception("test exception");
        }

    }

}

pom。xml

    <?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.5.4</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.aaa</groupId>
    <artifactId>async</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>Async</name>
    <description>async</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>