У меня есть приложение api для весенней загрузки, которое имеет конечную точку POST, давайте назовем его / doSomething как метод. При получении запроса для конечной точки / doSomething мне нужно сохранить эти данные в нашем приложении, а затем нужно сделать запрос GET для другого api [A] с этим запросом нужно ПОЛУЧИТЬ из API [B], а затем снова отправить в API [B]. В этом случае, каков наилучший способ обработать повторную попытку Spring.
Пожалуйста, найдите приведенный ниже код
@RequestMapping(value = "/subpub", method = RequestMethod.POST, headers = {"content-type=application/x-www-form-urlencoded"})
public String subPub(HttpServletRequest request, HttpServletResponse response, @RequestBody String rawBody) {
//persists some data on this database
//this method will invoke api[A] and api[B]
integrationServiceBean.processCourseMetaData("_id");
return "OK"
};
IntegrationServiceBean класс
package com.org.reader.integration;
@Service
public class IntegrationServiceBean {
/**
* This method will process meta data submission for
* section details by section id and update meta data
*
* @param sectionId
*/
@Retryable(RuntimeException.class)
public void processCourseMetaData(final String sectionId) {
System.out.println("Invoking processCourseMetaData");
ResponseEntity<String> responseEntity = registrarService.findOneSection(sectionId);
String responseBody = responseEntity.getBody();
LinkedHashMap requestObj = (LinkedHashMap) JsonUtils.jsonToObject(responseBody);
LinkedHashMap metaDataObj = (LinkedHashMap) requestObj.get(Constant.Response.META_DATA);
if (!contextConfig.getMetaDataCopyable().isEmpty()) {
metaDataObj.put(Constant.MetaData.COPYABLE, contextConfig.getMetaDataCopyable());
}
if (!contextConfig.getMetaDataPending().isEmpty()) {
metaDataObj.put(Constant.MetaData.PENDING, contextConfig.getMetaDataPending());
}
metaDataObj.put(Constant.MetaData.LAUNCH_URL, getLaunchUrlByEnvironment(requestObj, sectionId));
String updatedSectionPayload = JsonUtils.toJsonString(requestObj);
registrarService.updateSection(sectionId, updatedSectionPayload);
}
@Recover
public void recover(RuntimeException e){
System.out.println("Recovering - returning safe value"+e.getMessage());
}
}
Моя проблема в том, что если для компонента службы интеграции применяется повторная попытка, это повлияет на производительность основной части приложения, например, для сохранения данных в основной конечной точке.
И что было бы лучше всего
