HttpClient Java客户端

青旅半醒 2023-10-10 11:29 118阅读 0赞

文章目录

  • HttpClient Java客户端
    • 建立使用HttpClient的环境
    • HttpGet请求
    • HttpGet带参请求
    • HttpPost请求
    • HttpPost带参请求(提交表单数据)
    • HttpClient连接池+请求配置

HttpClient Java客户端

HttpClient 是Apache Jakarta Common 下的子项目，可以用来提供高效的、最新的、功能丰富的支持 HTTP 协议的客户端编程工具包，并且它支持 HTTP 协议最新的版本和建议。

HttpClient主要功能：

  1. 实现了所有 HTTP 的方法（GET,POST,PUT,HEAD 等）
  2. 支持自动转向
  3. 支持 HTTPS 协议

  4. 支持代理服务器等

    （以上资料来自百度百科）

建立使用HttpClient的环境

如果创建的是maven项目的话可以导入依赖：

  1. <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
  2. <dependency>
  3.     <groupId>org.apache.httpcomponents</groupId>
  4.     <artifactId>httpclient</artifactId>
  5.     <version>4.5.2</version>
  6. </dependency>

如果创建的是JavaWeb项目的话可以直接引入Jar包：httpclient-4.5.2.jar。

想要其他版本的HttpClient工具的话可以搜索maven HttpClient下载。

这样就可以使用HttpClient来请求浏览器了。

HttpClient请求的步骤大致分为几步（类似人操作浏览器的步骤）：

  1. 创建HttpClient的连接（打开浏览器建立与浏览器的连接）
  2. 创建请求，输入URI地址向浏览器发起请求（手动输入URI地址）
  3. HttpClient请求URI地址（浏览器中按回车发起请求）
  4. 拿到response响应数据（浏览器接收数据，解析渲染到页面）

以上就完成了从请求到接收数据的一个过程。下面看一下简单实现。

HttpGet请求

以GET请求的方式向百度贴吧发送一个请求：

  1. //HttpClient发送GET请求
  2. public class HttpGetRequest {
  4.     public static void main(String[] args) {
  6.         //百度贴吧的uri地址
  7.         String uri = "https://tieba.baidu.com/index.html";
  8.         //1、创建HttpClient连接
  9.         CloseableHttpClient httpClient = HttpClients.createDefault();
  10.         //2、创建HtpGet请求
  11.         HttpGet httpGet = new HttpGet(uri);
  12.         //3、HttpClient发送请求
  13.         CloseableHttpResponse response = null;
  14.         try {
  16.             response = httpClient.execute(httpGet);
  17.             //4、拿到请求页面的返回数据,请求成功才有数据啊！
  18.             HttpEntity entity = null;
  19.             if (response != null && response.getStatusLine().getStatusCode() == 200) {
  21.                 //获取服务器返回的实体数据
  22.                 entity = response.getEntity();
  23.                 //把实体数据转换成指定类型的字符串
  24.                 String context = EntityUtils.toString(entity, "utf-8");
  25.                 System.out.println(context);
  26.             }
  27.         } catch (IOException e) {
  29.             e.printStackTrace();
  30.             //发送请求异常
  31.         } finally {
  33.             //不管如何关闭响应、请求的连接
  34.             if (response != null) {
  36.                 try {
  38.                     response.close();
  39.                 } catch (IOException e) {
  41.                     e.printStackTrace();
  42.                 }
  43.             }
  44.             if (httpClient != null) {
  46.                 try {
  48.                     httpClient.close();
  49.                 } catch (IOException e) {
  51.                     e.printStackTrace();
  52.                 }
  53.             }
  54.         }
  55.     }
  56. }

返回数据的部分截图：
在这里插入图片描述

HttpGet带参请求

