Блог

Я понимаю некоторые идеи асинхронных сервисов, но не так много их закодировал, поэтому механика, особенно в Java, для меня нова. В принципе, у меня есть давно работающая служба, которую я хочу передать другому потоку и иметь возможность проверить ее состояние с помощью другой службы. На данный момент я могу приступить к работе, у меня пока нет возможности проверить это. Но хуже:

В почтовой службе asyncUploadSoftLayerFile ниже:

 @RestController
@RequestMapping("/")
public class MyController {
   ...
    @ResponseStatus(HttpStatus.CREATED)
    @PostMapping("/async-files")
    public DeferredResult<ResponseEntity<JobExecutionResult>>       asyncUploadSoftLayerFile(@RequestParam MultipartFile file) throws JobParametersInvalidException, JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException, IOException, JobExecutionAlreadyRunningException{
        logger.info("Received async-CompleteableFuture request");
        DeferredResult<ResponseEntity<JobExecutionResult>> output = new DeferredResult<ResponseEntity<JobExecutionResult>>();
        ForkJoinPool.commonPool().submit(() -> {
            logger.info("Processing in separate thread: Thread-ID=" Thread.currentThread().getId());

            JobExecutionResult jobExecutionResult = null;
            try {
                myReallyLongRunningProcess();
            } catch (JobParametersInvalidException | JobExecutionAlreadyRunningException | JobRestartException
                    | JobInstanceAlreadyCompleteException | IOException e) {
                logger.error("Error processing /async-files upload in Thread-ID: " Thread.currentThread().getId(),e);
                throw new RuntimeException(e);
            }
            if (!"COMPLETED".equals(jobExecutionResult.getExitStatus())) {
                throw new UploadFileException(file.getOriginalFilename()   " exit status: "   jobExecutionResult.getExitStatus());
            }
            ResponseEntity<JobExecutionResult> responseEntity = ResponseEntity.ok(jobExecutionResult);
            output.setResult(responseEntity);
        });
        
        return output;
    }
}
 

Весна действительно делает то, что откладывается, и я вижу, что она породила работу в другом потоке. Но он не вернулся обратно к звонящему. Вместо этого я увидел:

 2021-07-27 05:20:00 DEBUG o.s.web.servlet.DispatcherServlet - Exiting but response remains open for further handling
 

Так что это лишь частично дало мне то, что я хотел. Как я могу заставить Spring перенести работу в другой поток (и в идеале иметь возможность ссылаться на этот процесс с помощью другого вызова веб-службы), но сразу же возвращать какой-либо ответ веб-браузеру?

Это часть усилий, направленных на то, чтобы начать работу, но отслеживать процент завершения по мере ее выполнения.