工具类实现
@Component
public class RestTemplateUtil {
private static final Logger logger = LoggerFactory.getLogger(RestTemplateUtil.class);
@Resource
private UnimisConfig unimisConfig;
// 参见RestTemplate配置
@Resource(name = "restTemplate")
private RestTemplate restTemplate;
/**
* @param responseBodyType 返回体类型
* @param requestBody 请求体
* @return {@link T }
* @Description post请求
* @author wangwenying
* @date 2023-09-22
*/
public <T, A> T doPost(Class<T> responseBodyType, A requestBody, UnimisReqEnum reqType) {
try {
//请求添加token头
HttpHeaders headers = new HttpHeaders();
headers.add(UnimisConstants.APP_ID, unimisConfig.getAppId());
headers.add(UnimisConstants.APP_SECRET, unimisConfig.getAppSecret());
MimeType mimeType = MimeTypeUtils.parseMimeType("application/json");
MediaType mediaType = new MediaType(mimeType.getType(), mimeType.getSubtype(), StandardCharsets.UTF_8);
// 请求体
headers.setContentType(mediaType);
HttpEntity<A> requestEntity = new HttpEntity<>(requestBody, headers);
String url = unimisConfig.obtainRequestUrl(reqType);
logger.info("url:{} HttpEntity:{}", url, JacksonUtils.toJson(requestEntity));
ResponseEntity<T> resEntity = restTemplate.exchange(unimisConfig.obtainRequestUrl(reqType), HttpMethod.POST, requestEntity, responseBodyType);
logger.info("resEntity:{}", JacksonUtils.toJson(resEntity));
//请求结果
HttpStatus statusCode = resEntity.getStatusCode();
if (statusCode == HttpStatus.OK) {
Optional<T> body = Optional.ofNullable(resEntity.getBody());
if (body.isPresent()) {
return body.get();
}
}
} catch (Exception e) {
logger.error("Class: RestTemplateUtil; method: doPost; params:{}", JacksonUtils.toJson(responseBodyType, requestBody), e);
return null;
}
return null;
}
/**
* @param responseBodyType 返回类型
* @param requestBody 请求体
* @param uri 请求地址
* @return {@link T }
* @Description get请求
* @author wangwenying
* @date 2023-10-11
*/
public <T, A> T doGet(Class<T> responseBodyType, A requestBody, URI uri, MediaType mediaType) {
try {
logger.info("uri:{}", uri);
//请求添加token头
HttpHeaders headers = new HttpHeaders();
headers.setContentType(mediaType);
HttpEntity<A> requestEntity = new HttpEntity<>(requestBody, headers);
ResponseEntity<T> resEntity = restTemplate.exchange(uri, HttpMethod.GET, requestEntity, responseBodyType);
logger.info("resEntity:{}", resEntity);
//请求结果
HttpStatus statusCode = resEntity.getStatusCode();
if (statusCode == HttpStatus.OK) {
Optional<T> body = Optional.ofNullable(resEntity.getBody());
if (body.isPresent()) {
return body.get();
}
}
} catch (Exception e) {
logger.error("Class: RestTemplateUtil; method: doGet; uri:{}", uri, e);
return null;
}
return null;
}
}