在返回的这部分数据中找到一个请求地址发送一个带参数的GET请求，就以请求乘风破浪的姐姐为例：

  1. //HttpClient发送带参数的GET请求
  2. public class HttpGetRequestParam {
  4.     public static void main(String[] args) {
  6.         //百度贴吧的uri地址
  7.         String uri = "https://tieba.baidu.com/f";  // --> /f：就是二级地址:注意地址一定要正确哦！一不小心就会404
  8.         //1、创建HttpClient连接
  9.         CloseableHttpClient httpClient = HttpClients.createDefault();
  10.         CloseableHttpResponse response = null;
  11.         try {
  13.             //1.5、封装GET请求的参数
  14.             URIBuilder uriBuilder = new URIBuilder(uri);
  15.             //第一种：setParameter放参数
  16.             uriBuilder.setParameter("kw", "乘风破浪的姐姐");
  17.             //uriBuilder.setParameter("kw","乘风破浪的姐姐").setParameter("t","其他参数");
  19.             //第二种：放参数
  20.             //List<NameValuePair> params = new ArrayList<>();
  21.             //params.add(new BasicNameValuePair("kw", "乘风破浪的姐姐"));
  22.             //params.add(new BasicNameValuePair("t", "其他"));
  23.             //uriBuilder.setParameters(params);
  25.             //第三种：放参数
  26.             //uriBuilder.setParameters(new BasicNameValuePair("kw", "乘风破浪的姐姐"),
  27.             //        new BasicNameValuePair("t", "其他参数"));
  29.             //2、创建HtpGet请求:uriBuilder.build()
  30.             HttpGet httpGet = new HttpGet(uriBuilder.build());
  31.             //3、HttpClient发送请求
  32.             response = httpClient.execute(httpGet);
  33.             //4、拿到请求页面的返回数据,请求成功才有数据啊！
  34.             HttpEntity entity = null;
  35.             if (response != null && response.getStatusLine().getStatusCode() == 200) {
  37.                 //获取服务器返回的实体数据
  38.                 entity = response.getEntity();
  39.                 //把实体数据转换成指定类型的字符串
  40.                 String context = EntityUtils.toString(entity, "utf8");
  41.                 System.out.println(context);
  42.             }
  44.         } catch (URISyntaxException | IOException e) {
  46.             e.printStackTrace();
  47.         } finally {
  49.             //不管如何关闭响应、请求的连接
  50.             if (response != null) {
  52.                 try {
  54.                     response.close();
  55.                 } catch (IOException e) {
  57.                     e.printStackTrace();
  58.                 }
  59.             }
  60.             if (httpClient != null) {
  62.                 try {
  64.                     httpClient.close();
  65.                 } catch (IOException e) {
  67.                     e.printStackTrace();
  68.                 }
  69.             }
  70.         }
  71.     }
  72. }

拿到的响应数据部分截图：

在这里插入图片描述

HttpPost请求

同HttpGet请求一样，请求百度贴吧的地址，细看之下，POST请求和GET请求是一样地。

  1. //HttpClient发送POST请求
  2. public class HttpPostRequest {
  4.     public static void main(String[] args) {
  6.         String uri = "https://tieba.baidu.com";
  7.         //1、创建客户端，建立连接
  8.         CloseableHttpClient httpClient = HttpClients.createDefault();
  9.         //2、创建POST请求
  10.         HttpPost httpPost = new HttpPost(uri);
  11.         CloseableHttpResponse response = null;
  12.         try {
  14.             //3、发送请求
  15.             response = httpClient.execute(httpPost);
  16.             //4、获取响应数据
  17.             if (response != null && response.getStatusLine().getStatusCode() == 200) {
  19.                 HttpEntity entity = response.getEntity();
  20.                 String context = EntityUtils.toString(entity, "utf-8");
  21.                 System.out.println(context);
  22.             }
  23.         } catch (IOException e) {
  25.             e.printStackTrace();
  26.         } finally {
  28.             //不管如何关闭响应、请求的连接
  29.             if (response != null) {
  31.                 try {
  33.                     response.close();
  34.                 } catch (IOException e) {
  36.                     e.printStackTrace();
  37.                 }
  38.             }
  39.             if (httpClient != null) {
  41.                 try {
  43.                     httpClient.close();
  44.                 } catch (IOException e) {
  46.                     e.printStackTrace();
  47.                 }
  48.             }
  49.         }
  51.     }
  52. }

返回数据部分截图：
在这里插入图片描述

HttpPost带参请求(提交表单数据)

