| | |
| | | package com.panzhihua.common.utlis; |
| | | |
| | | import java.io.*; |
| | | import java.net.HttpURLConnection; |
| | | import java.net.MalformedURLException; |
| | | import java.net.URL; |
| | | import java.net.URLConnection; |
| | | import java.security.KeyManagementException; |
| | | import java.security.KeyStore; |
| | | import java.security.KeyStoreException; |
| | | import java.security.NoSuchAlgorithmException; |
| | | import java.security.cert.CertificateException; |
| | | import java.security.cert.X509Certificate; |
| | | import java.util.Iterator; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | |
| | | import org.apache.http.HttpEntity; |
| | | import org.apache.http.HttpResponse; |
| | | import org.apache.http.client.HttpClient; |
| | | import org.apache.http.client.config.RequestConfig; |
| | | 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.methods.HttpUriRequest; |
| | | import org.apache.http.conn.ssl.NoopHostnameVerifier; |
| | | import org.apache.http.conn.ssl.SSLConnectionSocketFactory; |
| | | import org.apache.http.conn.ssl.TrustStrategy; |
| | | import org.apache.http.entity.StringEntity; |
| | | import org.apache.http.impl.client.CloseableHttpClient; |
| | | import org.apache.http.impl.client.DefaultHttpClient; |
| | |
| | | import lombok.extern.slf4j.Slf4j; |
| | | |
| | | import javax.net.ssl.SSLContext; |
| | | |
| | | import static com.panzhihua.common.utlis.wx.WXPayConstants.USER_AGENT; |
| | | |
| | | /** |
| | | * @program: springcloud_k8s_panzhihuazhihuishequ |
| | |
| | | HttpResponse httpResponse = defaultHttpClient.execute(httpGet); |
| | | if (httpResponse.getStatusLine().getStatusCode() != 200) { |
| | | String errorLog = "请求失败,errorCode:" + httpResponse.getStatusLine().getStatusCode(); |
| | | log.info(errorLog); |
| | | log.info("errorLog:{}"+errorLog); |
| | | throw new Exception(url + errorLog); |
| | | } |
| | | // 读取返回信息 |
| | |
| | | bufferedReader.close(); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * http请求工具类,post请求 |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | // HTTP GET请求 |
| | | public static String sendGet(String url) throws Exception { |
| | | URL obj = new URL(url); |
| | | HttpURLConnection con = (HttpURLConnection) obj.openConnection(); |
| | | //默认值GET |
| | | con.setRequestMethod("GET"); |
| | | //添加请求头 |
| | | con.setRequestProperty("User-Agent", USER_AGENT); |
| | | int responseCode = con.getResponseCode(); |
| | | log.info("发送 'GET' 请求到 URL:{}" + url); |
| | | log.info("Response Code:{}" + responseCode); |
| | | BufferedReader in = new BufferedReader( |
| | | new InputStreamReader(con.getInputStream())); |
| | | String inputLine; |
| | | StringBuffer response = new StringBuffer(); |
| | | while ((inputLine = in.readLine()) != null) { |
| | | response.append(inputLine); |
| | | } |
| | | in.close(); |
| | | //打印结果 |
| | | log.info("uu洗车返回:{}"+response.toString()); |
| | | return response.toString(); |
| | | } |
| | | |
| | | /** |
| | | * http请求工具类,post请求 |
| | |
| | | } |
| | | |
| | | /** |
| | | * get请求 |
| | | * |
| | | * @param url |
| | | * 请求地址(get请求时参数自己组装到url上) |
| | | * @param headerMap |
| | | * 请求头 |
| | | * @return 响应文本 |
| | | */ |
| | | public static String getUU(String url, Map<String, String> headerMap, String param) { |
| | | // 请求地址,以及参数设置 |
| | | HttpPost post = new HttpPost(url); |
| | | |
| | | SSLContext sslContext = null; |
| | | try { |
| | | sslContext = SSLContexts.custom().loadTrustMaterial(null, new TrustStrategy() { |
| | | @Override |
| | | public boolean isTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException { |
| | | return true; |
| | | } |
| | | }).build(); |
| | | } catch (NoSuchAlgorithmException e) { |
| | | e.printStackTrace(); |
| | | } catch (KeyManagementException e) { |
| | | e.printStackTrace(); |
| | | } catch (KeyStoreException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | |
| | | CloseableHttpClient client = HttpClients.custom().setSslcontext(sslContext). |
| | | setSSLHostnameVerifier(new NoopHostnameVerifier()).build(); |
| | | |
| | | |
| | | //请求超时时间设置 |
| | | post.setConfig(RequestConfig.custom()// 连接超时时间 |
| | | .setConnectTimeout(5000) |
| | | // 请求超时时间 |
| | | .setConnectionRequestTimeout(5000) |
| | | // Socket读取超时时间 |
| | | .setSocketTimeout(5000) |
| | | // 是否允许重定向 |
| | | .setRedirectsEnabled(false) |
| | | .build()); |
| | | |
| | | //发送请求 |
| | | CloseableHttpResponse response = null; |
| | | try { |
| | | response = client.execute(post); |
| | | } catch (IOException e) { |
| | | e.printStackTrace(); |
| | | log.error("request error. "); |
| | | |
| | | } |
| | | HttpEntity entity = response.getEntity(); |
| | | try { |
| | | if (entity != null) { |
| | | //按指定编码转换结果实体为String类型 |
| | | return EntityUtils.toString(entity, "UTF-8"); |
| | | } |
| | | } catch (IOException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | |
| | | return null; |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 获取响应信息(String) |
| | | */ |
| | | public static String getRespString(HttpUriRequest request) { |