首页    技术博客    PHP教程    数据库技术    前端开发   HTML5    Nginx    php论坛
新用户注册 | 会员登录
加入会员，解锁专属内容
取消
热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

HttpClient入门（1）发送请求，处理响应及响应重复读取

作者：天雨 | 来源：互联网 | 2023-07-11 12:37
HttpClient是Apache旗下的项目，是一个负责创建和维护HTTP和相关协议的工具集。以下分析使用版本为：httpclient-4.5.3.ja

HttpClient是Apache旗下的项目&＃xff0c;是一个负责创建和维护HTTP和相关协议的工具集。

以下分析使用版本为&＃xff1a; httpclient-4.5.3.jar&＃xff0c; httpcore-4.4.6.jar&＃xff0c; jdk1.8.0_131 所有示例代码均经过运行测试

发送请求

httpclient最重要的功能就是发送http请求&＃xff0c;下面介绍如何执行一个get请求&＃xff1a;

CloseableHttpClient httpclient &＃61; HttpClients.createDefault();
HttpGet get &＃61; new HttpGet("http://www.jianshu.com/u/8a3115bb299c");
try(CloseableHttpResponse response &＃61; httpclient.execute(get)) { HttpEntity entity &＃61; response.getEntity();System.out.println(EntityUtils.toString(entity, "UTF-8"));
} catch (Exception e) {e.printStackTrace();
}

httpclient支持Http/1.1规范中定义的所有方法&＃xff1a;GET&＃xff0c;HEAD&＃xff0c;POST&＃xff0c;PUT&＃xff0c;DELETE&＃xff0c;TRACE&＃xff0c;OPTIONS&＃xff0c;对应的类是&＃xff1a;HttpGet&＃xff0c;HttpHead&＃xff0c;HttpPost&＃xff0c;HttpPut&＃xff0c;HttpDelete&＃xff0c;HttpTrace&＃xff0c;HttpOptions。

请求URI

URI&＃xff08;统一资源标识符&＃xff09;&＃xff0c;用于标识应用请求的资源&＃xff0c;通常由协议版本&＃xff0c;主机名&＃xff0c;端口&＃xff08;可选&＃xff09;&＃xff0c;资源路径&＃xff0c;参数名&＃xff08;可选&＃xff09;&＃xff0c;参数值&＃xff08;可选&＃xff09;组成。 请求时&＃xff0c;可以通过拼接字符串的形式访问&＃xff1a;

HttpGet get &＃61; new HttpGet("http://www.jianshu.com/p/7021031d6e49?utm_medium&＃61;index-banner&utm_source&＃61;desktop");

httpclient也提供了URIBuilder这个类简化请求URI的创建和修改。

URI uri &＃61; new URIBuilder().setScheme("http").setHost("www.jianshu.com").setPath("/p/7021031d6e49").setParameter("utm_medium", "index-banner").setParameter("utm_source", "desktop").build();
HttpGet httpget &＃61; new HttpGet(uri);
System.out.println(httpget.getURI());

输出

http://www.jianshu.com/p/7021031d6e49?utm_medium&＃61;index-banner&utm_source&＃61;desktop

http请求是客户端发给服务端的一个消息&＃xff0c;消息的第一行包括了请求方法&＃xff0c;URI以及使用的协议版本。

HttpGet get &＃61; new HttpGet("http://www.jianshu.com/u/8a3115bb299c");
RequestLine requestLine &＃61; get.getRequestLine();
System.out.println(requestLine.getMethod());
System.out.println(requestLine.getUri());
System.out.println(requestLine.getProtocolVersion());
System.out.println(requestLine);

输出

GET
http://www.jianshu.com/u/8a3115bb299c
HTTP/1.1
GET http://www.jianshu.com/u/8a3115bb299c HTTP/1.1

处理响应

服务端接收并处理请求后&＃xff0c;会返回消息给到客户端&＃xff0c;该消息的第一行包括协议版本&＃xff0c;状态码以及描述文字。

CloseableHttpClient httpclient &＃61; HttpClients.createDefault();
HttpGet get &＃61; new HttpGet("http://www.jianshu.com/u/8a3115bb299c");
try(CloseableHttpResponse response &＃61; httpclient.execute(get)) { System.out.println(response.getStatusLine());System.out.println(response.getProtocolVersion());System.out.println(response.getStatusLine().getStatusCode());System.out.println(response.getStatusLine().getReasonPhrase());System.out.println(response.getStatusLine().toString());
} catch (Exception e) {e.printStackTrace();
}

