使用HttpClient调用接口的实例讲解

更新时间：2017年10月07日 09:55:58 作者：0001

下面小编就为大家带来一篇使用HttpClient调用接口的实例讲解。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧

一，编写返回对象

public class HttpResult {
// 响应的状态码
private int code;

// 响应的响应体
private String body;
get/set…
}

二，封装HttpClient

package cn.xxxxxx.httpclient;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.apache.http.NameValuePair;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpDelete;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpPut;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;

public class APIService {

 private CloseableHttpClient httpClient;

 public APIService() {
  // 1 创建HttpClinet，相当于打开浏览器
  this.httpClient = HttpClients.createDefault();
 }

 /**
  * 带参数的get请求
  * 
  * @param url
  * @param map
  * @return
  * @throws Exception
  */
 public HttpResult doGet(String url, Map<String, Object> map) throws Exception {

  // 声明URIBuilder
  URIBuilder uriBuilder = new URIBuilder(url);

  // 判断参数map是否为非空
  if (map != null) {
   // 遍历参数
   for (Map.Entry<String, Object> entry : map.entrySet()) {
    // 设置参数
    uriBuilder.setParameter(entry.getKey(), entry.getValue().toString());
   }
  }

  // 2 创建httpGet对象，相当于设置url请求地址
  HttpGet httpGet = new HttpGet(uriBuilder.build());

  // 3 使用HttpClient执行httpGet，相当于按回车，发起请求
  CloseableHttpResponse response = this.httpClient.execute(httpGet);

  // 4 解析结果，封装返回对象httpResult，相当于显示相应的结果
  // 状态码
  // response.getStatusLine().getStatusCode();
  // 响应体，字符串，如果response.getEntity()为空，下面这个代码会报错,所以解析之前要做非空的判断
  // EntityUtils.toString(response.getEntity(), "UTF-8");
  HttpResult httpResult = null;
  // 解析数据封装HttpResult
  if (response.getEntity() != null) {
   httpResult = new HttpResult(response.getStatusLine().getStatusCode(),
     EntityUtils.toString(response.getEntity(), "UTF-8"));
  } else {
   httpResult = new HttpResult(response.getStatusLine().getStatusCode(), "");
  }

  // 返回
  return httpResult;
 }

 /**
  * 不带参数的get请求
  * 
  * @param url
  * @return
  * @throws Exception
  */
 public HttpResult doGet(String url) throws Exception {
  HttpResult httpResult = this.doGet(url, null);
  return httpResult;
 }

 /**
  * 带参数的post请求
  * 
  * @param url
  * @param map
  * @return
  * @throws Exception
  */
 public HttpResult doPost(String url, Map<String, Object> map) throws Exception {
  // 声明httpPost请求
  HttpPost httpPost = new HttpPost(url);

  // 判断map不为空
  if (map != null) {
   // 声明存放参数的List集合
   List<NameValuePair> params = new ArrayList<NameValuePair>();

   // 遍历map，设置参数到list中
   for (Map.Entry<String, Object> entry : map.entrySet()) {
    params.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString()));
   }

   // 创建form表单对象
   UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(params, "UTF-8");

