JAVA中的HTTP請(qǐng)求怎么利用HttpClient實(shí)現(xiàn)發(fā)送-四川平武建站

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案

JAVA中的HTTP請(qǐng)求怎么利用HttpClient實(shí)現(xiàn)發(fā)送

JAVA中的HTTP請(qǐng)求怎么利用HttpClient實(shí)現(xiàn)發(fā)送？很多新手對(duì)此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來(lái)學(xué)習(xí)下，希望你能有所收獲。

創(chuàng)新互聯(lián)是一家專業(yè)從事成都網(wǎng)站設(shè)計(jì)、網(wǎng)站制作的網(wǎng)絡(luò)公司。作為專業(yè)的建站公司,創(chuàng)新互聯(lián)依托的技術(shù)實(shí)力、以及多年的網(wǎng)站運(yùn)營(yíng)經(jīng)驗(yàn),為您提供專業(yè)的成都網(wǎng)站建設(shè)、全網(wǎng)整合營(yíng)銷推廣及網(wǎng)站設(shè)計(jì)開發(fā)服務(wù)！

HttpClient介紹

HttpClient 不是一個(gè)瀏覽器。它是一個(gè)客戶端的 HTTP 通信實(shí)現(xiàn)庫(kù)。HttpClient的目標(biāo)是發(fā) 送和接收HTTP 報(bào)文。HttpClient不會(huì)去緩存內(nèi)容，執(zhí)行嵌入在 HTML 頁(yè)面中的javascript 代碼，猜測(cè)內(nèi)容類型，重新格式化請(qǐng)求/重定向URI，或者其它和 HTTP 運(yùn)輸無(wú)關(guān)的功能。

HttpClient使用

使用需要引入jar包，maven項(xiàng)目引入如下：


      org.apache.httpcomponents
      httpclient
      4.5
    

    
      org.apache.httpcomponents
      httpcore
      4.4.4
    

    
      org.apache.httpcomponents
      httpmime
      4.5