输出

HTTP/1.1 200 OK
HTTP/1.1
200
OK
HTTP/1.1 200 OK

服务端返回的响应被封装在HttpEntity&＃xff0c;通过HttpEntity可以获取请求响应的一些元信息&＃xff0c;比如Content-Type&＃xff0c;Content-Length以及Content-Encoding&＃xff0c;元信息需由服务端提供&＃xff0c;否则将是空值。

CloseableHttpClient httpclient &＃61; HttpClients.createDefault();
HttpGet get &＃61; new HttpGet("http://www.jianshu.com/u/8a3115bb299c");
try(CloseableHttpResponse response &＃61; httpclient.execute(get)) { HttpEntity entity &＃61; response.getEntity();System.out.println(entity.getContentType());System.out.println(entity.getContentLength());System.out.println(entity.getContentEncoding());
} catch (Exception e) {e.printStackTrace();
}

输出

Content-Type: text/html; charset&＃61;utf-8
-1
null

HttpEntity提供了多种方法来读取正文&＃xff0c;官方文档推荐使用以下方法进行读取&＃xff1a;HttpEntity.getContent() 与 HttpEntity.writeTo(outputStream)

HttpEntity.getContent()方式

CloseableHttpClient httpclient &＃61; null;
CloseableHttpResponse response &＃61; null;
BufferedReader reader &＃61; null;
try {httpclient &＃61; HttpClients.createDefault();HttpGet get &＃61; new HttpGet("http://www.jianshu.com/u/8a3115bb299c");response &＃61; httpclient.execute(get);HttpEntity entity &＃61; response.getEntity();reader &＃61; new BufferedReader(new InputStreamReader(entity.getContent(), "UTF-8"));String str &＃61; "";StringBuilder sb &＃61; new StringBuilder(); while ((str &＃61; reader.readLine()) !&＃61; null) { sb.append(str).append("\n"); }System.out.println(sb);
} catch (Exception e) {e.printStackTrace();
} finally {CommonUtils.closeReader(reader);CommonUtils.closeResponse(response);CommonUtils.closeHttpClient(httpclient);
}

CommonUtils

public void closeReader(BufferedReader reader) {try {if (reader !&＃61; null) {reader.close();}} catch (Exception e) {e.printStackTrace();}
}public void closeResponse(CloseableHttpResponse response) {try {if (response !&＃61; null) {response.close();}} catch (Exception e) {e.printStackTrace();}
}public void closeHttpClient(CloseableHttpClient httpclient) {try {if (httpclient !&＃61; null) {httpclient.close();}} catch (Exception e) {e.printStackTrace();}
}

HttpEntity.writeTo方式

CloseableHttpClient httpclient &＃61; null;
CloseableHttpResponse response &＃61; null;
ByteArrayOutputStream outstream &＃61; new ByteArrayOutputStream();
try {httpclient &＃61; HttpClients.createDefault();HttpGet get &＃61; new HttpGet("http://www.jianshu.com/u/8a3115bb299c");response &＃61; httpclient.execute(get);HttpEntity entity &＃61; response.getEntity();entity.writeTo(outstream);System.out.println(outstream.toString("UTF-8"));
} catch (Exception e) {e.printStackTrace();
} finally {CommonUtils.closeOutputStream(outstream);CommonUtils.closeResponse(response);CommonUtils.closeHttpClient(httpclient);
}

CommonUtils

public void closeOutputStream(ByteArrayOutputStream outstream) {try {if (outstream !&＃61; null) {outstream.close();}} catch (Exception e) {e.printStackTrace();}
}

为了确保资源的正确释放&＃xff0c;采用上述两种方式读取正文时&＃xff0c;都需对流进行关闭。除此之外&＃xff0c;HttpClient还提供了EntityUtils工具类&＃xff0c;方便对正文的读取操作&＃xff0c;不过官方文档中建议&＃xff0c;只有当响应实体来自受信任的HTTP服务器&＃xff0c;并且已知其长度有限&＃xff0c;才可以采用这种方法。

EntityUtils.toString方式

