文档章节

httpClient4.3x版本的简单使用

 言不莫
发布于 2016/01/03 11:05
字数 703
阅读 3
收藏 0
点赞 0
评论 0

1、主要使用对象:

  1.  HttpClient:客户端

  2. HttpGetHttpPost:两种请求

  3. RequestConfig:请求配置

  4. HttpResponse:请求返回体

2、一般使用方法

  1. 创建客户端

  2. 配置客户端参数

  3. 创建get 或post 请求

  4. 设置请求参数如:添加cookie,请求头

  5. 执行请求,得到HttpResponse对象

  6. 解析HttpResponse,获取需要数据

    下面将所有的操作放在一个自己写的工具类中:

public class NetRequest {
 
 HttpClient client;
 HttpGet get;
 HttpPost post;
 HttpResponse response;
 
 boolean isGet = false;
 boolean isPost = false;
 
 public NetRequest() {
  client = HttpClientBuilder.create().build();
  
 }
 
 /**
  * 设置Get 请求
  * @param url
  * @param params
  * @return
  */
 public NetRequest setGet(String url,Map<String, Object> params){
  if(isPost){  
   client = HttpClientBuilder.create().build();
  }
  URI uri = setURI(url, params);
  get = new HttpGet(uri);
  isGet = true;
  isPost = false;
  return this;
 }
 
 /**
  * 设置Post请求
  * @param url
  * @param params
  * @return
  */
 public NetRequest setPost(String url,Map<String, Object> params){
  if(isGet){ 
   client = HttpClientBuilder.create().build();
  }
  URI uri = setURI(url, null);
  HttpEntity entity = setEntity(params);
  post = new HttpPost(uri);
  post.setEntity(entity);
  isGet = false;
  isPost = true;
  return this;
 }
 
 /**
  * 添加请求头
  * @param name
  * @param value
  * @return
  */
 public NetRequest addHead(String name,String value){
  if(isGet){
   get.addHeader(name, value);
  }
  if(isPost){
   post.addHeader(name, value);
  }
  return this;
 }
 
 /**
  * 添加Cookie
  * @param cookie
  * @return
  */
 public NetRequest addCookie(String cookie){
  addHead("Cookie", cookie);
  return this;
 }
 
 /**
  * 设置请求配置
  * @param config
  * @return
  */
 public NetRequest setRequestConfig(RequestConfig config){
  if(isGet){
   get.setConfig(config);
  }
  if(isPost){
   post.setConfig(config);
  }
  return this;
 }
 
 /**
  * 设置请求超时
  * @param conTime 连接
  * @param socketTime 数据传输
  * @return
  */
 public NetRequest setConnectiontime(int conTime,int socketTime){
  RequestConfig config = RequestConfig.custom().setConnectTimeout(conTime).setSocketTimeout(socketTime).build();
  return setRequestConfig(config);
 }
 
 /**
  * 执行请求
  * @return
  */
 public NetRequest doRequest(){
  //response = null;
  try{
   if(isGet){
    response = client.execute(get);
   }
   if(isPost){
    response = client.execute(post);
   }
  }catch(Exception e){
   e.printStackTrace();
  }
  
  return this;
 }
 
 /**
  * 获取返回字符串
  * @return
  */
 public String getStr(){
  try{
            HttpEntity entity = response.getEntity();
            String body = EntityUtils. toString(entity);
             return body;
      } catch(Exception e){
             e.printStackTrace();
             return null;
      }
 }
 
 
 public HttpResponse getResponse(){
  return response;
 }
 
 /**
  * 下载文件
  * @param file
  * @return
  */
 public  File getFile(File file){
        try{
             InputStream inputStream = response.getEntity().getContent();
             OutputStream outputStream = new FileOutputStream(file);
             int index = 0;
              byte[] btys = new byte[4096];
              while(( index = inputStream.read( btys)) != -1){
                    outputStream.write( btys, 0, index);
             }
              inputStream.close();
              outputStream.flush();
              outputStream.close();
              return file;
       } catch(Exception e){
              return null;
       }
 }
 