   // 把表单对象设置到httpPost中
   httpPost.setEntity(formEntity);
  }

  // 使用HttpClient发起请求，返回response
  CloseableHttpResponse response = this.httpClient.execute(httpPost);

  // 解析response封装返回对象httpResult
  HttpResult httpResult = null;
  if (response.getEntity() != null) {
   httpResult = new HttpResult(response.getStatusLine().getStatusCode(),
     EntityUtils.toString(response.getEntity(), "UTF-8"));
  } else {
   httpResult = new HttpResult(response.getStatusLine().getStatusCode(), "");
  }

  // 返回结果
  return httpResult;
 }

 /**
  * 不带参数的post请求
  * 
  * @param url
  * @return
  * @throws Exception
  */
 public HttpResult doPost(String url) throws Exception {
  HttpResult httpResult = this.doPost(url, null);
  return httpResult;
 }

 /**
  * 带参数的Put请求
  * 
  * @param url
  * @param map
  * @return
  * @throws Exception
  */
 public HttpResult doPut(String url, Map<String, Object> map) throws Exception {
  // 声明httpPost请求
  HttpPut httpPut = new HttpPut(url);

  // 判断map不为空
  if (map != null) {
   // 声明存放参数的List集合
   List<NameValuePair> params = new ArrayList<NameValuePair>();

   // 遍历map，设置参数到list中
   for (Map.Entry<String, Object> entry : map.entrySet()) {
    params.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString()));
   }

   // 创建form表单对象
   UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(params, "UTF-8");

   // 把表单对象设置到httpPost中
   httpPut.setEntity(formEntity);
  }

  // 使用HttpClient发起请求，返回response
  CloseableHttpResponse response = this.httpClient.execute(httpPut);

  // 解析response封装返回对象httpResult
  HttpResult httpResult = null;
  if (response.getEntity() != null) {
   httpResult = new HttpResult(response.getStatusLine().getStatusCode(),
     EntityUtils.toString(response.getEntity(), "UTF-8"));
  } else {
   httpResult = new HttpResult(response.getStatusLine().getStatusCode(), "");
  }

  // 返回结果
  return httpResult;
 }

 /**
  * 带参数的Delete请求
  * 
  * @param url
  * @param map
  * @return
  * @throws Exception
  */
 public HttpResult doDelete(String url, Map<String, Object> map) throws Exception {

  // 声明URIBuilder
  URIBuilder uriBuilder = new URIBuilder(url);

  // 判断参数map是否为非空
  if (map != null) {
   // 遍历参数
   for (Map.Entry<String, Object> entry : map.entrySet()) {
    // 设置参数
    uriBuilder.setParameter(entry.getKey(), entry.getValue().toString());
   }
  }

  // 2 创建httpGet对象，相当于设置url请求地址
  HttpDelete httpDelete = new HttpDelete(uriBuilder.build());

  // 3 使用HttpClient执行httpGet，相当于按回车，发起请求
  CloseableHttpResponse response = this.httpClient.execute(httpDelete);

  // 4 解析结果，封装返回对象httpResult，相当于显示相应的结果
  // 状态码
  // response.getStatusLine().getStatusCode();
  // 响应体，字符串，如果response.getEntity()为空，下面这个代码会报错,所以解析之前要做非空的判断
  // EntityUtils.toString(response.getEntity(), "UTF-8");
  HttpResult httpResult = null;
  // 解析数据封装HttpResult
  if (response.getEntity() != null) {
   httpResult = new HttpResult(response.getStatusLine().getStatusCode(),
     EntityUtils.toString(response.getEntity(), "UTF-8"));
  } else {
   httpResult = new HttpResult(response.getStatusLine().getStatusCode(), "");
  }

  // 返回
  return httpResult;
 }

}

三，调用接口

package cn.xxxxxx.httpclient.test;

import java.util.HashMap;
import java.util.Map;

import org.junit.Before;
import org.junit.Test;

import cn.itcast.httpclient.APIService;
import cn.itcast.httpclient.HttpResult;

public class APIServiceTest {

 private APIService apiService;

 @Before
 public void init() {
  this.apiService = new APIService();
 }

 // 查询
 @Test
 public void testQueryItemById() throws Exception {
  // http://manager.aaaaaa.com/rest/item/interface/{id}

  String url = "http://manager.aaaaaa.com/rest/item/interface/42";

  HttpResult httpResult = this.apiService.doGet(url);

  System.out.println(httpResult.getCode());
  System.out.println(httpResult.getBody());

 }

 // 新增
 @Test
 public void testSaveItem() throws Exception {
  // http://manager.aaaaaa.com/rest/item/interface/{id}

  String url = "http://manager.aaaaaa.com/rest/item/interface";

  Map<String, Object> map = new HashMap<String, Object>();
  // title=测试RESTful风格的接口&price=1000&num=1&cid=888&status=1
  map.put("title", "测试APIService调用新增接口");
  map.put("price", "1000");
  map.put("num", "1");
  map.put("cid", "666");
  map.put("status", "1");

  HttpResult httpResult = this.apiService.doPost(url, map);

  System.out.println(httpResult.getCode());
  System.out.println(httpResult.getBody());

 }

