从@Async函数调用获取数据

Question

大家好，我是java多线程新手。有人能帮我吗：

我的服务：

@Async
public List<String> doSomething(int a){
    //Do something
    return list;
}

SpringBoot应用程序：

@SpringBootApplication
@EnableAsync
public class Test {

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

}

异步配置：

@Configuration
@EnableAsync
public class AsyncConfig {

    @Bean(name ="taskExecutor")
    public Executor taskExecutor(){
        ThreadPoolTaskExecutor executor=new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(2);
        executor.setMaxPoolSize(2);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("userThread-");
        executor.initialize();
        return executor;
    }
}

控制器：

@RestController
public class Controller{
    
    @Autowired
    private Service service;

    @GetMapping("test")
    public List<String> getAll(){
        return service.doSomething(1);
    }
}

当我点击这个来自邮递员的get请求时，它在响应中显示为空白。我知道我的调用是异步进行的，响应甚至在调用我的方法之前就回来了。有没有办法通过更改邮递员或Spring启动应用程序中的一些设置来查看此响应

Answer 1

如果您想使用async，我会将您的单个请求分成所谓的“开始任务”和“获取任务结果”请求。您的应用程序为“开始任务”请求返回“请求id”。然后在执行“获取任务结果”时使用“请求id”。这种情况是批处理任务中的常见方式。如果您使用Spring，您可能会对Spring批处理框架感兴趣，该框架具有启动/停止/重启作业功能。

Answer 2

你可以回到未来。当CompleteableFuture完成时，您将收到http响应。

服务：

@Async
public CompletableFuture<List<String>> doSomething() {
    return CompletableFuture.completedFuture(Arrays.asList("1", "2", "3"));
} 

控制器：

@GetMapping("test")
public CompletableFuture<List<String>> getAll(){
    return service.getAll();
}

Answer 3

如果您希望异步处理请求，但也希望API客户端在完成处理后接收响应，这样从客户端的角度来看，请求处理看起来仍然是同步的，关键是使用Servlet3异步处理功能。

您不需要使用@Aysnc将其配置为在服务级别异步执行。而是将控制器方法配置为返回CompletableFuture。在封面下，它将触发Servlet3的异步请求处理，该处理将在接收请求的HTTP线程之外的另一个线程中处理该请求。

所以你的代码应该是这样的：

public class Service {
    
    //No need to add @Async
    public List<String> doSomething(int a){
        return list;
    }
}


@RestController
public class Controller{
    
    @Autowired
    private Service service;

    @GetMapping("test")
    public CompletableFuture<List<String>> getAll(){
        return CompletableFuture.supplyAsync(()->service.doSomething(1));
    }
}

有关spring mvc支持的Servlet3异步请求处理的详细信息，您可以参考本系列博客，从这里开始。