public RmiRespBase sendHttpRes(String jsonParamStr, String url, String apiName,String systemId,String apiUrl) {
sendLog(apiName,url + apiUrl,jsonParamStr,null); //自定义日志方法
//设置请求头headers
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
//将headers和参数 json放入entity对象中
HttpEntity<String> entity = new HttpEntity<>(jsonParamStr, headers);
//设置连接超时时间
SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
requestFactory.setConnectTimeout(Integer.valueOf(timeoutvalue));
requestFactory.setReadTimeout(Integer.valueOf(timeoutvalue));
//创建远程调用api,并构造连接超时的设置
restTemplate = new RestTemplate(requestFactory);
//调用,并返回
JSONObject body = restTemplate.postForEntity(url + apiUrl, entity, JSONObject.class).getBody();
//自定义逻辑,返回结果
RmiRespBase respBase = new RmiRespBase(url + apiUrl, apiName, systemId, body);
sendLog(apiName,url + apiUrl,jsonParamStr,body.toJSONString()); //自定义日志方法
return respBase;
}
/**
* 描述:
* 基础Http调用
* @Param [jsonParamStr, url, apiName, systemId, apiUrl]
**/
public RmiRespBase sendHttpRes(String jsonParamStr, String url, String apiName,String systemId,String apiUrl) {
sendLog(apiName,url + apiUrl,jsonParamStr,null);
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
HttpEntity<String> entity = new HttpEntity<>(jsonParamStr, headers);
//设置连接超时时间
SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
requestFactory.setConnectTimeout(Integer.valueOf(timeoutvalue));
requestFactory.setReadTimeout(Integer.valueOf(timeoutvalue));
restTemplate = new RestTemplate(requestFactory);
JSONObject body = restTemplate.postForEntity(url + apiUrl, entity, JSONObject.class).getBody();
RmiRespBase respBase = new RmiRespBase(url + apiUrl, apiName, systemId, body);
sendLog(apiName,url + apiUrl,jsonParamStr,body.toJSONString());
return respBase;
}