java发送http请求get/post
1,导入依赖
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.12</version>
</dependency>
2,http发送请求工具类
@Value("${spring.profiles.active}") 获取配置文件中对应的值
注解很详细
package com.hl.analyze.utils;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Maps;
import com.integration.utils.DateUtils;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import org.apache.http.Header;
import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import java.io.IOException;
import java.net.URI;
import java.text.DecimalFormat;
import java.time.LocalDateTime;
import java.util.*;
import java.util.stream.Collectors;
/**
* @program: sgitg-micro-service
* @description: HttpClient工具类
**/
@Component
@NoArgsConstructor(access = AccessLevel.PRIVATE)
public class HttpClientUtil {
private static final Logger log = LoggerFactory.getLogger(HttpClientUtil.class);
private final static String ACTIVE_TAG = "dev";
private static String active;
private static String loginUrl;
private static String loginUrlNew;
private static String userName;
private static String userNameNew;
private static String passWord;
private static String passWordNew;
private static String distributedPredictUrl;
private static String distribsunStationUrl;
@Value("${spring.profiles.active}")
public void setActive(String active) {
HttpClientUtil.active = active;
}
@Value("${hlkj.new-power-sys.login-url}")
public void setLoginUrl(String loginUrl) {
HttpClientUtil.loginUrl = loginUrl;
}
@Value("${hlkj.new-power-sys.login-url-new}")
public void setLoginUrlNew(String loginUrl) {
HttpClientUtil.loginUrlNew = loginUrl;
}
@Value("${hlkj.new-power-sys.user-name}")
public void setUserName(String userName) {
HttpClientUtil.userName = userName;
}
@Value("${hlkj.new-power-sys.user-name-new}")
public void setUserNameNew(String userName) {
HttpClientUtil.userNameNew = userName;
}
@Value("${hlkj.new-power-sys.pass-word}")
public void setPassWord(String passWord) {
HttpClientUtil.passWord = passWord;
}
@Value("${hlkj.new-power-sys.pass-word-new}")
public void setPassWordNew(String passWord) {
HttpClientUtil.passWordNew = passWord;
}
@Value("${hlkj.new-power-sys.distributed-predict-url}")
public void setDistributedPredictUrl(String distributedPredictUrl) {
HttpClientUtil.distributedPredictUrl = distributedPredictUrl;
}
@Value("${hlkj.new-power-sys.distribsun-station-url}")
public void setDistribsunStationUrl(String distribsunStationUrl) {
HttpClientUtil.distribsunStationUrl = distribsunStationUrl;
}
/**
* @return java.lang.String
* @Description get map参数
* @Date 2020/12/8 13:56
* @Param [url, param]
**/
public static String doGet(String url, Map<String, String> param) {
// 创建Httpclient对象
CloseableHttpClient httpclient = HttpClients.createDefault();
String resultString = "";
CloseableHttpResponse response = null;
try {
// 创建uri
URIBuilder builder = new URIBuilder(url);
if (param != null) {
for (String key : param.keySet()) {
builder.addParameter(key, param.get(key));
}
}
URI uri = builder.build();
// 创建http GET请求
HttpGet httpGet = new HttpGet(uri);
// 执行请求
response = httpclient.execute(httpGet);
// 判断返回状态是否为200
if (response.getStatusLine().getStatusCode() == 200) {
resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
}
} catch (Exception e) {
log.error(e.getMessage(), e);
} finally {
try {
if (response != null) {
response.close();
}
} catch (IOException e) {
log.error(e.getMessage(), e);
}
try {
httpclient.close();
} catch (IOException e) {
log.error(e.getMessage(), e);
}
}
return resultString;
}
public static String doGet(String url, Map<String, String> headMap, Map<String, String> param) {
// 创建Httpclient对象
CloseableHttpClient httpclient = HttpClients.createDefault();
String resultString = "";
CloseableHttpResponse response = null;
try {
// 创建uri
URIBuilder builder = new URIBuilder(url);
if (param != null) {
for (String key : param.keySet()) {
builder.addParameter(key, param.get(key));
}
}
URI uri = builder.build();
// 创建http GET请求
HttpGet httpGet = new HttpGet(uri);
// 执行请求
response = httpclient.execute(httpGet);
// 判断返回状态是否为200
if (response.getStatusLine().getStatusCode() == 200) {
resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
}
// 添加head参数
if (headMap != null && !headMap.isEmpty()) {
for (String key : headMap.keySet()) {
httpGet.addHeader(key, headMap.get(key));
}
}
} catch (Exception e) {
log.error(e.getMessage(), e);
} finally {
try {
if (response != null) {
response.close();
}
} catch (IOException e) {
log.error(e.getMessage(), e);
}
try {
httpclient.close();
} catch (IOException e) {
log.error(e.getMessage(), e);
}
}
return resultString;
}
/**
* @return java.lang.String
* @Description get无参
* @Date 2020/12/8 13:56
* @Param [url]
**/
public static String doGet(String url) {
return doGet(url, null);
}
/**
* @return java.lang.String
* @Description post map参数
* @Date 2020/12/8 13:56
* @Param [url, param]
**/
public static String doPost(String url, Map<String, String> param) {
log.debug("接口地址【{}】", url);
log.debug("接口参数【{}】", param);
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
CloseableHttpResponse response = null;
String resultString = "";
try {
// 创建Http Post请求
HttpPost httpPost = new HttpPost(url);
// 创建参数列表
if (param != null) {
List<NameValuePair> paramList = new ArrayList<>();
for (String key : param.keySet()) {
paramList.add(new BasicNameValuePair(key, param.get(key)));
}
// 模拟表单
UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList, "utf-8");
httpPost.setEntity(entity);
httpPost.setHeader("sppp-id", "fe8de0-3749-43b1-9b7e-e652763a682d");
}
// 执行http请求
response = httpClient.execute(httpPost);
resultString = EntityUtils.toString(response.getEntity(), "utf-8");
} catch (Exception e) {
log.error(e.getMessage(), e);
} finally {
try {
if (response != null) {
response.close();
}
} catch (IOException e) {
log.error(e.getMessage(), e);
}
try {
httpClient.close();
} catch (IOException e) {
log.error(e.getMessage(), e);
}
}
log.debug("接口返回值【{}】", resultString);
return resultString;
}
public static Header[] doPostForHeader(String url, Map<String, String> param) {
log.debug("接口地址【{}】", url);
log.debug("接口参数【{}】", param);
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
CloseableHttpResponse response = null;
Header[] allHeaders = new Header[0];
try {
// 创建Http Post请求
HttpPost httpPost = new HttpPost(url);
// 创建参数列表
if (param != null) {
List<NameValuePair> paramList = new ArrayList<>();
for (String key : param.keySet()) {
paramList.add(new BasicNameValuePair(key, param.get(key)));
}
// 模拟表单
UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList, "utf-8");
httpPost.setEntity(entity);
httpPost.setHeader("sppp-id", "fe8de0-3749-43b1-9b7e-e652763a682d");
}
// 执行http请求
response = httpClient.execute(httpPost);
allHeaders = response.getAllHeaders();
} catch (Exception e) {
log.error(e.getMessage(), e);
} finally {
try {
if (response != null) {
response.close();
}
} catch (IOException e) {
log.error(e.getMessage(), e);
}
try {
httpClient.close();
} catch (IOException e) {
log.error(e.getMessage(), e);
}
}
log.debug("返回值【{}】", allHeaders);
return allHeaders;
}
/**
* @return java.lang.String
* @Description post head map参数
* @Date 2021/04/28 15:15
* @Param [url, headMap, param]
**/
public static String doPost(String url, Map<String, String> headMap, Map<String, String> param) {
log.debug("接口地址【{}】", url);
log.debug("接口参数【{}】", param);
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
CloseableHttpResponse response = null;
String resultString = "";
try {
// 创建Http Post请求
HttpPost httpPost = new HttpPost(url);
// 创建参数列表
if (param != null) {
List<NameValuePair> paramList = new ArrayList<>();
for (String key : param.keySet()) {
paramList.add(new BasicNameValuePair(key, param.get(key)));
}
// 模拟表单
UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList, "utf-8");
httpPost.setEntity(entity);
}
// 添加head参数
if (headMap != null && !headMap.isEmpty()) {
for (String key : headMap.keySet()) {
httpPost.addHeader(key, headMap.get(key));
}
}
// 执行http请求
response = httpClient.execute(httpPost);
resultString = EntityUtils.toString(response.getEntity(), "utf-8");
} catch (Exception e) {
log.error(e.getMessage(), e);
} finally {
try {
if (response != null) {
response.close();
}
} catch (IOException e) {
log.error(e.getMessage(), e);
}
try {
httpClient.close();
} catch (IOException e) {
log.error(e.getMessage(), e);
}
}
log.debug("接口返回值【{}】", resultString);
return resultString;
}
public static String doPostByFormData(String url, Map<String, String> param) throws Exception {
log.debug("接口地址【{}】", url);
log.debug("接口参数【{}】", param);
String result = "";
CloseableHttpClient client = null;
CloseableHttpResponse response = null;
RequestConfig defaultRequestConfig = RequestConfig.custom().setSocketTimeout(6000).setConnectTimeout(5000)
.setConnectionRequestTimeout(6000).setStaleConnectionCheckEnabled(true).build();
client = HttpClients.custom().setDefaultRequestConfig(defaultRequestConfig).build();
// client = HttpClients.createDefault();
URIBuilder uriBuilder = new URIBuilder(url);
HttpPost httpPost = new HttpPost(uriBuilder.build());
httpPost.setHeader("Connection", "Keep-Alive");
httpPost.setHeader("Charset", "UTF-8");
httpPost.setHeader("Content-Type", "application/x-www-form-urlencoded");
Iterator<Map.Entry<String, String>> it = param.entrySet().iterator();
List<NameValuePair> params = new ArrayList<NameValuePair>();
while (it.hasNext()) {
Map.Entry<String, String> entry = it.next();
NameValuePair pair = new BasicNameValuePair(entry.getKey(), entry.getValue());
params.add(pair);
}
httpPost.setEntity(new UrlEncodedFormEntity(params, "UTF-8"));
try {
response = client.execute(httpPost);
if (response != null) {
log.debug("response 为空");
HttpEntity resEntity = response.getEntity();
if (resEntity != null) {
log.debug("resEntity 为空");
result = EntityUtils.toString(resEntity, "UTF-8");
}
}
} catch (ClientProtocolException e) {
throw new RuntimeException("创建连接失败" + e);
} catch (IOException e) {
throw new RuntimeException("创建连接失败" + e);
} finally {
try {
if (response != null) {
response.close();
}
} catch (IOException e) {
log.error(e.getMessage(), e);
}
try {
client.close();
} catch (IOException e) {
log.error(e.getMessage(), e);
}
}
log.debug("接口返回值【{}】", result);
return result;
}
public static String doPost(String url) {
return doPost(url, null);
}
/**
* @return java.lang.String
* @Description post json参数
* @Date 2020/12/8 13:56
* @Param [url, param]
**/
public static String doPostJson(String url, String json) {
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
CloseableHttpResponse response = null;
String resultString = "";
try {
// 创建Http Post请求
HttpPost httpPost = new HttpPost(url);
// 创建请求内容
StringEntity entity = new StringEntity(json, ContentType.APPLICATION_JSON);
httpPost.setEntity(entity);
// 执行http请求
response = httpClient.execute(httpPost);
resultString = EntityUtils.toString(response.getEntity(), "utf-8");
} catch (Exception e) {
log.error(e.getMessage(), e);
} finally {
try {
if (response != null) {
response.close();
}
} catch (IOException e) {
log.error(e.getMessage(), e);
}
try {
httpClient.close();
} catch (IOException e) {
log.error(e.getMessage(), e);
}
}
return resultString;
}
public static String doPostJson(String url, Map<String, String> headMap, String json) {
log.info("请求地址:{}",url);
log.info("请求头:{}",headMap);
log.info("请求参数:{}",json);
// 创建Httpclient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
CloseableHttpResponse response = null;
String resultString = "";
try {
// 创建Http Post请求
HttpPost httpPost = new HttpPost(url);
// 添加head参数
if (headMap != null && !headMap.isEmpty()) {
for (String key : headMap.keySet()) {
httpPost.addHeader(key, headMap.get(key));
}
}
// 创建请求内容
StringEntity entity = new StringEntity(json, ContentType.APPLICATION_JSON);
httpPost.setEntity(entity);
// 执行http请求
response = httpClient.execute(httpPost);
resultString = EntityUtils.toString(response.getEntity(), "utf-8");
} catch (Exception e) {
log.error(e.getMessage(), e);
} finally {
try {
if (response != null) {
response.close();
}
} catch (IOException e) {
log.error(e.getMessage(), e);
}
try {
httpClient.close();
} catch (IOException e) {
log.error(e.getMessage(), e);
}
}
log.info("返回值:{}",resultString);
return resultString;
}
public static String getNewPowerSysCookie() {
if (ACTIVE_TAG.equals(active)) {
return "cookie";
} else {
try {
Header[] headers = HttpClientUtil.doPostForHeader(loginUrl, new HashMap<String, String>() {{
put("username", userName);
put("password", passWord);
}});
Map<Object, Object> objectMap = Arrays.stream(headers).collect(Collectors.toMap(NameValuePair::getName, NameValuePair::getValue, (e1, e2) -> e1));
String cookie = objectMap.get("Set-Cookie").toString();
log.debug(String.valueOf(objectMap));
log.debug("date:{}====================cookie:{}===========", LocalDateTime.now(), cookie);
return cookie;
}catch (Exception e){
e.printStackTrace();
log.error("新能源接口异常，请检查新能源系统是否正常！");
return "null";
}
}
}
public static String getAuthorization() {
if (ACTIVE_TAG.equals(active)) {
return "Authorization";
} else {
try {
log.info("userNameNew=" + userNameNew);
log.info("passWordNew=" + passWordNew);
log.info("loginUrlNew=" + loginUrlNew);
Header[] headers = HttpClientUtil.doPostForHeader(loginUrlNew, new HashMap<String, String>() {{
put("username", userNameNew);
put("password", passWordNew);
put("type", "0");
}});
log.info("headers=" + headers.toString());
String res = HttpClientUtil.doPost(loginUrlNew, new HashMap<String, String>() {{
put("username", userNameNew);
put("password", passWordNew);
put("type", "0");
}});
log.info("loginUrlNewRes=" + String.valueOf(res));
JSONObject jsonObject = JSONObject.parseObject(res);
String token = jsonObject.get("token").toString();
String Authorization = "Bearer " + token;
/*Map<Object, Object> objectMap = Arrays.stream(headers).collect(Collectors.toMap(NameValuePair::getName, NameValuePair::getValue, (e1, e2) -> e1));
String cookie = objectMap.get("Set-Cookie").toString();*/
log.info("AuthorizationSet=" + String.valueOf(Authorization));
log.info("date:{}====================cookie:{}===========", LocalDateTime.now(), Authorization);
return Authorization;
}catch (Exception e){
e.printStackTrace();
log.error("可开放容量监测接口异常，请检查新能源系统是否正常！");
return "null";
}
}
}
public static String getNewEnergyPower(String scheduleId, String scheduleName) {
if (ACTIVE_TAG.equals(active)) {
return "222.33";
} else {
// 德州所有用户在某刻的瞬时功率
String realTimePower = "";
// 获取token
String newPowerSysCookie = HttpClientUtil.getNewPowerSysCookie();
try {
Map<String, String> map = Maps.newHashMapWithExpectedSize(6);
Map<String, String> hMap = Maps.newHashMapWithExpectedSize(6);
map.put("scheduleId", scheduleId);
map.put("scheduleName", scheduleName);
map.put("beginTime", com.integration.utils.DateUtils.parseDate(new Date(), "yyyy-MM-dd"));
map.put("endTime", com.integration.utils.DateUtils.parseDate(new Date(), "yyyy-MM-dd"));
map.put("distribsunStationId", "");
map.put("distribsunStationName", "");
hMap.put("Cookie", newPowerSysCookie);
// 接口返回值
String postRes = HttpClientUtil.doPost(distributedPredictUrl, hMap, map);
JSONObject objMap = (JSONObject) JSONObject.parseObject(postRes).get("obj");
JSONArray lineData = (JSONArray) objMap.get("linedata");
JSONArray tabledata = (JSONArray) objMap.get("tabledata");
Double value = 0.0;
for (int i = 0; i < tabledata.size(); i++) {
JSONObject data = (JSONObject) tabledata.get(i);
String hours = data.get("time").toString();
// 当前是几点
String nowHours = DateUtils.parseDate(new Date(), "yyyy-MM-dd HH:mm:ss").split(" ")[1].split(":")[0];
if (hours.contains(nowHours + ":00:00")) {
value = value + Double.parseDouble("-".equals(data.get("data").toString())?"0":data.get("data").toString());
log.debug("德州所有用户的的瞬时功率值：{}", value);
break;
}
}
if (value == 0.0) {
realTimePower = lineData.get(lineData.indexOf("-") - 1).toString();
} else {
DecimalFormat decimalFormat = new DecimalFormat("0.00");
realTimePower = decimalFormat.format(value);
}
} catch (Exception e) {
log.error("新能源接口异常" + e.getMessage(), e);
}
return realTimePower;
}
}
}