    public  File getFile(String filePath){
           try{
                File file = new File( filePath);
                 if(! file.exists()){
                       if(! file.getParentFile().exists()){
                             file.getParentFile().mkdirs();
                      }
                       file.createNewFile();
                }
                 return getFile(file);
          } catch(Exception e){
                 e.printStackTrace();
                 return null;
          }
          
    }
 
 
 /**
     * 设置参数 --在URI中
     * @param url
     * @param params
     * @return
     */
    public static URI setURI(String url,Map<String, Object> params){
           try{
                 if(! url.startsWith( "http")){
                       url = "http://" + url;
                }
                URIBuilder builder = new URIBuilder( url);
                 if( params == null){
                       return builder.build();
                }
                Set<String> keys = params.keySet();
                 for (String key : keys) {
                      Object object = params.get( key);
                       if( object.getClass().equals(File. class)){
                            
                      } else{
                             builder.addParameter( key, object.toString());
                      }
                }
                 return builder.build();
          } catch(Exception e){
                 e.printStackTrace();
                 return null;
          }
    }
    
    /**
     * 设置参数 --包含文件上传
     * @param params
     * @return
     */
    public static HttpEntity setEntity(Map<String, Object> params){
          MultipartEntityBuilder builder = MultipartEntityBuilder.create();
           builder.setMode(HttpMultipartMode. BROWSER_COMPATIBLE);//浏览器兼容模式
           try{
                 builder.setCharset(CharsetUtils. get("UTF-8" )); //设置编码
          } catch(Exception e){
                
          }
          Set<String> keys = params.keySet();
           for (String key : keys) {            
                Object object = params.get( key);                    
              if(object == null )
                    continue;              
                 if( object.getClass().equals(File. class)){
                      FileBody fileBody = new FileBody((File) object);
                       builder.addPart( key, fileBody);
                } else if(object.getClass().equals(String.class)){
                 
                      StringBody stringBody = new StringBody(object.toString(), ContentType.TEXT_PLAIN);
                      builder.addPart( key, stringBody);
                }
          }
           return builder.build();
    }
}

测试用例:

  NetRequest netRequest = new NetRequest();
  String sign = baseUrl + "/sign/mysign?page=1&step=1000&type=1";
  JSONArray array = JSONArray.parseArray(netRequest.setGet(sign, null).addCookie("JSESSIONID=9A5611188E3E25193DF1F848A012957D").doRequest().getStr());

 

 

 

© 著作权归作者所有

共有 人打赏支持
粉丝 0
博文 2
码字总数 2424
作品 0
南京
Zookeeper的简单结构的基本操作

Zookeeper的简单结构的基本操作 第一,整体结构的设计 第二,数据分层和命名空间 第三,客户端的一些基本操作 1.我使用的linux的客户端,在执行命令的时候需要一个比较关键东西就试需要java版...

年少爱追梦 ⋅ 2016/09/22 ⋅ 0

Spring Boot CLI安装及使用。

Spring Boot CLI是一种快速开发Spring应用的命令行界面。CLI就是Command Line Interface的简写,CLI利用了Spring Boot的起步依赖和自动配置,可以让人们专注于代码本身,而不用完成繁琐的配置...

Leafage_M ⋅ 2017/10/23 ⋅ 0

判断手机是否支持程序安装(版本判断)

今天早晨起来看了皇马和塞维利亚的比赛,睡不着了,不错,6:2的比分确实是场进球盛宴,而圣卡西在上半场的几次精彩扑救异常关键。好了,闲话少扯,开始正题。 改写了书上的一个小例子,判断手...

迷途d书童 ⋅ 2012/03/30 ⋅ 0

Npoi操作excel

Npoi 简介 1.整个Excel表格叫做工作表:WorkBook(工作薄),包含的叫页(工作表):Sheet;行:Row;单元格Cell。 2.Npoi 下载地址:http://npoi.codeplex.com/releases/view/38113 3.Npoi...

postdep ⋅ 2014/08/24 ⋅ 0

一个工具管理多个基于Java的应用程序

  【IT168 技术】如果程序员需要一个独立于平台的工具,并可以管理多个基于Java的应用程序,如Maven,Gradle和Tomcat,那么jenv是个不错的选择。使用jenv可以轻松地同时安装多个版本,轻松...

it168网站 ⋅ 2017/05/05 ⋅ 0

node版本管理工具nvm-Mac下安装及使用

前言 目前主流的node版本管理工具有两种,nvm和n。两者差异挺大的,具体分析可以参考一下淘宝FED团队的一篇文章: 管理 node 版本,选择 nvm 还是 n? 总的来说,nvm有点类似于 Python 的 vi...

Sailor20 ⋅ 2016/12/09 ⋅ 0

koa2试水