 // 修改

 @Test
 public void testUpdateItem() throws Exception {
  // http://manager.aaaaaa.com/rest/item/interface/{id}

  String url = "http://manager.aaaaaa.com/rest/item/interface";

  Map<String, Object> map = new HashMap<String, Object>();
  // title=测试RESTful风格的接口&price=1000&num=1&cid=888&status=1
  map.put("title", "测试APIService调用修改接口");
  map.put("id", "44");

  HttpResult httpResult = this.apiService.doPut(url, map);

  System.out.println(httpResult.getCode());
  System.out.println(httpResult.getBody());

 }

 // 删除
 @Test
 public void testDeleteItemById() throws Exception {
  // http://manager.aaaaaa.com/rest/item/interface/{id}

  String url = "http://manager.aaaaaa.com/rest/item/interface/44";

  HttpResult httpResult = this.apiService.doDelete(url, null);

  System.out.println(httpResult.getCode());
  System.out.println(httpResult.getBody());

 }

}

以上这篇使用HttpClient调用接口的实例讲解就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

MyBatis-Plus中公共字段的统一处理的实现
在开发中经常遇到多个实体类有共同的属性字段,这些字段属于公共字段，本文主要介绍了MyBatis-Plus中公共字段的统一处理的实现，具有一定的参考价值，感兴趣的可以了解一下
2023-08-08
Java+Selenium调用JavaScript的方法详解
这篇文章主要为大家讲解了java在利用Selenium操作浏览器网站时候，有时会需要用的JavaScript的地方，代码该如何实现呢？快跟随小编一起学习一下吧
2023-01-01
深入解析Java多态进阶学习
java的动态绑定机制非常重要。这篇文章将带大家更深入的学习一下Java的多态，文中的示例代码讲解详细，对我们学习Java有一定帮助，需要的可以参考一下
2022-07-07
SpringBoot @Configuration与@Bean注解使用介绍
这篇文章主要介绍了SpringBoot中的@Configuration与@Bean注解，在进行项目编写前，我们还需要知道一个东西，就是SpringBoot对我们的SpringMVC还做了哪些配置，包括如何扩展，如何定制，只有把这些都搞清楚了，我们在之后使用才会更加得心应手
2022-10-10
Spring 静态变量/构造函数注入失败的解决方案
我们经常会遇到一下问题：Spring对静态变量的注入为空、在构造函数中使用Spring容器中的Bean对象，得到的结果为空。不要担心，本文将为大家介绍如何解决这些问题，跟随小编来看看吧
2021-11-11
浅谈Java绝对布局
这篇文章主要介绍了Java当中的绝对布局，还举了一个简单的实例,需要的朋友可以参考下。
2017-08-08
SpringCloud Feign实现微服务之间相互请求问题
Feign是Netflix开发的声明式、模板化的HTTP客户端， Feign可以帮助我们更快捷、优雅地实现微服务之间的调用，这篇文章主要介绍了SpringCloud Feign实现微服务之间相互请求,需要的朋友可以参考下
2022-06-06
手把手带你理解java线程池之工作队列workQueue
这篇文章主要介绍了java线程池之工作队列workQueue，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-09-09
Java NIO Files类读取文件流方式小结
本文主要介绍了Java NIO Files类读取文件流方式小结，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-07-07
Java Exception异常全方面分析
异常就是不正常，比如当我们身体出现了异常我们会根据身体情况选择喝开水、吃药、看病、等异常处理方法。 java异常处理机制是我们java语言使用异常处理机制为程序提供了错误处理的能力，程序出现的错误，程序可以安全的退出，以保证程序正常的运行等
2022-03-03

使用HttpClient调用接口的实例讲解

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具