http请求

心已赠人 2022-01-15 01:23 401阅读 0赞

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

import java.io.*;
import java.net.*;
import java.security.KeyManagementException;
import java.security.KeyStore;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.security.UnrecoverableKeyException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;

import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;

import org.apache.commons.httpclient.HttpException;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.http.*;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
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.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ClientConnectionManager;
import org.apache.http.conn.params.ConnRoutePNames;
import org.apache.http.conn.scheme.PlainSocketFactory;
import org.apache.http.conn.scheme.Scheme;
import org.apache.http.conn.scheme.SchemeRegistry;
import org.apache.http.conn.ssl.*;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager;
import org.apache.http.params.BasicHttpParams;
import org.apache.http.params.CoreConnectionPNames;
import org.apache.http.params.HttpParams;
import org.apache.http.params.HttpProtocolParams;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;

@SuppressWarnings(“deprecation”)
public class HttpUtil {

  1. //注册端口  
  2. //private static int port = 443;  
  3. //超时时间（毫秒）  
  4. private final static int CONNECTION\_TIME\_OUT = 10000;
  6. public static final int READDATA\_TIMEOUT = 10000;// 数据读取等待超时
  8. protected static Log log = LogFactory.getLog(HttpUtil.class);
  10. public synchronized static String sendDataByGet(String url,  
  11.                                                 Map<String, String> params, boolean enableProxy, int timeout) \{
  13.     if (params != null && params.size() > 0) \{  
  14.         StringBuffer sb = new StringBuffer();  
  15.         Set<Entry<String, String>> set = params.entrySet();  
  16.         for (Iterator<Entry<String, String>> iterator = set.iterator(); iterator.hasNext(); ) \{  
  17.             Entry<String, String> entry = (Entry<String, String>) iterator.next();  
  18.             sb.append("&" + entry.getKey() + "=" + URLEncoder.encode(entry.getValue()));  
  19.         \}  
  20.         if (url.indexOf("?") == -1) \{  
  21.             sb.deleteCharAt(0);  
  22.             url = url + "?" + sb.toString();  
  23.         \} else \{  
  24.             url = url + sb.toString();  
  25.         \}  
  26.     \}
  28.     DefaultHttpClient client = null;
  30.     if (client == null) \{  
  31.         client = createHttpClient(timeout);  
  32.     \}
  34.     if (enableProxy) \{  
  35.         HttpHost host = new HttpHost("10.37.84.16", 80);  
  36.         client.getParams().setParameter(ConnRoutePNames.DEFAULT\_PROXY, host);  
  37.         client.getCredentialsProvider().setCredentials(new AuthScope("10.37.84.16", 80), new UsernamePasswordCredentials("um", "密码"));  
  38.     \}  
  39.     HttpGet get = new HttpGet(url);  
  40.     HttpResponse resp = null;  
  41.     String result = null;  
  42.     try \{  
  43.         resp = client.execute(get);  
  44.         if (resp.getStatusLine().getStatusCode() == HttpStatus.SC\_OK  
  45.                 || resp.getStatusLine().getStatusCode() == 400) \{  
  46.             result = EntityUtils.toString(resp.getEntity(), HTTP.UTF\_8);  
  47.             System.out.println(result);  
  48.         \}  
  49.     \} catch (UnsupportedEncodingException e) \{  
  50.         e.printStackTrace();  
  51.     \} catch (ClientProtocolException e) \{  
  52.         e.printStackTrace();  
  53.     \} catch (IOException e) \{
  55.         e.printStackTrace();  
  56.     \} catch (Exception e) \{
  58.         e.printStackTrace();  
  59.     \}  
  60.     return result;  
  61. \}
  63. public synchronized static String sendDataByPost(String url,  
  64.                                                  List<NameValuePair> datas, boolean enableProxy, int timeout) \{  
  65.     DefaultHttpClient client = null;
  67.     if (client == null) \{  
  68.         client = createHttpClient(timeout);  
  69.     \}  
  70.     if (enableProxy) \{  
  71.         HttpHost host = new HttpHost("10.37.84.16", 80);  
  72.         client.getParams().setParameter(ConnRoutePNames.DEFAULT\_PROXY, host);  
  73.         client.getCredentialsProvider().setCredentials(new AuthScope("10.37.84.16", 80), new UsernamePasswordCredentials("gengqian499", "gq1234!@\#$"));  
  74.     \}  
  75.     HttpPost post = new HttpPost(url);
  77.     HttpResponse resp = null;  
  78.     String result = null;  
  79.     try \{  
  80.         post.setEntity(new UrlEncodedFormEntity(datas, HTTP.UTF\_8));  
  81.         resp = client.execute(post);  
  82.         if (resp.getStatusLine().getStatusCode() == HttpStatus.SC\_OK  
  83.                 || resp.getStatusLine().getStatusCode() == 400) \{  
  84.             result = EntityUtils.toString(resp.getEntity(), HTTP.UTF\_8);  
  85.             System.out.println(result);  
  86.         \}  
  87.     \} catch (UnsupportedEncodingException e) \{  
  88.         e.printStackTrace();  
  89.     \} catch (ClientProtocolException e) \{  
  90.         e.printStackTrace();  
  91.     \} catch (IOException e) \{
  93.         e.printStackTrace();  
  94.     \} catch (Exception e) \{
  96.         e.printStackTrace();  
  97.     \}  
  98.     return result;  
  99. \}  
  100. public static String doGet(String url) throws IOException \{  
  101.     CloseableHttpClient httpClient = HttpClients.createDefault();  
  102.     HttpGet httpGet = new HttpGet(url);  
  103.     RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(CONNECTION\_TIME\_OUT).setConnectTimeout(CONNECTION\_TIME\_OUT).build();  
  104.     httpGet.setConfig(requestConfig);  
  105.     try \{  
  106.         HttpResponse resp = httpClient.execute(httpGet);  
  107.         String result = EntityUtils.toString(resp.getEntity(), HTTP.UTF\_8);  
  108.         int statusCode = resp.getStatusLine().getStatusCode();  
  109.         if (statusCode == HttpStatus.SC\_OK) \{  
  110.             return result;  
  111.         \} else \{  
  112.             throw new HttpException("Unsuccessful request -------->  The response is statusCode= " + statusCode + " and message= " + result);  
  113.         \}  
  114.     \} finally \{  
  115.         httpClient.close();  
  116.     \}  
  117. \}
  119. private static DefaultHttpClient createHttpClient(int soTimeout) \{  
  120.     if (soTimeout == 0) \{  
  121.         soTimeout = CONNECTION\_TIME\_OUT;  
  122.     \}  
  123.     try \{  
  124.         HttpParams params = new BasicHttpParams();  
  125.         HttpProtocolParams.setVersion(params, HttpVersion.HTTP\_1\_1);  
  126.         HttpProtocolParams.setContentCharset(params, HTTP.DEFAULT\_CONTENT\_CHARSET);  
  127.         HttpProtocolParams.setUseExpectContinue(params, true);  
  128.         // 设置超时时间  
  129.         params.setParameter(CoreConnectionPNames.CONNECTION\_TIMEOUT, soTimeout);  
  130.         // 读取超时  
  131.         params.setParameter(CoreConnectionPNames.SO\_TIMEOUT, soTimeout);  
  132.         params.setParameter("Connection", "Keep-Alive");  
  133.         params.setParameter("Content-Length", " 12");
  135.         KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());  
  136.         trustStore.load(null, null);  
  137.         MySSLSocketFactory sf = new MySSLSocketFactory(trustStore);  
  138.         sf.setHostnameVerifier(MySSLSocketFactory.ALLOW\_ALL\_HOSTNAME\_VERIFIER);
  140.         SchemeRegistry registry = new SchemeRegistry();  
  141.         registry.register(new Scheme("http", PlainSocketFactory.getSocketFactory(), 80));  
  142.         registry.register(new Scheme("https", sf, 443));  
  143.         ClientConnectionManager conMgr = new ThreadSafeClientConnManager(params, registry);
  145.         return new DefaultHttpClient(conMgr, params);  
  146.     \} catch (Exception e) \{  
  147.         e.printStackTrace();  
  148.         return null;  
  149.     \}  
  150. \}
  152. public static String sendHttpsPost(String url, String requestBody, String contentType, String hostName) throws Exception \{  
  153.     log.info("httpsClient访问开始..." + url);  
  154.     CloseableHttpClient httpClient = null;  
  155.     try \{  
  156.         SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() \{  
  157.             // 默认信任所有证书  
  158.             public boolean isTrusted(X509Certificate\[\] arg0, String arg1) \{  
  159.                 return false;  
  160.             \}  
  161.         \}).build();  
  162.         SSLConnectionSocketFactory ssf = new SSLConnectionSocketFactory(sslContext, SSLConnectionSocketFactory.ALLOW\_ALL\_HOSTNAME\_VERIFIER);  
  163.         httpClient = HttpClients.custom().setSSLSocketFactory(ssf).build();
  165.         HttpPost httpPost = new HttpPost(url);  
  166.         Authenticator.setDefault(new MyAuthenticator("gaowei399","741asd\#fg"));              
  167.         RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECTION\_TIME\_OUT).setSocketTimeout(READDATA\_TIMEOUT)  
  168.                 .setProxy(new HttpHost("10.37.84.36", 8080))  
  169.                 .build();  
  170.         httpPost.setConfig(requestConfig);  
  171.         httpPost.setEntity(new StringEntity(requestBody, "UTF-8"));  
  172.         if (StringUtils.isNotBlank(hostName)) \{  
  173.             httpPost.setHeader("HOST", hostName);  
  174.         \}  
  175.         if (StringUtils.isNotBlank(contentType)) \{  
  176.             httpPost.setHeader("Content-Type", contentType);  
  177.         \}  
  178.         HttpResponse resp = httpClient.execute(httpPost);  
  179.         String result = EntityUtils.toString(resp.getEntity(), HTTP.UTF\_8);  
  180.         int statusCode = resp.getStatusLine().getStatusCode();  
  181.         if (statusCode == HttpStatus.SC\_OK) \{  
  182.             return result;  
  183.         \} else \{  
  184.             throw new HttpException("HTTP REQUEST FAIL ---- statusCode: " + statusCode + " and result: " + result);  
  185.         \}  
  186.     \} catch (Exception e) \{  
  187.         log.error(e.getMessage(), e);  
  188.         throw new RuntimeException("通讯未知系统异常", e);  
  189.     \} finally \{  
  190.         if (httpClient != null) \{  
  191.             httpClient.close();  
  192.         \}  
  193.     \}  
  194. \}

}

