Http工具类 HttpUtils

àì夳堔傛蜴生んèń 2022-02-03 14:23 252阅读 0赞

import java.io.IOException;
 import java.nio.charset.Charset;
 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.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
 
 import javax.net.ssl.SSLContext;
 
 import com.alibaba.fastjson.JSONObject;
 import org.apache.http.HttpEntity;
 import org.apache.http.NameValuePair;
 import org.apache.http.ParseException;
 import org.apache.http.client.ClientProtocolException;
 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.config.ConnectionConfig;
 import org.apache.http.config.Registry;
 import org.apache.http.config.RegistryBuilder;
 import org.apache.http.config.SocketConfig;
 import org.apache.http.conn.socket.ConnectionSocketFactory;
 import org.apache.http.conn.socket.LayeredConnectionSocketFactory;
 import org.apache.http.conn.socket.PlainConnectionSocketFactory;
 import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
 import org.apache.http.conn.ssl.SSLContexts;
 import org.apache.http.conn.ssl.TrustStrategy;
 import org.apache.http.impl.client.CloseableHttpClient;
 import org.apache.http.impl.client.HttpClientBuilder;
 import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
 import org.apache.http.message.BasicHeader;
 import org.apache.http.message.BasicNameValuePair;
 import org.apache.http.util.EntityUtils;
 
 /**
 * 类名: HttpUtils
 * 描述: http请求工具类
 * 修改时间: 2019年04月30日 上午10:12:35
 *
 * @author lidongyang
 */
 public class HttpUtils {
 
 public static String defaultEncoding = "utf-8";
 
 /**
 * 发送http post请求，并返回响应实体
 *
 * @param url 请求地址
 * @return url响应实体
 */
 public static String postRequest(String url) {
 return postRequest(url, null, null);
 }
 
 /**
 * 方法名: postRequest
 * 描述: 发送httpPost请求
 *
 * @param url
 * @param params
 * @return
 */
 public static String postRequest(String url, Map<String, Object> params) {
 return postRequest(url, null, params);
 }
 
 /**
 * 发送http post请求，并返回响应实体
 *
 * @param url 访问的url
 * @param headers 请求需要添加的请求头
 * @param params 请求参数
 * @return
 */
 public static String postRequest(String url, Map<String, String> headers,
 Map<String, Object> params) {
 String result = null;
 CloseableHttpClient httpClient = buildHttpClient();
 HttpPost httpPost = new HttpPost(url);
 
 if (null != headers && headers.size() > 0) {
 for (Entry<String, String> entry : headers.entrySet()) {
 String key = entry.getKey();
 String value = entry.getValue();
 httpPost.addHeader(new BasicHeader(key, value));
 }
 }
 if (null != params && params.size() > 0) {
 List<NameValuePair> pairList = new ArrayList<NameValuePair>(params.size());
 for (Map.Entry<String, Object> entry : params.entrySet()) {
 NameValuePair pair = new BasicNameValuePair(entry.getKey(), entry.getValue().toString());
 pairList.add(pair);
 }
 httpPost.setEntity(new UrlEncodedFormEntity(pairList, Charset.forName(defaultEncoding)));
 }
 
 try {
 CloseableHttpResponse response = httpClient.execute(httpPost);
 try {
 HttpEntity entity = response.getEntity();
 if (entity != null) {
 result = EntityUtils.toString(entity,
 Charset.forName(defaultEncoding));
 }
 } finally {
 response.close();
 }
 } catch (Exception ex) {
 ex.printStackTrace();
 } finally {
 try {
 httpClient.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 }
 
 return result;
 }
 
 /**
 * 发送http get请求
 *
 * @param url 请求url
 * @return url返回内容
 */
 public static String getRequest(String url) {
 return getRequest(url, null);
 }
 
 
 /**
 * 发送http get请求
 *
 * @param url 请求的url
 * @param params 请求的参数
 * @return
 */
 public static String getRequest(String url, Map<String, Object> params) {
 return getRequest(url, null, params);
 }
 
 /**
 * 发送http get请求
 *
 * @param url 请求的url
 * @param headersMap 请求头
 * @param params 请求的参数
 * @return
 */
 public static String getRequest(String url, Map<String, String> headersMap, Map<String, Object> params) {
 String result = null;
 CloseableHttpClient httpClient = buildHttpClient();
 try {
 String apiUrl = url;
 if (null != params && params.size() > 0) {
 StringBuffer param = new StringBuffer();
 int i = 0;
 for (String key : params.keySet()) {
 if (i == 0)
 param.append("?");
 else
 param.append("&");
 param.append(key).append("=").append(params.get(key));
 i++;
 }
 apiUrl += param;
 }
 
 HttpGet httpGet = new HttpGet(apiUrl);
 if (null != headersMap && headersMap.size() > 0) {
 for (Entry<String, String> entry : headersMap.entrySet()) {
 String key = entry.getKey();
 String value = entry.getValue();
 httpGet.addHeader(new BasicHeader(key, value));
 }
 }
 CloseableHttpResponse response = httpClient.execute(httpGet);
 try {
 HttpEntity entity = response.getEntity();
 if (null != entity) {
 result = EntityUtils.toString(entity, defaultEncoding);
 }
 } finally {
 response.close();
 }
 } catch (ClientProtocolException e) {
 e.printStackTrace();
 } catch (ParseException e) {
 e.printStackTrace();
 } catch (IOException e) {
 e.printStackTrace();
 } finally {
 try {
 httpClient.close();
 } catch (IOException e) {
 e.printStackTrace();
 }
 }
 return result;
 }
 
 /**
 * 创建httpclient
 *
 * @return
 */
 public static CloseableHttpClient buildHttpClient() {
 try {
 RegistryBuilder<ConnectionSocketFactory> builder = RegistryBuilder
 .create();
 ConnectionSocketFactory factory = new PlainConnectionSocketFactory();
 builder.register("http", factory);
 KeyStore trustStore = KeyStore.getInstance(KeyStore
 .getDefaultType());
 SSLContext context = SSLContexts.custom().useTLS()
 .loadTrustMaterial(trustStore, new TrustStrategy() {
 public boolean isTrusted(X509Certificate[] chain,
 String authType) throws CertificateException {
 return true;
 }
 }).build();
 LayeredConnectionSocketFactory sslFactory = new SSLConnectionSocketFactory(
 context,
 SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
 builder.register("https", sslFactory);
 Registry<ConnectionSocketFactory> registry = builder.build();
 PoolingHttpClientConnectionManager manager = new PoolingHttpClientConnectionManager(
 registry);
 ConnectionConfig connConfig = ConnectionConfig.custom()
 .setCharset(Charset.forName(defaultEncoding)).build();
 SocketConfig socketConfig = SocketConfig.custom()
 .setSoTimeout(100000).build();
 manager.setDefaultConnectionConfig(connConfig);
 manager.setDefaultSocketConfig(socketConfig);
 return HttpClientBuilder.create().setConnectionManager(manager)
 .build();
 } catch (KeyStoreException e) {
 e.printStackTrace();
 } catch (KeyManagementException e) {
 e.printStackTrace();
 } catch (NoSuchAlgorithmException e) {
 e.printStackTrace();
 }
 return null;
 }
 
 public static void main(String[] args) {
 String url = "http://127.0.0.1:8080/user/login";
 
 JSONObject params = new JSONObject();
 params.put("username", "test");
 params.put("password", "123456");
 
 String result = HttpUtils.postRequest(url, params);
 System.out.println(result);
 }
 
 
 }