Будет ли асинхронный HTTP-запрос разрешать тайм-аут сервера? ⇐ JAVA

[Anonymous]

У меня есть сервер A, который отправляет запрос на сервер B, используя метод выполнения CloseableHttpClient.
Когда сервер B продолжает обработку запроса, он пытается отправить запрос на сервер A (перед возвратом ответа), используя postForEntity RestTemplate. И я получаю исключение тайм-аута на сервере A (я думаю, это из-за какой-то циклической зависимости с точки зрения запросов). Итак, решит ли эту проблему введение AsyncRestTemplate postFroEntity на сервере B?
Чтобы объяснить, зачем мне такая логика, мне нужно вызвать конечную точку сервера A с сервера B для записи данных в базу данных серверу A, что процесс на сервере B действительно начался.
Я думал об использовании асинхронных запросов на обоих концах: на сервере A, который вызывает сервер B, и на сервере B, который находится в середине процесс вызывает Сервер А. Но не приведет ли это к какому-то несоответствию данных? И я думаю, что решением моего вопроса будет использование Kafka или RabbitMQ, но, возможно, есть более простой способ решения моей проблемы?
Вот несколько фрагментов кода для дальнейшего объяснения:
Сервер А:
try (CloseableHttpClient client = HttpClients.createDefault()) {

log.info("******* start outBoundDocument URL: " + DATA_CENTER_URL + "/rest/api/outbound-documents");
HttpPost httpPost = new HttpPost(DATA_CENTER_URL + "/rest/api/outbound-documents");
httpPost.setHeader("Accept-Encoding", "UTF-8");
httpPost.setHeader("Content-type", "application/json");
httpPost.setHeader("Accept", "application/json");

// Add the hostname as a custom header
httpPost.setHeader("X-Sender-Host", SYNERGY_URL);

UsernamePasswordCredentials credentials = new
UsernamePasswordCredentials(USERNAME, PASSWORD);
httpPost.addHeader(new BasicScheme().authenticate(credentials, httpPost, null));

String json = new ObjectMapper().writeValueAsString(document);
log.info("******** outBoundDocument send JSON=" + json);
httpPost.setEntity(new StringEntity(json, ContentType.APPLICATION_JSON));

CloseableHttpResponse response = client.execute(httpPost);// here we request Server B

if (response.getStatusLine().getStatusCode() != 200) {
byte[] bytes =
IOUtils.toByteArray(response.getEntity().getContent());
log.error("******** outBoundDocument " + new
String(bytes, StandardCharsets.UTF_8));

}

} catch (IOException | AuthenticationException e) {
log.error(e.getMessage(), e);
}


Сервер Б:
// some received DTO manipulations:

// here we call for Server A to write in it's DB that process on Server B has started
ResponseEntity responseEntity = restTemplate.postForEntity(
fullUrl,// basically the host:port and endpoint to server A
logRecord,
ErrorInfoDto.class
);
putOutboundDocument(docOutgoing);// sends SOAP request
return new OkDto();



Подробнее здесь: https://stackoverflow.com/questions/790 ... er-timeout