JAVA通过HttpClient发送HTTP请求的方法示例

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"));
  
  }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# java  # HttpClient  # http请求  # java发送http请求  # java使用httpclient 发送请求的示例  # java 11新特性HttpClient主要组件及发送请求示例详解  # Java通过HttpClient进行HTTP请求的代码详解  # java中httpclient封装post请求和get的请求实例  # Java commons-httpclient如果实现get及post请求  # Java使用HttpClient实现Post请求实例  # java实现HttpClient异步请求资源的方法  # Java高并发场景下的 HttpClient请求优化实现  # 管理器  # 表单  # 可以获得  # 键值  # 它是  # 会去  # 配置文件  # 大家多多  # 转化成  # 重试  # 连接数  # 客户端  # 重定向  # 上午  # 连接池  # 增加到  # DefaultHttpRequestRetryHandler  # CloseableHttpClient  # HttpClients  # PoolingHttpClientConnectionManager 

相关文章： 如何在阿里云高效完成企业建站全流程？  如何基于云服务器快速搭建个人网站？  h5网站制作工具有哪些,h5页面制作工具有哪些？  已有域名如何免费搭建网站？  零基础网站服务器架设实战：轻量应用与域名解析配置指南  如何选择域名并搭建高效网站？  如何选择高效便捷的WAP商城建站系统？  GML (Geography Markup Language)是什么，它如何用XML来表示地理空间信息？  网站视频怎么制作,哪个网站可以免费收看好莱坞经典大片？  大学网站设计制作软件有哪些,如何将网站制作成自己app？  建站之星官网登录失败？如何快速解决？  道歉网站制作流程,世纪佳缘致歉小吴事件，相亲网站身份信息伪造该如何稽查？  如何做静态网页,sublimetext3.0制作静态网页？  建站主机无法访问？如何排查域名与服务器问题  Python lxml的etree和ElementTree有什么区别  PHP正则匹配日期和时间(时间戳转换)的实例代码  开封网站制作公司,网络用语开封是什么意思？  浅谈Javascript中的Label语句  韩国网站服务器搭建指南：VPS选购、域名解析与DNS配置推荐  c# Task.ConfigureAwait(true) 在什么场景下是必须的  宝塔面板创建网站无法访问？如何快速排查修复？  如何制作网站标识牌,动态网站如何制作（教程）？  西安市网站制作公司,哪个相亲网站比较好?西安比较好的相亲网站？  C#怎么创建控制台应用 C# Console App项目创建方法  建站上传速度慢？如何优化加速网站加载效率？  如何获取PHP WAP自助建站系统源码？  定制建站如何定义？其核心优势是什么？  如何通过虚拟机搭建网站？详细步骤解析  网站专业制作公司有哪些,做一个公司网站要多少钱？  红河网站制作公司,红河事业单位身份证如何上传？  python的本地网站制作,如何创建本地站点？  建站之星客服服务时间及联系方式如何？  香港服务器租用每月最低只需15元？  交易网站制作流程,我想开通一个网站，注册一个交易网址，需要那些手续？  如何选择服务器才能高效搭建专属网站？  哪家制作企业网站好,开办像阿里巴巴那样的网络公司和网站要怎么做？  如何通过.red域名打造高辨识度品牌网站？  网页设计网站制作软件,microsoft office哪个可以创建网页？  php json中文编码为null的解决办法  齐河建站公司：营销型网站建设与SEO优化双核驱动策略  如何快速搭建安全的FTP站点？  mc皮肤壁纸制作器,苹果平板怎么设置自己想要的壁纸我的世界？  高端网站建设与定制开发一站式解决方案 中企动力  如何通过云梦建站系统实现SEO快速优化？  教育培训网站制作流程,请问edu教育网站的域名怎么申请？  如何选购建站域名与空间？自助平台全解析  如何登录建站主机？访问步骤全解析  如何在IIS中配置站点IP、端口及主机头？  网站规划与制作是什么,电子商务网站系统规划的内容及步骤是什么？  宝塔面板如何快速创建新站点？