public class HttpClientResponseResult {
private int statusCode; //httpClient请求返回的状态码。0:失败;1:成功
private String responseContent; //httpClient请求返回成功或失败的内容
public int getStatusCode() {
return statusCode;
}
public void setStatusCode(int statusCode) {
this.statusCode = statusCode;
}
public String getResponseContent() {
return responseContent;
}
public void setResponseContent(String responseContent) {
this.responseContent = responseContent;
}
}
public class HttpClientUtil {
/**
* 进行模拟GET请求方法
* @paramurl
* @return
*/
public static HttpClientResponseResult requestGet(String url){
HttpClientResponseResult responseResult = new HttpClientResponseResult();
//生成HttpClinet对象并设置参数
CloseableHttpClient httpClient = HttpClients.createDefault();
//生成HttpGet对象并设置参数
HttpGet httpGet = new HttpGet(url);
//设置httpGet请求超时为 5 秒
RequestConfig requestConfig = RequestConfig.custom()
.setSocketTimeout(5000).setConnectTimeout(5000).build();
httpGet.setConfig(requestConfig);
// 定义返回对象
String jsonStr = "";
//执行 HTTP GET 请求
try {
CloseableHttpResponse httpResponse = httpClient.execute(httpGet);
//获取响应编码
int statusCode = httpResponse.getStatusLine().getStatusCode();
responseResult.setStatusCode(statusCode);
//解析响应内容
HttpEntity httpEntity = httpResponse.getEntity();
jsonStr = EntityUtils.toString(httpEntity,"UTF-8");
responseResult.setResponseContent(jsonStr);
} catch (IOException e) {
//发生网络异常
} finally {
//释放连接
httpGet.releaseConnection();
try {
httpClient.close();
} catch (IOException e) {
}
}
return responseResult;
}
/**
* 进行模拟POST请求方法
* @paramurl
* @paramparams
* @return
*/
public static HttpClientResponseResult requestPost(String url, Map<String,String> paramMap){
if(paramMap==null)
return null;
HttpClientResponseResult responseResult = new HttpClientResponseResult();
CloseableHttpClient httpClient = HttpClients.createDefault();
HttpPost httpPost = new HttpPost(url);
String jsonStr = "";
HttpEntity entity = null;
try {
entity = new StringEntity(new Gson().toJson(paramMap),ContentType.APPLICATION_JSON);//new UrlEncodedFormEntity(params, "UTF-8");
httpPost.setEntity(entity);
CloseableHttpResponse httpResponse = null;
httpResponse = httpClient.execute(httpPost);
int statusCode = httpResponse.getStatusLine().getStatusCode();
responseResult.setStatusCode(statusCode);
HttpEntity httpEntity = httpResponse.getEntity();
if (httpEntity != null) {
jsonStr = EntityUtils.toString(httpEntity,"UTF-8");
responseResult.setResponseContent(jsonStr);
}
} catch (IOException e) {
}finally{
httpPost.releaseConnection();
try {
httpClient.close();
} catch (IOException e) {
}
}
return responseResult;
}
}
版权声明:本文为wh_java01原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。