POST请求一般用来提交表单数据，下面就是 POST带参请求的示例，同样以和HttpGet带参请求相同的地址乘风破浪的姐姐为例：

  1. //由于篇幅的原因，异常不捕捉，直接抛出去了
  2. //HttpClient发送带参POST请求
  3. public class HttpPostRequestParam {
  5.     public static void main(String[] args) throws IOException {
  7.         String uri = "https://tieba.baidu.com/f";
  8.         //1、创建客户端，建立连接
  9.         CloseableHttpClient httpClient = HttpClients.createDefault();
  10.         //1.5、封装表单参数
  11.         //********************************************
  12.         List<NameValuePair> params = new ArrayList<>();
  13.         params.add(new BasicNameValuePair("kw", "乘风破浪的姐姐"));
  14.         UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(params);
  15.         //2、创建HttpPost请求
  16.         HttpPost httpPost = new HttpPost(uri);
  17.         //设置表单参数到请求体
  18.         httpPost.setEntity(formEntity);
  19.         //********************************************
  20.         //3、发送数据
  21.         CloseableHttpResponse response = httpClient.execute(httpPost);
  22.         if (response != null && response.getStatusLine().getStatusCode() == 200) {
  24.             //4、获取数据
  25.             HttpEntity entity = response.getEntity();
  26.             String context = EntityUtils.toString(entity, "utf-8");
  27.             System.out.println(context);
  28.         }
  29.         //关闭资源
  30.         if (response != null) {
  32.             response.close();
  33.         }
  34.         if (httpClient != null) {
  36.             httpClient.close();
  37.         }
  38.     }
  39. }

获取到返回的数据：

在这里插入图片描述

仔细对比之下，HttpGet请求和HttpPost请求除了参数的封装方式不一样之外其他的全部都是相同的。

HttpClient连接池+请求配置

httpClient连接池就类似于数据库连接池一样，从一个池子里里面获取连接。
从上面的示例可以看出，每一个代码后面都有一个finally代码块中的代码去关闭资源，而频繁的创建、关闭资源对性能的影响是很大的（就相当于每次打开浏览器，再关闭），所以在这里有了HttpClient连接池的概念。

连接池准备好HttpClient（先打开一定数量的浏览器）每次请求从连接池中获取一个HttpClient连接（随便拿到一个已经打开的浏览器使用），使用完成后HttpClient再归还到连接池中（让别人使用）。

下面的示例就是创建连接池以及设置请求配置的步骤，除此之外，无论是GET请求还是POST请求都无变化。

  1. //HttpClient连接池
  2. public class HttpClientPool {
  5.     public static void main(String[] args) throws IOException {
  7.         //创建HttpClient连接池:使用连接池管理器发起请求
  8.         PoolingHttpClientConnectionManager pm = new PoolingHttpClientConnectionManager();
  9.         //设置连接池最大连接数量
  10.         pm.setMaxTotal(100);
  11.         //设置每个主机(访问的目标主机)的最大连接数
  12.         //每一个相同的主机最多获取10个连接数量：连接可以尽可能的达到一个数据均衡的目的
  13.         pm.setDefaultMaxPerRoute(10);
  14.         //设置请求设置：部分
  15.         RequestConfig requestConfig = RequestConfig.custom().setConnectionRequestTimeout(5000)  //设置连接最长时间5000毫秒
  16.                 .setConnectTimeout(500)   //创建连接的最长时间：ms
  17.                 .setSocketTimeout(10 * 1000).build();  //设置数据传输的最长时间
  18.         //设置请求信息
  19.         doGet(pm, requestConfig);
  20.         doGet(pm, requestConfig);
  21.     }
  23.     private static void doGet(PoolingHttpClientConnectionManager pm, RequestConfig config) throws IOException {
  25.         //不每次都创建新的HttpClient，而是从连接池管理器中获取连接
  26.         CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(pm).build();
  27.         //下面的部分就相同了
  28.         String uri = "https://www.baidu.com/";
  29.         HttpGet httpGet = new HttpGet(uri);
  30.         //设置请求信息
  31.         httpGet.setConfig(config);
  32.         //
  33.         CloseableHttpResponse response = httpClient.execute(httpGet);
  34.         if (response != null && response.getStatusLine().getStatusCode() == 200) {
  36.             HttpEntity entity = response.getEntity();
  37.             String content = EntityUtils.toString(entity, "utf-8");
  38.             System.out.println(content);
  39.         }
  40.         //关闭响应
  41.         response.close();
  42.         //注意！这就不用关闭HttpClient了，因为连接通过连接池管理了
  43.         //httpClient.close();
  44.     }
  45. }

发表评论

表情：
评论列表 （有 0 条评论，118人围观）

还没有评论，来说两句吧...

相关阅读