CloseableHttpClient httpclient &＃61; HttpClients.createDefault();
HttpGet get &＃61; new HttpGet("http://www.jianshu.com/u/8a3115bb299c");
try(CloseableHttpResponse response &＃61; httpclient.execute(get)) { HttpEntity entity &＃61; response.getEntity();System.out.println(EntityUtils.toString(entity, "UTF-8"));
} catch (Exception e) {e.printStackTrace();
} finally {CommonUtils.closeHttpClient(httpclient);
}

EntityUtils.toString内部会对HttpEntity中的输入流进行关闭。 以上三种读取方式&＃xff0c;当CloseableHttpClient的实例不再使用时&＃xff0c;都需调用close方法进行关闭。

通过BufferedHttpEntity实现响应多次读取

对于流类型的HttpEntity而言&＃xff0c;是不可重复读取的&＃xff0c;若想多次读取&＃xff0c;则需要在某个地方将HttpEntity缓存起来&＃xff0c;最简单的方式&＃xff0c;可以使用HttpClient提供的BufferedHttpEntity类来实现。

HttpEntity.getContent()&＃43;BufferedHttpEntity实现多次读取

CloseableHttpClient httpclient &＃61; HttpClients.createDefault();
HttpGet get &＃61; new HttpGet("http://www.jianshu.com/u/8a3115bb299c");
try(CloseableHttpResponse response &＃61; httpclient.execute(get)) {HttpEntity entity &＃61; response.getEntity();BufferedHttpEntity bufferedEntity &＃61; new BufferedHttpEntity(entity);System.out.println(getEntityContent(bufferedEntity));System.out.println(getEntityContent(bufferedEntity));
} catch (Exception e) {e.printStackTrace();
} finally {CommonUtils.closeHttpClient(httpclient);
}

public String getEntityContent(HttpEntity entity) {try(BufferedReader reader &＃61; new BufferedReader(new InputStreamReader(entity.getContent(), "UTF-8"))) {String str &＃61; "";StringBuilder sb &＃61; new StringBuilder(); while ((str &＃61; reader.readLine()) !&＃61; null) { sb.append(str).append("\n"); }return sb.toString();} catch (Exception e) {e.printStackTrace();return "";}
}

HttpEntity.writeTo&＃43;BufferedHttpEntity实现多次读取

CloseableHttpClient httpclient &＃61; HttpClients.createDefault();
HttpGet get &＃61; new HttpGet("http://www.jianshu.com/u/8a3115bb299c");
try(CloseableHttpResponse response &＃61; httpclient.execute(get)) {HttpEntity entity &＃61; response.getEntity();BufferedHttpEntity bufferedEntity &＃61; new BufferedHttpEntity(entity);System.out.println(getContentByWriteTo(bufferedEntity));System.out.println(getContentByWriteTo(bufferedEntity));
} catch (Exception e) {e.printStackTrace();
} finally {CommonUtils.closeHttpClient(httpclient);
}

public String getContentByWriteTo(HttpEntity entity) {try(ByteArrayOutputStream outstream &＃61; new ByteArrayOutputStream()) {entity.writeTo(outstream);return outstream.toString("UTF-8");} catch (Exception e) {e.printStackTrace();return "";}
}

EntityUtils.toString&＃43;BufferedHttpEntity实现多次读取

CloseableHttpClient httpclient &＃61; HttpClients.createDefault();
HttpGet get &＃61; new HttpGet("http://www.jianshu.com/u/8a3115bb299c");
try(CloseableHttpResponse response &＃61; httpclient.execute(get)) { HttpEntity entity &＃61; response.getEntity();BufferedHttpEntity bufferedEntity &＃61; new BufferedHttpEntity(entity);System.out.println(EntityUtils.toString(bufferedEntity, "UTF-8"));System.out.println(EntityUtils.toString(bufferedEntity, "UTF-8"));
} catch (Exception e) {e.printStackTrace();
} finally {CommonUtils.closeHttpClient(httpclient);
}

至此&＃xff0c;通过HttpClient&＃xff0c;简单实现了http get请求的发送和响应处理。