koa2出来已经很长一段时间了,之前一直没有遇上可以练手的项目,这次刚好有了机会,正好折腾一下。 安装 koa2需要7.6.0及以上的node版本,目的是为了支持async await语法,不需要babel支持(...

Yard ⋅ 2017/04/14 ⋅ 0

Mantis 1.2.3 发布,BUG管理系统

Mantis 1.2.3 是一个安全补丁版本,建议所有使用 1.2.x 版本的用户应立即升级到这个版本。该版本修复了一些潜在的 XSS 攻,改进了 Excel 导出功能;更新了一些翻译包,修复了 SOAP API、安装...

红薯 ⋅ 2010/09/15 ⋅ 0

服务端技术选型

服务框架 MVC Framework:Rose 框架简单易用,并且我米内部服务和工具都优先支持 Rose 项目,默认使用 Rose 框架是很好的选择。文艺一点想做个异步化 web 服务,可以选择 Spring MVC 3.2 以上...

北天_ ⋅ 2016/07/05 ⋅ 0

Mac 10.13 安装中文版 man 命令

Mac 10.13 安装中文版 man 命令 本文参考于 《Mac 安装man命令中文文档》,但原文提供的链接以及安装的版本比较老旧。因此重新整理新版在这边提供给大家。 为什么需要 man 以及 man 怎么使用...

FungLeo ⋅ 2017/11/13 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

解决httpclient超时设置不生效的问题

最近公司有项目需要通过http调用第三方服务,且第三方服务偶有超时,故需要设置一定的超时时间防止不响应的情况出现。 初始设置如下: [java] view plain copy //超时设置 RequestConfig re...

Mr_Tea伯奕 ⋅ 5分钟前 ⋅ 0

过滤器Filter和拦截器HandlerInterceptor

过滤器 依赖于servlet容器。在实现上基于函数回调,可以对几乎所有请求进行过滤,但是缺点是一个过滤器实例只能在容器初始化时调用一次。使用过滤器的目的是用来做一些过滤操作,获取我们想要...

hutaishi ⋅ 10分钟前 ⋅ 0

Redis入门详解(转)

Redis入门详解 Redis简介 Redis安装 Redis配置 Redis数据类型 Redis功能 持久化 主从复制 事务支持 发布订阅 管道 虚拟内存 Redis性能 Redis部署 Redis应用场景 Redis总结 Redis简介: Redi...

xiaoyaoyoufang ⋅ 22分钟前 ⋅ 0

说说javascript中的那些专业名词

DOM(Document Object Model) 文档对象模型 BOM(Browser Object Model) 浏览器对象模型 ECMA(European Computer Manufacturer's Association) 欧洲计算机制造商协会 W3C(World Wide Web Conso......

hang1989 ⋅ 41分钟前 ⋅ 0

Bootstrap Wizard 多步表单控件

废话 有一块需求是 有多步表单 点击下一步时触发验证一个范围内的表单,点击上一步或取消,清空表单并返回第一步,点击最后一步提交整个表单的 就找到了这个插件,本来自己写了一个原生的 fo...

无极之岚 ⋅ 57分钟前 ⋅ 0

如何利用Spring Cloud构建起自我修复型分布式系统

利用Netflix所打造的组件及各类大家熟知的工具,我们完全可以顺利应对由微服务以及分布式计算所带来的技术挑战。 在过去一年当中,微服务已经成为软件架构领域一个炙手可热的新名词,而且我们...

harries ⋅ 今天 ⋅ 0

临近实习前的感想

再过两星期就要开始新的一段实习了,想想去年的这个时候也在实习,心中不免思绪万千,也一直想写对2017做个总结,但一直迟迟没有下笔。 2017年的春节,我就开始准备开学后找份实习。那时候就...

无精疯 ⋅ 今天 ⋅ 0

Spring AOP(面向切面编程)

Spring AOP概念: Spring AOP 可以劫持一个执行的方法,在方法执行之前或之后添加额外的功能。通常情况下,AOP把项目中需要在多处用到的功能,比如日志、安全和事物等集中到一个类中处理,而...

霍淇滨 ⋅ 今天 ⋅ 0

人工智能、机器学习、数据挖掘以及数据分析有什么联系?

人工智能是目前炙手可热的一个领域,所有的互联网公司以及各路大迦们纷纷表态人工智能将是下一个时代的革命性技术,可与互联网、移动互联网时代的变更相媲美;AlphaGo在围棋领域战胜人类最顶...

董黎明 ⋅ 今天 ⋅ 0

使用 vue-cli 搭建项目

vue-cli 是一个官方发布 vue.js 项目脚手架,使用 vue-cli 可以快速创建 vue 项目,GitHub地址是:https://github.com/vuejs/vue-cli 一、 安装 node.js 首先需要安装node环境,可以直接到中...

初学者的优化 ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部