【Java工具七】java使用HttpClient的post请求http、https示例

古城微笑少年丶 2022-05-18 09:04 418阅读 0赞

package com.xxx.utils;
    
    
    import com.google.gson.Gson;
    import org.apache.commons.codec.binary.Base64;
    import org.apache.commons.httpclient.HttpClient;
    import org.apache.commons.httpclient.HttpException;
    import org.apache.commons.httpclient.NameValuePair;
    import org.apache.commons.httpclient.methods.PostMethod;
    import org.apache.http.client.config.RequestConfig;
    import org.apache.http.config.ConnectionConfig;
    import org.apache.http.config.SocketConfig;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.DefaultHttpRequestRetryHandler;
    import org.apache.http.impl.client.HttpClientBuilder;
    import org.apache.http.impl.client.HttpClients;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import javax.net.ssl.HttpsURLConnection;
    import javax.net.ssl.SSLContext;
    import javax.net.ssl.TrustManager;
    import javax.net.ssl.X509TrustManager;
    import java.io.ByteArrayOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.HttpURLConnection;
    import java.net.URL;
    import java.net.URLConnection;
    import java.net.URLEncoder;
    import java.nio.charset.Charset;
    import java.security.cert.X509Certificate;
    import java.util.HashMap;
    import java.util.Map;
    
    
    /**
     * http 请求接口
     * 
     *
     */
    public class HttpUtils {
    	public static final Gson gson = new Gson();
    	private static final String HTTP_PREFIX = "http://";
    	private static final String HTTPS_PREFIX = "https://";
    	private static final Logger LOGGER = LoggerFactory.getLogger(HttpUtils.class);
    	
    	/**
    	 * 请求超时时间
    	 */
    	public static final int CONNECTION_TIMEOUT_DEFAULT = 30000;
    
    	/**
    	 * 响应超时时间
    	 */
    	public static final int SOCKET_TIMEOUT_DEFAULT = 50000;
    
    	/**
    	 * 无限超时时间
    	 */
    	public static final int INFINITE_TIMEOUT = 0;
    
    	/**
    	 * 接收/传输数据时使用的默认socket缓冲字节大小
    	 */
    	public static final int SOCKET_BUFFER_SIZE_DEFAULT = 81920;
    
    	/**
    	 * 请求失败后重新尝试的次数
    	 */
    	public static final int RETRY_COUNT_DEFAULT = 2;
    
    	/**
    	 * 默认字符集
    	 */
    	public static final String DEFAULT_CHARSET = "UTF-8";
    
    	public static final CloseableHttpClient httpClient = buildHttpClient(SOCKET_TIMEOUT_DEFAULT);
    
    	public static final CloseableHttpClient httpClientNoTimeout = buildHttpClient(INFINITE_TIMEOUT);
    	private static CloseableHttpClient buildHttpClient(int socketTimeout) {
    		// 设置最大连接数和每个host的最大连接数
    		HttpClientBuilder httpClientBuilder = HttpClients.custom().setMaxConnTotal(2000).setMaxConnPerRoute(2000);
    		// 内部默认使用 PoolingHttpClientConnectionManager 作为其连接管理器, 再次设置会覆盖下面其它参数的设置
    		// httpClientBuilder.setConnectionManager(new PoolingHttpClientConnectionManager());
    		// 设置服务器连接超时时间 及 服务器响应超时时间
    		httpClientBuilder.setDefaultRequestConfig(RequestConfig.custom().setConnectionRequestTimeout(CONNECTION_TIMEOUT_DEFAULT).setSocketTimeout(socketTimeout).build());
    		// 设置在关闭TCP连接时最大停留时间,是否禁用优化算法延迟发送数据 及 在非阻塞I/O情况下的服务器响应时间
    		httpClientBuilder.setDefaultSocketConfig(SocketConfig.custom().setSoLinger(1500).setTcpNoDelay(true).setSoTimeout(socketTimeout).build());
    		// 设置接收/传输数据时的buffer大小,及默认字符集
    		httpClientBuilder.setDefaultConnectionConfig(ConnectionConfig.custom().setBufferSize(SOCKET_BUFFER_SIZE_DEFAULT).setCharset(Charset.forName(DEFAULT_CHARSET)).build());
    		// 设置失败后重新尝试访问的处理器,不使用已经请求的连接
    		httpClientBuilder.setRetryHandler(new DefaultHttpRequestRetryHandler(RETRY_COUNT_DEFAULT, false));
    		return httpClientBuilder.build();
    	} 
    	
    	private static TrustManager myX509TrustManager = new X509TrustManager() {
    		@Override
    		public void checkClientTrusted(X509Certificate[] arg0, String arg1)
    				throws java.security.cert.CertificateException {
    			// TODO Auto-generated method stub
    
    		}
    		@Override
    		public void checkServerTrusted(X509Certificate[] arg0, String arg1)
    				throws java.security.cert.CertificateException {
    			// TODO Auto-generated method stub
    			
    		}
    		@Override
    		public X509Certificate[] getAcceptedIssuers() {
    			// TODO Auto-generated method stub
    			return null;
    		}
    	};
    
    	public static byte[] readInputStream(InputStream inStream) throws Exception {
    		ByteArrayOutputStream outStream = new ByteArrayOutputStream();
    		byte[] buffer = new byte[1024];
    		int len = 0;
    		while ((len = inStream.read(buffer)) != -1) {
    			outStream.write(buffer, 0, len);
    		}
    		byte[] data = outStream.toByteArray();// 网页的二进制数据
    		outStream.close();
    		inStream.close();
    		return data;
    	}
    
    	public static String getPostParam(Map<String, Object> params) throws Exception {
    		StringBuffer buffer = new StringBuffer();
    		for (String key : params.keySet()) {
    			String urlKey = URLEncoder.encode(key, "UTF-8");
    			String urlValue = URLEncoder.encode(String.valueOf(params.get(key)), "UTF-8");
    			buffer.append(urlKey).append("=").append(urlValue).append("&");
    		}
    		String paramStr = buffer.toString();
    		if (paramStr.endsWith("&") && paramStr.length() > 0) {
    			paramStr = paramStr.substring(0, paramStr.length() - 1);
    		}
    		return paramStr;
    	}
    
    	public static String postForm(String url, Map<String, Object> params) throws Exception {
    		LOGGER.info("请求的url {},输入参数{}", url, new Gson().toJson(params));
    		OutputStream out = null;
    		if (!url.startsWith(HTTP_PREFIX) && !url.startsWith(HTTPS_PREFIX)) {
    			url = HTTP_PREFIX + url;
    		}
    		URL localURL = new URL(url);
    		URLConnection connection =null;
    		if(url.toLowerCase().startsWith(HTTPS_PREFIX)){
    			SSLContext sslcontext = SSLContext.getInstance("TLS"); 
    			sslcontext.init(null, new TrustManager[]{myX509TrustManager}, null);
    			URL requestUrl = new URL(url);
    			HttpsURLConnection httpsConn = (HttpsURLConnection)requestUrl.openConnection();
    			httpsConn.setSSLSocketFactory(sslcontext.getSocketFactory());
    			connection=httpsConn;
    		}else{
    			connection = (HttpURLConnection) localURL.openConnection();
    		}
    		connection.setRequestProperty("accept", "*/*");
    		connection.setRequestProperty("connection", "Keep-Alive");
    		connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
    		connection.setDoOutput(true);
    		connection.setDoInput(true);
    		out = connection.getOutputStream();
    		out.write(getPostParam(params).getBytes());
    		out.flush();
    		InputStream inStream = connection.getInputStream();
    		String str = new String(readInputStream(inStream), "UTF-8");
    		return str;
    	}
    	
    	
    	public static String postHttps(String url, String params) throws Exception {
    		LOGGER.info("请求的url {},输入参数 {}", url, new Gson().toJson(params));
    		OutputStream out = null;
    		if (!url.startsWith(HTTP_PREFIX) && !url.startsWith(HTTPS_PREFIX)) {
    			url = HTTP_PREFIX + url;
    		}
    		URL localURL = new URL(url);
    		URLConnection connection =null;
    		if(url.toLowerCase().startsWith(HTTPS_PREFIX)){
    			SSLContext sslcontext = SSLContext.getInstance("TLS"); 
    			sslcontext.init(null, new TrustManager[]{myX509TrustManager}, null);
    			URL requestUrl = new URL(url);
    			HttpsURLConnection httpsConn = (HttpsURLConnection)requestUrl.openConnection();
    			httpsConn.setSSLSocketFactory(sslcontext.getSocketFactory());
    			connection=httpsConn;
    		}else{
    			connection = (HttpURLConnection) localURL.openConnection();
    		}
    		connection.setRequestProperty("accept", "*/*");
    		connection.setRequestProperty("connection", "Keep-Alive");
    		connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
    		connection.setDoOutput(true);
    		connection.setDoInput(true);
    		out = connection.getOutputStream();
    		out.write(params.getBytes());
    		out.flush();
    		InputStream inStream = connection.getInputStream();
    		String str = new String(readInputStream(inStream), "UTF-8");
    		return str;
    	}
    
    	public static String postForm(String url, String params) throws Exception {
    		LOGGER.info("请求的url {},输入参数{}", url, new Gson().toJson(params));
    		OutputStream out = null;
    		if (!url.startsWith(HTTP_PREFIX) && !url.startsWith(HTTPS_PREFIX)) {
    			url = HTTP_PREFIX + url;
    		}
    		URL localURL = new URL(url);
    		HttpURLConnection connection = (HttpURLConnection) localURL.openConnection();
    		connection.setRequestProperty("accept", "*/*");
    		connection.setRequestProperty("connection", "Keep-Alive");
    		connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
    		connection.setDoOutput(true);
    		connection.setDoInput(true);
    		out = connection.getOutputStream();
    		out.write(params.getBytes());
    		out.flush();
    		InputStream inStream = connection.getInputStream();
    		String str = new String(readInputStream(inStream), "UTF-8");
    //		String str = "";
    		return str;
    	}
    
    	public static String postGsonForm(String url, String params) throws Exception {
    		LOGGER.info("请求的url {},输入参数{}", url, new Gson().toJson(params));
    		OutputStream out = null;
    		URL localURL = new URL(url);
    		HttpURLConnection connection = null;
    		if(url.toLowerCase().startsWith(HTTPS_PREFIX)){
    			SSLContext sslcontext = SSLContext.getInstance("TLS"); 
    			sslcontext.init(null, new TrustManager[]{myX509TrustManager}, null);
    			URL requestUrl = new URL(url);
    			HttpsURLConnection httpsConn = (HttpsURLConnection)requestUrl.openConnection();
    			httpsConn.setSSLSocketFactory(sslcontext.getSocketFactory());
    			connection=httpsConn;
    		}else{
    			connection = (HttpURLConnection) localURL.openConnection();
    		}
    		connection.setRequestProperty("Accept", "*/*");
    		connection.setRequestProperty("connection", "Keep-Alive");
    		connection.setRequestProperty("user-agent", "Mozilla/6.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
    		connection.setRequestProperty("content-type", "application/json;charset=UTF-8");
    		connection.setDoOutput(true);
    		connection.setDoInput(true);
    		out = connection.getOutputStream();
    		out.write(params.getBytes("UTF-8"));
    		out.flush();
    		InputStream inStream = connection.getInputStream();
    		
    		String str = new String(readInputStream(inStream), "UTF-8");
    		return str;
    	}
    	public static String postGsonFormForHeader
    	(String url,String params,String accesstoken,String orgId,String appId) throws Exception {
    		LOGGER.info("请求的url {},输入参数{}", url, new Gson().toJson(params));
    		OutputStream out = null;
    		URL localURL = new URL(url);
    		HttpURLConnection connection = null;
    		if(url.toLowerCase().startsWith(HTTPS_PREFIX)){
    			SSLContext sslcontext = SSLContext.getInstance("TLS"); 
    			sslcontext.init(null, new TrustManager[]{myX509TrustManager}, null);
    			URL requestUrl = new URL(url);
    			HttpsURLConnection httpsConn = (HttpsURLConnection)requestUrl.openConnection();
    			httpsConn.setSSLSocketFactory(sslcontext.getSocketFactory());
    			connection=httpsConn;
    		}else{
    			connection = (HttpURLConnection) localURL.openConnection();
    		}
    		connection.setRequestProperty("Accept", "*/*");
    		connection.setRequestProperty("connection", "Keep-Alive");
    		connection.setRequestProperty("user-agent", "Mozilla/6.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
    		connection.setRequestProperty("content-type", "application/json;charset=UTF-8");
    		connection.setRequestProperty(accesstoken, accesstoken);
    		connection.setRequestProperty(orgId, orgId);
    		connection.setRequestProperty(appId, appId);
    		connection.setDoOutput(true);
    		connection.setDoInput(true);
    		out = connection.getOutputStream();
    		out.write(params.getBytes("UTF-8"));
    		out.flush();
    		InputStream inStream = connection.getInputStream();
    		
    		String str = new String(readInputStream(inStream), "UTF-8");
    		return str;
    	}
    	public static String postGsonForm(String url, String params, Map<String, Object> headerParams) throws Exception {
    		LOGGER.info("请求的url {},输入参数{}", url, new Gson().toJson(params));
    		OutputStream out = null;
    		URL localURL = new URL(url);
    		HttpURLConnection connection = null;
    		if(url.toLowerCase().startsWith(HTTPS_PREFIX)){
    			SSLContext sslcontext = SSLContext.getInstance("TLS");
    			sslcontext.init(null, new TrustManager[]{myX509TrustManager}, null);
    			URL requestUrl = new URL(url);
    			HttpsURLConnection httpsConn = (HttpsURLConnection)requestUrl.openConnection();
    			httpsConn.setSSLSocketFactory(sslcontext.getSocketFactory());
    			connection=httpsConn;
    		}else{
    			connection = (HttpURLConnection) localURL.openConnection();
    		}
    		connection.setRequestProperty("Accept", "*/*");
    		connection.setRequestProperty("connection", "Keep-Alive");
    		connection.setRequestProperty("user-agent", "Mozilla/6.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
    		connection.setRequestProperty("content-type", "application/json;charset=UTF-8");
    		connection.setDoOutput(true);
    		connection.setDoInput(true);
    		
    		if (headerParams != null && !headerParams.isEmpty()) {
    			for(Map.Entry<String, Object> headerParam:headerParams.entrySet()){
    				connection.setRequestProperty(headerParam.getKey(), headerParam.getValue().toString());
    			}
    		}
    		
    		out = connection.getOutputStream();
    		out.write(params.getBytes("UTF-8"));
    		out.flush();
    		InputStream inStream = connection.getInputStream();
    		
    		String str = new String(readInputStream(inStream), "UTF-8");
    		return str;
    	}
    
    	public static String getForm(String url, String params) throws Exception {
    		url = url + "?" + params;
    		URL localURL = new URL(url);
    		HttpURLConnection connection = null;
    		if(url.startsWith(HTTPS_PREFIX)){
    			SSLContext sslcontext = SSLContext.getInstance("TLS"); 
    			sslcontext.init(null, new TrustManager[]{myX509TrustManager}, null);
    			URL requestUrl = new URL(url);
    			HttpsURLConnection httpsConn = (HttpsURLConnection)requestUrl.openConnection();
    			httpsConn.setSSLSocketFactory(sslcontext.getSocketFactory());
    			connection=httpsConn;
    		}else{
    			connection = (HttpURLConnection) localURL.openConnection();
    		}
    		connection.setRequestProperty("accept", "*/*");
    		connection.setRequestProperty("connection", "Keep-Alive");
    		connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
    		InputStream inStream = connection.getInputStream();
    		String str = new String(readInputStream(inStream), "UTF-8");
     		return str;
    	}
    	
    	public static String getForm(String url, Map<String, Object> params) throws Exception {
    		url = url + "?" + getPostParam(params);
    		URL localURL = new URL(url);
    		HttpURLConnection connection = null;
    		if(url.startsWith(HTTPS_PREFIX)){
    			SSLContext sslcontext = SSLContext.getInstance("TLS"); 
    			sslcontext.init(null, new TrustManager[]{myX509TrustManager}, null);
    			URL requestUrl = new URL(url);
    			HttpsURLConnection httpsConn = (HttpsURLConnection)requestUrl.openConnection();
    			httpsConn.setSSLSocketFactory(sslcontext.getSocketFactory());
    			connection=httpsConn;
    		}else{
    			connection = (HttpURLConnection) localURL.openConnection();
    		}
    		connection.setRequestProperty("accept", "*/*");
    		connection.setRequestProperty("connection", "Keep-Alive");
    		connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
    		connection.setUseCaches(false);
    		InputStream inStream = connection.getInputStream();
    		String str = new String(readInputStream(inStream), "UTF-8");
     		return str;
    	}
    	
    	public static Map<String, Object> getMap(String key, Object value) {
    		Map<String, Object> result = new HashMap<String, Object>();
    		result.put(key, value);
    		return result;
    	}
    	
    	public static String post(String url, NameValuePair[] data) {
    		LOGGER.info("请求的url {},输入参数{}", url, new Gson().toJson(data));
    		
    		String responseMsg = null;
    
    		// 1.构造HttpClient的实例
    		HttpClient httpClient = new HttpClient();
    		httpClient.getParams().setContentCharset("UTF-8");
    
    		// 2.构造PostMethod的实例
    		PostMethod postMethod = new PostMethod(url);
    
    		// 3.把参数值放入到PostMethod对象中
    		postMethod.setRequestBody(data);
    
    		try {
    			// 4.执行postMethod,调用http接口
    			httpClient.executeMethod(postMethod);// 200
    
    			// 5.读取内容
    			responseMsg = postMethod.getResponseBodyAsString().trim();
    
    			// 6.处理返回的内容
    
    		} catch (HttpException e) {
    			LOGGER.error(e.getMessage(),e);
    		} catch (IOException e) {
    			LOGGER.error(e.getMessage(),e);
    		} finally {
    			// 7.释放连接
    			postMethod.releaseConnection();
    		}
    		return responseMsg;
    	}
    	
    	public static void main(String[] args) {
    		try {
    			Map<String, Object> paramsMap = new HashMap<>();
    			
    			paramsMap.put("orgId", "5835");
    			String[] userIds = {"84544"};
    			paramsMap.put("userIds", userIds);
    			String[] userNames = {"测试名片2"};
    			paramsMap.put("userNames", userNames);
    			String[] userPhones = {"18611368266"};
    			paramsMap.put("userPhones", userPhones);
    			
    			
    			Map<String, Object> headerParams = new HashMap<>();
    			headerParams.put("token", "4b55b10a8f454beacf8d9fd9b85f453a");
    			
    			String params = JSONUtils.toJson(paramsMap);
    			String url = "http://172.31.81.37:8080/CardManagerUI/usermanager/grantUserCard";
    			String rv = HttpUtils.postGsonForm(url, params,headerParams);
    			System.out.println("rv:"+rv);
    		}
    		catch (Exception e) {
    			e.printStackTrace();
    		}
    		
    		
    	}
    }

## **          下面是个人创建的公众号，主攻Java方向，有兴趣的可以扫描二维码。** ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1Zm9yZXZlcmxvdmU_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3h1Zm9yZXZlcmxvdmU_size_16_color_FFFFFF_t_70]: /images/20220518/5f1965b1c23f406583d094d93a72c0dc.png