推荐阅读
  • text

    使用Python爬取妙笔阁小说信息并保存为TXT和CSV格式

    本文介绍了如何使用Python爬取妙笔阁小说网仙侠系列中所有小说的信息，并将其保存为TXT和CSV格式。主要内容包括如何构造请求头以避免被网站封禁，以及如何利用XPath解析HTML并提取所需信息。 ... [详细]
  • byte

    HTTP header 介绍

    HTTP(HyperTextTransferProtocol)是超文本传输协议的缩写，它用于传送www方式的数据。HTTP协议采用了请求响应模型。客服端向服务器发送一 ... [详细]
  • io

    解决Only fullscreen opaque activities can request orientation错误的方法

    解决Only fullscreen opaque activities can request orientation错误的方法
    本文介绍了在使用PictureSelectorLight第三方框架时遇到的Only fullscreen opaque activities can request orientation错误，并提供了一种有效的解决方案。 ... [详细]
  • stream

    如何将TS文件转换为M3U8直播流：HLS与M3U8格式详解

    如何将TS文件转换为M3U8直播流：HLS与M3U8格式详解
    在视频传输领域，MP4虽然常见，但在直播场景中直接使用MP4格式存在诸多问题。例如，MP4文件的头部信息（如ftyp、moov）较大，导致初始加载时间较长，影响用户体验。相比之下，HLS（HTTP Live Streaming）协议及其M3U8格式更具优势。HLS通过将视频切分成多个小片段，并生成一个M3U8播放列表文件，实现低延迟和高稳定性。本文详细介绍了如何将TS文件转换为M3U8直播流，包括技术原理和具体操作步骤，帮助读者更好地理解和应用这一技术。 ... [详细]
  • php

    Cookie学习小结

    Cookie学习小结
    Cookie学习小结 ... [详细]
  • text

    python模块之正则

    python模块之正则
    re模块可以读懂你写的正则表达式根据你写的表达式去执行任务用re去操作正则正则表达式使用一些规则来检测一些字符串是否符合个人要求，从一段字符串中找到符合要求的内容。在 ... [详细]
  • io

    一个Tomcat配置多个端口

    一、Tomcat安装后本身提供了一个server，端口配置默认是8080，对应目录为：..\Tomcat8.0\webapps二、Tomcat8.0配置多个端口，其实也就是给T ... [详细]
  • text

    Android Studio SQLite 数据库 增删改查 简单（代码参考）

    一个建表一个执行crud操作建表代码importandroid.content.Context;importandroid.database.sqlite.SQLiteDat ... [详细]
  • text

    Spring Data JdbcTemplate 入门指南

    Spring Data JdbcTemplate 入门指南
    本文将介绍如何使用 Spring JdbcTemplate 进行数据库操作，包括查询和插入数据。我们将通过一个学生表的示例来演示具体步骤。 ... [详细]
  • byte

    将.o文件链接到.elf文件时

    我有一个从C项目编译的.o文件，该文件引用了名为init_static_pool ... [详细]
  • io

    Linux 环境下 Java 及相关软件的安装指南

    本文详细介绍了如何在 Linux 系统上安装 JDK 1.8、MySQL 和 Redis，并提供了相应的环境配置和验证步骤。 ... [详细]
  • io

    使用ArcGIS for Java和Flex浏览自定义ArcGIS Server 9.3地图

    使用ArcGIS for Java和Flex浏览自定义ArcGIS Server 9.3地图
    本文介绍了如何在Flex应用程序中实现浏览自定义ArcGIS Server 9.3发布的地图。这是一个基本的入门示例，适用于初学者。 ... [详细]
  • io

    （7）Python爬虫——爬取豆瓣电影Top250

    利用python爬取豆瓣电影Top250的相关信息，包括电影详情链接,图片链接,影片中文名,影片外国名,评分,评价数,概况,导演,主演,年份,地区,类别这12项内容，然后将爬取的信息写入Exce ... [详细]
  • text

    Android 自定义加载对话框 CustomProgressDialog

    本文介绍如何在 Android 中自定义加载对话框 CustomProgressDialog，包括自定义 View 类和 XML 布局文件的详细步骤。 ... [详细]
  • php

    网站访问全流程解析

    网站访问全流程解析
    本文详细介绍了从用户在浏览器中输入一个域名（如www.yy.com）到页面完全展示的整个过程，包括DNS解析、TCP连接、请求响应等多个步骤。 ... [详细]
author-avatar
天雨
这个家伙很懒，什么也没留下！
Tags | 热门标签
RankList | 热门文章
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有