java - Spring启动异步 Controller

Question

我有这个发布方法:

 @PostMapping("/upload")
        public String singleFileUpload(@RequestParam("file") MultipartFile file,RedirectAttributes redirectAttributes)
                throws IOException {
    ExecutorService service= Executors.newSingleThreadExecutor();
            Future<String> future=service.submit(new Callable<String>() {
                @Override
                public String call() throws Exception {
                    //parse file
                    Thread.sleep(5000);
                    return "done";
                }
            });
    String result=future.get();
     service.shutdown();
    return "redirect:uploadState";
    }

我想在执行程序解析我的文件时重定向到 uploadState，并且 uploadState 有长轮询 ajax 来通知解析是否完成。可以帮助我提供一些提示。

Answer 1

这里 future.get() 是拦截器。

您可以使用 Java 8 CompletableFuture :

CompletableFuture.supplyAsync(() -> {
    try{
   Thread.sleep(5000);
   return "done";
 }catch(Exception ex){}
}).thenApply((res->)->{
  return res;
});

它不会阻止您的控制。