如何让Java Rest API在前半部分处理后返回响应，然后在返回响应后继续后半部分？

Question

我有一个使用Spring Boot的APIendpoint。这个endpoint所做的是调用另外两个APIendpoint并处理它们的响应。

该过程的前半部分调用一个 API 终结点，获取响应并将此响应与 202 Accepted 一起返回到表面。

在202被返回之后，后台正在经历该过程的第二部分。它从第一个API调用中获取响应并进一步处理它。

我尝试过使用Executor或ComppletableFuture，但它们在返回202之后都停止了，并且不会运行下半部分，或者他们等到下半部分才能完成，只返回202。

这有可能实现吗？还是我在寻找错误的设计？

以下是一些示例代码：

@PostMapping("/user")
public ResponseEntity<?> processUser(@Valid @RequestBody UserRequestDto request,
                                            @RequestHeader("Authorization") String token) throws Exception {
    CompletableFuture<UserResponseDto> response = CompletableFuture.supplyAsync(() ->
            userService.processUser(request, token));
        
    userService.processUserSecond(response, token);

    return new ResponseEntity<>(response, HttpStatus.ACCEPTED);
}

Answer 1

要明确一点：RESTendpoint由两个调用组成-＜code＞processUser。您希望获得＜code＞processUser

请记住，在这种情况下，第一次调用必须是同步的，因为您等待其结果在后续调用中使用。后者可以是异步的。

@PostMapping("/user")
public ResponseEntity<?> processUser(@Valid @RequestBody UserRequestDto request,
                                            @RequestHeader("Authorization") String token) 
{
   // synchronous, waiting for the response to be used
   UserResponseDto response = userService.processUser(request, token);

   // asynchronous, fired without waiting for the response
   CompletableFuture.runAsync(() -> userService.processUserSecond(response, token));
       
   // return the result of the first (an only) synchronous call 
   return new ResponseEntity<>(response, HttpStatus.ACCEPTED);
}