/**
* 过滤证书
*
*/
@SuppressWarnings(“deprecation”)
class MySSLSocketFactory extends SSLSocketFactory {
SSLContext sslContext = SSLContext.getInstance(“TLS”);

  1. public MySSLSocketFactory(KeyStore truststore)  
  2.         throws NoSuchAlgorithmException, KeyManagementException,  
  3.         KeyStoreException, UnrecoverableKeyException \{  
  4.     super(truststore);  
  5.     TrustManager tm = new X509TrustManager() \{  
  6.         public void checkClientTrusted(X509Certificate\[\] chain,  
  7.                                        String authType) throws CertificateException \{  
  8.         \}
  10.         public void checkServerTrusted(X509Certificate\[\] chain,  
  11.                                        String authType) throws CertificateException \{  
  12.         \}
  14.         public X509Certificate\[\] getAcceptedIssuers() \{  
  15.             return null;  
  16.         \}  
  17.     \};  
  18.     sslContext.init(null, new TrustManager\[\]\{tm\}, null);  
  19. \}
  21. [@Override][Override]  
  22. public Socket createSocket(Socket socket, String host, int port,  
  23.                            boolean autoClose) throws IOException, UnknownHostException \{  
  24.     return sslContext.getSocketFactory().createSocket(socket, host, port,  
  25.             autoClose);  
  26. \}
  28. [@Override][Override]  
  29. public Socket createSocket() throws IOException \{  
  30.     return sslContext.getSocketFactory().createSocket();  
  31. \}

}

转载于:https://my.oschina.net/u/198077/blog/3047633

发表评论

表情：
评论列表 （有 0 条评论，401人围观）

还没有评论，来说两句吧...

相关阅读

    相关 HTTP请求

    http请求分为请求头和请求体，请求头的第一行又为请求行，下面分别进行介绍。 请求头 话不多说，我们直接以一个请求头为例子来介绍，我们随便抓取一个包进行演示，下列是我抓

    港控/mmm°港控/mmm°/ 0 赞/ 74 阅读

    相关 http请求

    http 1、是客服端与服务器传输文本的一种协议 2、http协议是无状态的 3、http协议默认端口是80 4、http协议（加密传输）端口是443  

    r囧r小猫r囧r小猫/ 0 赞/ 62 阅读