HttpClient远程调用基本使用(详解)

本文涉及的产品
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
云解析 DNS,旗舰版 1个月
全局流量管理 GTM,标准版 1个月
简介: HttpClient远程调用基本使用(详解)

通过HttpClient实现远程调用

如果在不同的服务要实现服务与服务之间的调用,有众多选择,如HttpclientOkhttp

HttpURLConnectionRestTemplate这几种,当然还有那些封装好的框架,如feign等。这里主要讲解一下这个HttpClient的使用。

1,通过get方式实现

public static String get(String url,String tokenName,String tokenValue,Map<String,String> map) {
  //构建客户端对象
  CloseableHttpClient httpClient = HttpClientBuilder.create().build();
  //设置参数
  if (CollectionUtils.isNotEmpty(map)) {
    //添加参数
    String paramData = addParamByGet(map);
    //拼接参数
    url = url + "?" + paramData ;
  }
  //String url = ""http://127.0.0.1:8080/user"
  HttpGet httpGet = new HttpGet(url);
  //响应体
  CloseableHttpResponse response;
  try {
    //添加请求头,添加token
    //httpGet.addHeader("token", "eyJ0eXAiOiJKc29uV2ViVG9rZW4iLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOi");
    httpGet.addHeader(tokenName, tokenValue);
    //添加请求配置,设置响应时间等
    RequestConfig requestConfig = RequestConfig.custom()
      .setSocketTimeout(2000) //服务器响应超时时间
      .setConnectionRequestTimeout(2000) //连接服务器超时时间
      .build();
    //将配置信息添加到 httpGet 中
    httpGet.setConfig(requestConfig);
    //调用接口,获取响应
    response = httpClient.execute(httpGet);
    //将响应转化为一个结果集
    HttpEntity entity = response.getEntity();
    //将内容转化为字符串,并且设定指定字符集
    String result= EntityUtils.toString(entity, "UTF-8");
    //最终将结果集返回
    return result;
  } catch (IOException e) {
    e.printStackTrace();
  } finally {
    //资源释放
    if (httpGet != null) {
      try {
        httpGet.clone();
      } catch (CloneNotSupportedException e) {
        e.printStackTrace();
      }
    }
    if (httpClient != null) {
      try {
        httpClient.close();
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
  }
}

get请求添加参数

    /**
     * get添加参数
     */
    public static StringBuilder addParamByGet(Map<String,String> map){
        StringBuilder param = new StringBuilder();
        //遍历参数
        for (Map.Entry<String, String> m :map.entrySet()) {
            param.append(m.getKey()).append("=").append(m.getValue()).append("&");
        }
        return param;
    }

2,通过post的方式实现

里面有一些token,参数之类的,如果不用,直接将代码注释即可

public static String post(String url, String tokenName,String tokenValue, Map<String,String> map) throws IOException {
  //构建客户端对象
  CloseableHttpClient httpClient = HttpClientBuilder.create().build();
  CloseableHttpResponse response = null;
  try {
    //创建http post请求对象 这个url可以手动封装一个
    HttpPost post = new HttpPost("http://127.0.0.1:8080/user/addUser");
    //设置请求头
    //post.setHeader("token", "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJ1c2VyIiwidXN" +
    //  "lckluZm8iOnsidXNlcklkIjoxNTg5ODIxMzMwNTY1NjQ0Mjg5fSwiZXhwIjoxNjY4MDU5MzQ3LCJpYXQiOjE2N" +
    //  "jc5NzI5NDd9.mcmgzc0yEyTyfeo-2D5vpaYhdyD9LFBwCwP8s30r0Hs");
    post.addHeader(tokenName, tokenValue);
    //设置文本类型
    post.setHeader("Content-Type", "application/json");
        //如果只有一两个参数的话,也可以通过这个反转义字符手动传参变成json格式,反正最终是要转成json的形式的
    //post.setEntity(new StringEntity("{\"type\":\"1\"}", "UTF-8"));
    //构建参数
        if (CollectionUtils.isNotEmpty(map)){
            JSONObject jo = new JSONObject();
            //增加参数
            addParam(map,jo);
      post.setEntity(new StringEntity(jo.toString(), ContentType.APPLICATION_JSON));
        }else {
          post.setEntity(new StringEntity(null, ContentType.APPLICATION_JSON));
        }
        //创建响应对象
    response = httpClient.execute(post);
    /**
     * 由于响应接口返回的是一个字符串,因此需要转换
     * 响应体数据封装在HttpEntity对象中
     */
    String result = EntityUtils.toString(response.getEntity(), "utf-8");
    return result;
  } catch (Exception e) {
    e.printStackTrace();
  } finally {
    //关闭资源
    response.close();
    httpClient.close();
  }
}

post请求添加参数

/**
 * post添加参数
 */
public static JSONObject addParam(Map < String, String > map, JSONObject jsonObject) {
  for (Map.Entry < String, String > entry: map.entrySet()) {
    jsonObject.put(entry.getKey(), entry.getValue());
  }
  return jsonObject;
}

3,解析返回数据

上面两种方式都是返回一个json格式的字符串,因此可以将这个字符串解析,或者直接在方法里面解析,我这里选择在外面解析

public static vois mian(String Args[]) {
  //调用get请求,可以将里面的url,token等作为参数传入
  String url = "localhost:8080/user/message";
  String tokenName = "token";
  String tokenValue = "xxx";
  String message = get(url,tokenName,tokenValue,null);
  //如果里面有多条数据,那么可以用数组方式解析,即使一条数据,也是可以通过这个解析的
  JSONArray jsonArray = JSONArray.parseArray(message);
  //遍历
    List<User> list = new ArrayList<>();
  jsonArray.stream().forEach(json - > {
    JSONObject jsonObject = JSONArray.parseObject(json.toString());
        User user = JSON.toJavaObject(jsonObject, User.class);
        list.add(user);
  });
    //遍历全部的用户
    list.stream.forEach(e->{System.out.println(e)});
}


相关文章
|
Apache
HttpClient实现RPC调用
HttpClient实现RPC调用
54 0
|
设计模式 负载均衡 Nacos
远程调用 OpenFeign 底层原理解析
Feign 是Springcloud 提供一个声明式的伪Http客户端 它使得调用远程服务就像调用本地服务一样简单 只需要创建一个接口 并且添加注解就可以 Nacos 很好的兼容Feign Feign 默认集成了Ribbon 所以在Nacos 下使用Fegin 默认就实现了负载均衡的效果
1750 0
远程调用 OpenFeign 底层原理解析
|
5月前
|
Java Spring
spring restTemplate 进行http请求的工具类封装
spring restTemplate 进行http请求的工具类封装
225 3
|
7月前
|
Java Apache
远程调用工具HttpClient工具类封装
java远程调用工具HttpClient工具类类封装
|
7月前
封装httpclient工具类
httpclient远程调用工具封装使用
|
网络协议 Dubbo Java
【远程调用框架概述 一】基于HTTP和RPC的远程调用方式
【远程调用框架概述 一】基于HTTP和RPC的远程调用方式
404 0
|
存储 网络协议 Dubbo
服务远程调用指南(RestTemplate、HttpClient)
服务远程调用指南(RestTemplate、HttpClient)
1243 0
|
存储 资源调度 SpringCloudAlibaba
Openfeign客户端与feign客户端区别|学习笔记
快速学习Openfeign客户端与feign客户端区别
Java HttpClient 如何使用代理IP请求接口
Java HttpClient 如何使用代理IP请求接口