如何在Spring Boot中处理来自外部API的即时响应和单个控制器中的回调响应？

问：

我有一个控制器，我试图从中尝试使用标头和请求正文触发 POST 外部 api 调用。

外部 API URL 示例：

http://sample:7070/test

示例标头：

Content-type: application/json
Authorization : someEncryptedData
CallBack: http://mycallback:8080/sendCallback

样品主体：

{
"A": {
    "B": 100,
    "C": "TEST",
},
"ReceiverParty": {
    "A": 41,
    "D": "123214526"
},
"Reference": [
    {
        "Key": "A",
        "Value": "B"
    }
]
}

现在，此 api 将在触发时发送即时响应。此外，它还将向标头中提供的回调 url（POST） 发送另一个响应。

我想在一个控制器中获得两个响应。获得它的方法是什么？请参考任何主题博客以更好地理解。

我的示例代码：

@RestController
@RequestMapping("/main")
public class MainController {

@Autowired
private RestTemplate restTemplate;

@PostMapping("/call-api")
public ResponseEntity<String> callApi() {
    HttpHeaders headers = new HttpHeaders();
    headers.setContentType(MediaType.APPLICATION_JSON);

    // Create the request body
    SamplePlayload requestPayload = createRequestPayload();

    HttpEntity<SamplePlayload> requestEntity = new HttpEntity<>(requestPayload, headers);

    ResponseEntity<String> responseEntity = restTemplate.exchange(
            "http://sample:7070/test",
            HttpMethod.POST,
            requestEntity,
            String.class
    );

    String initialResponse = responseEntity.getBody();
    System.out.println("Received initial response: " + initialResponse);

    String callbackUrl = "http://mycallback:8080/sendCallback"; 

    CompletableFuture.supplyAsync(() -> restTemplate.postForObject(callbackUrl, 
    requestPayload, String.class))
            .thenAccept(callbackResponse -> {
                System.out.println("Received callback response: " + 
    callbackResponse);
                // Perform further actions as needed
            });

    return responseEntity;
}

private SamplePlayload createRequestPayload() {
    //make the request body
}

回调控制器：

@RestController
@RequestMapping("/sendCallback")
public class CallbackController {

@PostMapping
public void handleCallback(@RequestBody CallbackResponse callbackResponse) {
    // Process the callback response
    System.out.println("Received callback response: " + callbackResponse);
    // Perform further actions as needed
    }
}

即时响应示例：

{
"Header": {
//some elements
},
"Body": {
//Some elements
}
}

回调响应示例：

{
"Header": {
//some elements
},
"Body": {
//Some elements
}
}