JAVA中的HTTP請求怎么利用HttpClient實現發送

發布時間：2020-12-07 16:22:44 來源：億速云閱讀：215 作者：Leah 欄目：編程語言

JAVA中的HTTP請求怎么利用HttpClient實現發送？很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。

HttpClient介紹

HttpClient 不是一個瀏覽器。它是一個客戶端的 HTTP 通信實現庫。HttpClient的目標是發送和接收HTTP 報文。HttpClient不會去緩存內容，執行嵌入在 HTML 頁面中的javascript 代碼，猜測內容類型，重新格式化請求/重定向URI，或者其它和 HTTP 運輸無關的功能。

HttpClient使用

使用需要引入jar包，maven項目引入如下：

<dependency>
      <groupId>org.apache.httpcomponents</groupId>
      <artifactId>httpclient</artifactId>
      <version>4.5</version>
    </dependency>

    <dependency>
      <groupId>org.apache.httpcomponents</groupId>
      <artifactId>httpcore</artifactId>
      <version>4.4.4</version>
    </dependency>

    <dependency>
      <groupId>org.apache.httpcomponents</groupId>
      <artifactId>httpmime</artifactId>
      <version>4.5</version>
    </dependency>

使用方法，代碼如下：　

package com.test;

import java.io.File;
import java.io.IOException;
import java.security.KeyManagementException;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.apache.http.HttpEntity;
import org.apache.http.HttpStatus;
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.config.Registry;
import org.apache.http.config.RegistryBuilder;
import org.apache.http.conn.socket.ConnectionSocketFactory;
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.conn.ssl.SSLContextBuilder;
import org.apache.http.conn.ssl.TrustSelfSignedStrategy;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.entity.mime.content.FileBody;
import org.apache.http.entity.mime.content.StringBody;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.DefaultHttpRequestRetryHandler;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.util.EntityUtils;

/**
 * 
 * @author H__D
 * @date 2016年10月19日 上午11:27:25
 *
 */
public class HttpClientUtil {

  // utf-8字符編碼
  public static final String CHARSET_UTF_8 = "utf-8";

  // HTTP內容類型。
  public static final String CONTENT_TYPE_TEXT_HTML = "text/xml";

  // HTTP內容類型。相當于form表單的形式，提交數據
  public static final String CONTENT_TYPE_FORM_URL = "application/x-www-form-urlencoded";

  // HTTP內容類型。相當于form表單的形式，提交數據
  public static final String CONTENT_TYPE_JSON_URL = "application/json;charset=utf-8";
  

  // 連接管理器
  private static PoolingHttpClientConnectionManager pool;

  // 請求配置
  private static RequestConfig requestConfig;

  static {
    
    try {
      //System.out.println("初始化HttpClientTest~~~開始");
      SSLContextBuilder builder = new SSLContextBuilder();
      builder.loadTrustMaterial(null, new TrustSelfSignedStrategy());
      SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(
          builder.build());
      // 配置同時支持 HTTP 和 HTPPS
      Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory> create().register(
          "http", PlainConnectionSocketFactory.getSocketFactory()).register(
          "https", sslsf).build();
      // 初始化連接管理器
      pool = new PoolingHttpClientConnectionManager(
          socketFactoryRegistry);
      // 將最大連接數增加到200，實際項目最好從配置文件中讀取這個值
      pool.setMaxTotal(200);
      // 設置最大路由
      pool.setDefaultMaxPerRoute(2);
      // 根據默認超時限制初始化requestConfig
      int socketTimeout = 10000;
      int connectTimeout = 10000;
      int connectionRequestTimeout = 10000;
      requestConfig = RequestConfig.custom().setConnectionRequestTimeout(
          connectionRequestTimeout).setSocketTimeout(socketTimeout).setConnectTimeout(
          connectTimeout).build();

      //System.out.println("初始化HttpClientTest~~~結束");
    } catch (NoSuchAlgorithmException e) {
      e.printStackTrace();
    } catch (KeyStoreException e) {
      e.printStackTrace();
    } catch (KeyManagementException e) {
      e.printStackTrace();
    }
    

    // 設置請求超時時間
    requestConfig = RequestConfig.custom().setSocketTimeout(50000).setConnectTimeout(50000)
        .setConnectionRequestTimeout(50000).build();
  }

