首页    技术博客    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请求的发送和响应处理。




推荐阅读
  • io

    如何实现织梦DedeCms全站伪静态

    如何实现织梦DedeCms全站伪静态
    本文介绍了如何通过修改织梦DedeCms源代码来实现全站伪静态，以提高管理和SEO效果。全站伪静态可以避免重复URL的问题，同时通过使用mod_rewrite伪静态模块和.htaccess正则表达式，可以更好地适应搜索引擎的需求。文章还提到了一些相关的技术和工具，如Ubuntu、qt编程、tomcat端口、爬虫、php request根目录等。 ... [详细]
  • string

    Spring源码解密之默认标签的解析方式分析

    Spring源码解密之默认标签的解析方式分析
    本文分析了Spring源码解密中默认标签的解析方式。通过对命名空间的判断，区分默认命名空间和自定义命名空间，并采用不同的解析方式。其中，bean标签的解析最为复杂和重要。 ... [详细]
  • string

    SpringBoot uri统一权限管理的实现方法及步骤详解

    SpringBoot uri统一权限管理的实现方法及步骤详解
    本文详细介绍了SpringBoot中实现uri统一权限管理的方法，包括表结构定义、自动统计URI并自动删除脏数据、程序启动加载等步骤。通过该方法可以提高系统的安全性，实现对系统任意接口的权限拦截验证。 ... [详细]
  • main

    阿里云物联网 .NET Core 客户端 | CZGL.AliIoTClient：4. 设备上报属性

    阿,里,云,物,联网,net,core,客户端,czgl,aliiotclient, ... [详细]
  • string

    PHP URL处理的三个函数详解

    本文详细介绍了PHP中与URL处理相关的三个函数：http_build_query、parse_str和查询字符串的解析。通过示例和语法说明，讲解了这些函数的使用方法和作用，帮助读者更好地理解和应用。 ... [详细]
  • string

    在重复造轮子的情况下用ProxyServlet反向代理来减少工作量

    在重复造轮子的情况下用ProxyServlet反向代理来减少工作量
    像不少公司内部不同团队都会自己研发自己工具产品，当各个产品逐渐成熟，到达了一定的发展瓶颈，同时每个产品都有着自己的入口，用户 ... [详细]
  • version

    自动轮播，反转播放的ViewPagerAdapter的使用方法和效果展示

    自动轮播，反转播放的ViewPagerAdapter的使用方法和效果展示
    本文介绍了如何使用自动轮播、反转播放的ViewPagerAdapter，并展示了其效果。该ViewPagerAdapter支持无限循环、触摸暂停、切换缩放等功能。同时提供了使用GIF.gif的示例和github地址。通过LoopFragmentPagerAdapter类的getActualCount、getActualItem和getActualPagerTitle方法可以实现自定义的循环效果和标题展示。 ... [详细]
  • main

    Java学习笔记之面向对象编程（OOP）

    Java学习笔记之面向对象编程（OOP）
    本文介绍了Java学习笔记中的面向对象编程（OOP）内容，包括OOP的三大特性（封装、继承、多态）和五大原则（单一职责原则、开放封闭原则、里式替换原则、依赖倒置原则）。通过学习OOP，可以提高代码复用性、拓展性和安全性。 ... [详细]
  • testing

    ShiftLeft：将静态防护与运行时防护结合的持续性安全防护解决方案

    ShiftLeft：将静态防护与运行时防护结合的持续性安全防护解决方案
    ShiftLeft公司是一家致力于将应用的静态防护和运行时防护与应用开发自动化工作流相结合以提升软件开发生命周期中的安全性的公司。传统的安全防护方式存在误报率高、人工成本高、耗时长等问题，而ShiftLeft提供的持续性安全防护解决方案能够解决这些问题。通过将下一代静态代码分析与应用开发自动化工作流中涉及的安全工具相结合，ShiftLeft帮助企业实现DevSecOps的安全部分，提供高效、准确的安全能力。 ... [详细]
  • string

    Java如何导入和导出Excel文件的方法和步骤详解

    Java如何导入和导出Excel文件的方法和步骤详解
    本文详细介绍了在SpringBoot中使用Java导入和导出Excel文件的方法和步骤，包括添加操作Excel的依赖、自定义注解等。文章还提供了示例代码，并将代码上传至GitHub供访问。 ... [详细]
  • version

    交换机华为命令行配置视图

    用户视图(查看运行状态或其他参数)系统视图(配置设备的系统参数)system-viewEntersystemview,returnuservi ... [详细]
  • version

    前端 Django那些以re开头的功能单词

    Request对象和Response对象request:(请求)当一个页面被请求时，Django就会创建一个包含本次请求原信息的HttpRequest对象。Djang ... [详细]
  • main

    Go Cobra命令行工具入门教程

    Go Cobra命令行工具入门教程
    本文介绍了Go语言实现的命令行工具Cobra的基本概念、安装方法和入门实践。Cobra被广泛应用于各种项目中，如Kubernetes、Hugo和Github CLI等。通过使用Cobra，我们可以快速创建命令行工具，适用于写测试脚本和各种服务的Admin CLI。文章还通过一个简单的demo演示了Cobra的使用方法。 ... [详细]
  • string

    C#制作Java+Mysql+Tomcat环境安装程序，一键式安装教程

    本文介绍了如何使用C#制作Java+Mysql+Tomcat环境安装程序，实现一键式安装。通过将JDK、Mysql、Tomcat三者制作成一个安装包，解决了客户在安装软件时的复杂配置和繁琐问题，便于管理软件版本和系统集成。具体步骤包括配置JDK环境变量和安装Mysql服务，其中使用了MySQL Server 5.5社区版和my.ini文件。安装方法为通过命令行将目录转到mysql的bin目录下，执行mysqld --install MySQL5命令。 ... [详细]
  • string

    iOS数据库Sqlite的SQL语句分类和常见约束关键字

    本文介绍了iOS数据库Sqlite的SQL语句分类和常见约束关键字。SQL语句分为DDL、DML和DQL三种类型，其中DDL语句用于定义、删除和修改数据表，关键字包括create、drop和alter。常见约束关键字包括if not exists、if exists、primary key、autoincrement、not null和default。此外，还介绍了常见的数据库数据类型，包括integer、text和real。 ... [详细]
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社区 版权所有