使用方法，代碼如下：　

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內(nèi)容類型。
  public static final String CONTENT_TYPE_TEXT_HTML = "text/xml";

  // HTTP內(nèi)容類型。相當(dāng)于form表單的形式，提交數(shù)據(jù)
  public static final String CONTENT_TYPE_FORM_URL = "application/x-www-form-urlencoded";

  // HTTP內(nèi)容類型。相當(dāng)于form表單的形式，提交數(shù)據(jù)
  public static final String CONTENT_TYPE_JSON_URL = "application/json;charset=utf-8";
  

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

  // 請(qǐng)求配置
  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());
      // 配置同時(shí)支持 HTTP 和 HTPPS
      Registry socketFactoryRegistry = RegistryBuilder. create().register(
          "http", PlainConnectionSocketFactory.getSocketFactory()).register(
          "https", sslsf).build();
      // 初始化連接管理器
      pool = new PoolingHttpClientConnectionManager(
          socketFactoryRegistry);
      // 將最大連接數(shù)增加到200，實(shí)際項(xiàng)目最好從配置文件中讀取這個(gè)值
      pool.setMaxTotal(200);
      // 設(shè)置最大路由
      pool.setDefaultMaxPerRoute(2);
      // 根據(jù)默認(rèn)超時(shí)限制初始化requestConfig
      int socketTimeout = 10000;
      int connectTimeout = 10000;
      int connectionRequestTimeout = 10000;
      requestConfig = RequestConfig.custom().setConnectionRequestTimeout(
          connectionRequestTimeout).setSocketTimeout(socketTimeout).setConnectTimeout(
          connectTimeout).build();

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

    // 設(shè)置請(qǐng)求超時(shí)時(shí)間
    requestConfig = RequestConfig.custom().setSocketTimeout(50000).setConnectTimeout(50000)
        .setConnectionRequestTimeout(50000).build();
  }

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

  /**
   * 發(fā)送Post請(qǐng)求
   * 
   * @param httpPost
   * @return
   */
  private static String sendHttpPost(HttpPost httpPost) {

    CloseableHttpClient httpClient = null;
    CloseableHttpResponse response = null;
    // 響應(yīng)內(nèi)容
    String responseContent = null;
    try {
      // 創(chuàng)建默認(rèn)的httpClient實(shí)例.
      httpClient = getHttpClient();
      // 配置請(qǐng)求信息
      httpPost.setConfig(requestConfig);
      // 執(zhí)行請(qǐng)求
      response = httpClient.execute(httpPost);
      // 得到響應(yīng)實(shí)例
      HttpEntity entity = response.getEntity();

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

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

      // 判斷響應(yīng)狀態(tài)
      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;
  }

  /**
   * 發(fā)送Get請(qǐng)求
   * 
   * @param httpGet
   * @return
   */
  private static String sendHttpGet(HttpGet httpGet) {

    CloseableHttpClient httpClient = null;
    CloseableHttpResponse response = null;
    // 響應(yīng)內(nèi)容
    String responseContent = null;
    try {
      // 創(chuàng)建默認(rèn)的httpClient實(shí)例.
      httpClient = getHttpClient();
      // 配置請(qǐng)求信息
      httpGet.setConfig(requestConfig);
      // 執(zhí)行請(qǐng)求
      response = httpClient.execute(httpGet);
      // 得到響應(yīng)實(shí)例
      HttpEntity entity = response.getEntity();

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

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

      // 判斷響應(yīng)狀態(tài)
      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;
  }
  
  
  
  /**
   * 發(fā)送 post請(qǐng)求
   * 
   * @param httpUrl
   *      地址
   */
  public static String sendHttpPost(String httpUrl) {
    // 創(chuàng)建httpPost
    HttpPost httpPost = new HttpPost(httpUrl);
    return sendHttpPost(httpPost);
  }

  /**
   * 發(fā)送 get請(qǐng)求
   * 
   * @param httpUrl
   */
  public static String sendHttpGet(String httpUrl) {
    // 創(chuàng)建get請(qǐng)求
    HttpGet httpGet = new HttpGet(httpUrl);
    return sendHttpGet(httpGet);
  }
  
  

  /**
   * 發(fā)送 post請(qǐng)求（帶文件）
   * 
   * @param httpUrl
   *      地址
   * @param maps
   *      參數(shù)
   * @param fileLists
   *      附件
   */
  public static String sendHttpPost(String httpUrl, Map maps, List fileLists) {
    HttpPost httpPost = new HttpPost(httpUrl);// 創(chuàng)建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);
  }

  /**
   * 發(fā)送 post請(qǐng)求
   * 
   * @param httpUrl
   *      地址
   * @param params
   *      參數(shù)(格式:key1=value1&key2=value2)
   * 
   */
  public static String sendHttpPost(String httpUrl, String params) {
    HttpPost httpPost = new HttpPost(httpUrl);// 創(chuàng)建httpPost
    try {
      // 設(shè)置參數(shù)
      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);
  }

  /**
   * 發(fā)送 post請(qǐng)求
   * 
   * @param maps
   *      參數(shù)
   */
  public static String sendHttpPost(String httpUrl, Map maps) {
    String parem = convertStringParamter(maps);
    return sendHttpPost(httpUrl, parem);
  }

  
  
  
  /**
   * 發(fā)送 post請(qǐng)求 發(fā)送json數(shù)據(jù)
   * 
   * @param httpUrl
   *      地址
   * @param paramsJson
   *      參數(shù)(格式 json)
   * 
   */
  public static String sendHttpPostJson(String httpUrl, String paramsJson) {
    HttpPost httpPost = new HttpPost(httpUrl);// 創(chuàng)建httpPost
    try {
      // 設(shè)置參數(shù)
      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);
  }
  
  /**
   * 發(fā)送 post請(qǐng)求 發(fā)送xml數(shù)據(jù)
   * 
   * @param httpUrl  地址
   * @param paramsXml 參數(shù)(格式 Xml)
   * 
   */
  public static String sendHttpPostXml(String httpUrl, String paramsXml) {
    HttpPost httpPost = new HttpPost(httpUrl);// 創(chuàng)建httpPost
    try {
      // 設(shè)置參數(shù)
      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集合的鍵值對(duì)轉(zhuǎn)化成：key1=value1&key2=value2 的形式
   * 
   * @param parameterMap
   *      需要轉(zhuǎn)化的鍵值對(duì)集合
   * @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"));
  
  }
}

看完上述內(nèi)容是否對(duì)您有幫助呢？如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對(duì)創(chuàng)新互聯(lián)的支持。

新聞標(biāo)題：JAVA中的HTTP請(qǐng)求怎么利用HttpClient實(shí)現(xiàn)發(fā)送
文章鏈接：http://ef60e0e.cn/article/gsjgep.html

99热在线精品一区二区三区_国产伦精品一区二区三区女破破_亚洲一区二区三区无码_精品国产欧美日韩另类一区

新聞中心

其他資訊