  public static CloseableHttpClient getHttpClient() {
    
    CloseableHttpClient httpClient = HttpClients.custom()
        // 設置連接池管理
        .setConnectionManager(pool)
        // 設置請求配置
        .setDefaultRequestConfig(requestConfig)
        // 設置重試次數
        .setRetryHandler(new DefaultHttpRequestRetryHandler(0, false))
        .build();
    
    return httpClient;
  }

  /**
   * 發送Post請求
   * 
   * @param httpPost
   * @return
   */
  private static String sendHttpPost(HttpPost httpPost) {

    CloseableHttpClient httpClient = null;
    CloseableHttpResponse response = null;
    // 響應內容
    String responseContent = null;
    try {
      // 創建默認的httpClient實例.
      httpClient = getHttpClient();
      // 配置請求信息
      httpPost.setConfig(requestConfig);
      // 執行請求
      response = httpClient.execute(httpPost);
      // 得到響應實例
      HttpEntity entity = response.getEntity();

      // 可以獲得響應頭
      // Header[] headers = response.getHeaders(HttpHeaders.CONTENT_TYPE);
      // for (Header header : headers) {
      // System.out.println(header.getName());
      // }

      // 得到響應類型
      // System.out.println(ContentType.getOrDefault(response.getEntity()).getMimeType());

      // 判斷響應狀態
      if (response.getStatusLine().getStatusCode() >= 300) {
        throw new Exception(
            "HTTP Request is not success, Response code is " + response.getStatusLine().getStatusCode());
      }

      if (HttpStatus.SC_OK == response.getStatusLine().getStatusCode()) {
        responseContent = EntityUtils.toString(entity, CHARSET_UTF_8);
        EntityUtils.consume(entity);
      }

    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      try {
        // 釋放資源
        if (response != null) {
          response.close();
        }
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
    return responseContent;
  }

  /**
   * 發送Get請求
   * 
   * @param httpGet
   * @return
   */
  private static String sendHttpGet(HttpGet httpGet) {

    CloseableHttpClient httpClient = null;
    CloseableHttpResponse response = null;
    // 響應內容
    String responseContent = null;
    try {
      // 創建默認的httpClient實例.
      httpClient = getHttpClient();
      // 配置請求信息
      httpGet.setConfig(requestConfig);
      // 執行請求
      response = httpClient.execute(httpGet);
      // 得到響應實例
      HttpEntity entity = response.getEntity();

      // 可以獲得響應頭
      // Header[] headers = response.getHeaders(HttpHeaders.CONTENT_TYPE);
      // for (Header header : headers) {
      // System.out.println(header.getName());
      // }

      // 得到響應類型
      // System.out.println(ContentType.getOrDefault(response.getEntity()).getMimeType());

      // 判斷響應狀態
      if (response.getStatusLine().getStatusCode() >= 300) {
        throw new Exception(
            "HTTP Request is not success, Response code is " + response.getStatusLine().getStatusCode());
      }

      if (HttpStatus.SC_OK == response.getStatusLine().getStatusCode()) {
        responseContent = EntityUtils.toString(entity, CHARSET_UTF_8);
        EntityUtils.consume(entity);
      }

    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      try {
        // 釋放資源
        if (response != null) {
          response.close();
        }
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
    return responseContent;
  }
  
  
  
  /**
   * 發送 post請求
   * 
   * @param httpUrl
   *      地址
   */
  public static String sendHttpPost(String httpUrl) {
    // 創建httpPost
    HttpPost httpPost = new HttpPost(httpUrl);
    return sendHttpPost(httpPost);
  }

  /**
   * 發送 get請求
   * 
   * @param httpUrl
   */
  public static String sendHttpGet(String httpUrl) {
    // 創建get請求
    HttpGet httpGet = new HttpGet(httpUrl);
    return sendHttpGet(httpGet);
  }
  
  

  /**
   * 發送 post請求（帶文件）
   * 
   * @param httpUrl
   *      地址
   * @param maps
   *      參數
   * @param fileLists
   *      附件
   */
  public static String sendHttpPost(String httpUrl, Map<String, String> maps, List<File> fileLists) {
    HttpPost httpPost = new HttpPost(httpUrl);// 創建httpPost
    MultipartEntityBuilder meBuilder = MultipartEntityBuilder.create();
    if (maps != null) {
      for (String key : maps.keySet()) {
        meBuilder.addPart(key, new StringBody(maps.get(key), ContentType.TEXT_PLAIN));
      }
    }
    if (fileLists != null) {
      for (File file : fileLists) {
        FileBody fileBody = new FileBody(file);
        meBuilder.addPart("files", fileBody);
      }
    }
    HttpEntity reqEntity = meBuilder.build();
    httpPost.setEntity(reqEntity);
    return sendHttpPost(httpPost);
  }

  /**
   * 發送 post請求
   * 
   * @param httpUrl
   *      地址
   * @param params
   *      參數(格式:key1=value1&key2=value2)
   * 
   */
  public static String sendHttpPost(String httpUrl, String params) {
    HttpPost httpPost = new HttpPost(httpUrl);// 創建httpPost
    try {
      // 設置參數
      if (params != null && params.trim().length() > 0) {
        StringEntity stringEntity = new StringEntity(params, "UTF-8");
        stringEntity.setContentType(CONTENT_TYPE_FORM_URL);
        httpPost.setEntity(stringEntity);
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
    return sendHttpPost(httpPost);
  }

  /**
   * 發送 post請求
   * 
   * @param maps
   *      參數
   */
  public static String sendHttpPost(String httpUrl, Map<String, String> maps) {
    String parem = convertStringParamter(maps);
    return sendHttpPost(httpUrl, parem);
  }

  
  
  
  /**
   * 發送 post請求 發送json數據
   * 
   * @param httpUrl
   *      地址
   * @param paramsJson
   *      參數(格式 json)
   * 
   */
  public static String sendHttpPostJson(String httpUrl, String paramsJson) {
    HttpPost httpPost = new HttpPost(httpUrl);// 創建httpPost
    try {
      // 設置參數
      if (paramsJson != null && paramsJson.trim().length() > 0) {
        StringEntity stringEntity = new StringEntity(paramsJson, "UTF-8");
        stringEntity.setContentType(CONTENT_TYPE_JSON_URL);
        httpPost.setEntity(stringEntity);
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
    return sendHttpPost(httpPost);
  }
  
  /**
   * 發送 post請求 發送xml數據
   * 
   * @param httpUrl  地址
   * @param paramsXml 參數(格式 Xml)
   * 
   */
  public static String sendHttpPostXml(String httpUrl, String paramsXml) {
    HttpPost httpPost = new HttpPost(httpUrl);// 創建httpPost
    try {
      // 設置參數
      if (paramsXml != null && paramsXml.trim().length() > 0) {
        StringEntity stringEntity = new StringEntity(paramsXml, "UTF-8");
        stringEntity.setContentType(CONTENT_TYPE_TEXT_HTML);
        httpPost.setEntity(stringEntity);
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
    return sendHttpPost(httpPost);
  }
  

  /**
   * 將map集合的鍵值對轉化成：key1=value1&key2=value2 的形式
   * 
   * @param parameterMap
   *      需要轉化的鍵值對集合
   * @return 字符串
   */
  public static String convertStringParamter(Map parameterMap) {
    StringBuffer parameterBuffer = new StringBuffer();
    if (parameterMap != null) {
      Iterator iterator = parameterMap.keySet().iterator();
      String key = null;
      String value = null;
      while (iterator.hasNext()) {
        key = (String) iterator.next();
        if (parameterMap.get(key) != null) {
          value = (String) parameterMap.get(key);
        } else {
          value = "";
        }
        parameterBuffer.append(key).append("=").append(value);
        if (iterator.hasNext()) {
          parameterBuffer.append("&");
        }
      }
    }
    return parameterBuffer.toString();
  }

  public static void main(String[] args) throws Exception {
    
    System.out.println(sendHttpGet("http://www.baidu.com"));
  
  }
}

看完上述內容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業資訊頻道，感謝您對億速云的支持。

向AI問一下細節

中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

JAVA中的HTTP請求怎么利用HttpClient實現發送

猜你喜歡

中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

JAVA中的HTTP請求怎么利用HttpClient實現發送

猜你喜歡

最新資訊

相關推薦

相關標簽