登录 注册

HttpClient&RestTemplate

本贴最后更新于 1743 天前，其中的信息可能已经时移世改

HttpClient

  • HttpClient 是 Apache Jakarta Common 下的子项目，用来提供高效的、最新的、功能丰富的支持 HTTP 协议的客户端编程工具包，
  • HttpClient 不是一个浏览器。它是一个客户端的 HTTP 通信实现库。HttpClient 的目标是发送和接收 HTTP 报文。HttpClient 不会去缓存内容，执行嵌入在 HTML 页面中的 javascript 代码，猜测内容类型，重新格式化请求/重定向 URI，或者其它和 HTTP 运输无关的功能。
  • 应用场景：
    • 在一个 java 服务器中，访问另一个 java 服务器，获取返回的资源

依赖坐标

<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.4</version>
</dependency>
​

springboot 整合 HttpClient 使用

  • 配置类：

      #The config for HttpClient 
  http.maxTotal=300
  http.defaultMaxPerRoute=50
  http.connectTimeout=1000
  http.connectionRequestTimeout=500
  http.socketTimeout=5000
  http.staleConnectionCheckEnabled=true
​

  • 配置类：

    list = template.getMessageConverters();
    for (HttpMessageConverter? mc : list) {
    if (mc instanceof StringHttpMessageConverter) {
    ((StringHttpMessageConverter) mc).setDefaultCharset(Charset.forName("UTF-8"));
    }
    }
    return template;
    }

      public Integer getMaxTotal() { 
      return maxTotal; 
  } 

  public void setMaxTotal(Integer maxTotal) { 
      this.maxTotal = maxTotal; 
  } 

  public Integer getDefaultMaxPerRoute() { 
      return defaultMaxPerRoute; 
  } 

  public void setDefaultMaxPerRoute(Integer defaultMaxPerRoute) { 
      this.defaultMaxPerRoute = defaultMaxPerRoute; 
  } 

  public Integer getConnectTimeout() { 
      return connectTimeout; 
  } 

  public void setConnectTimeout(Integer connectTimeout) { 
      this.connectTimeout = connectTimeout; 
  } 

  public Integer getConnectionRequestTimeout() { 
      return connectionRequestTimeout; 
  } 

  public void setConnectionRequestTimeout(Integer connectionRequestTimeout) { 
      this.connectionRequestTimeout = connectionRequestTimeout; 
  } 

  public Integer getSocketTimeout() { 
      return socketTimeout; 
  } 

  public void setSocketTimeout(Integer socketTimeout) { 
      this.socketTimeout = socketTimeout; 
  } 
​

    }
    ">

      /** 
   * HttpClient的配置类 
   * 
   */ 
  @Configuration 
  @ConfigurationProperties(prefix = "http", ignoreUnknownFields = true) 
  public class HttpClientConfig { 

      private Integer maxTotal;// 最大连接 

      private Integer defaultMaxPerRoute;// 每个host的最大连接 

      private Integer connectTimeout;// 连接超时时间 

      private Integer connectionRequestTimeout;// 请求超时时间 

      private Integer socketTimeout;// 响应超时时间 

      /** 
       * HttpClient连接池 
       * @return 
       */ 
      @Bean 
      public HttpClientConnectionManager httpClientConnectionManager() { 
          PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(); 
          connectionManager.setMaxTotal(maxTotal); 
          connectionManager.setDefaultMaxPerRoute(defaultMaxPerRoute); 
          return connectionManager; 
      } 

      /** 
       * 注册RequestConfig 
       * @return 
       */ 
      @Bean 
      public RequestConfig requestConfig() { 
          return RequestConfig.custom().setConnectTimeout(connectTimeout) 
              .setConnectionRequestTimeout(connectionRequestTimeout).setSocketTimeout(socketTimeout) 
              .build(); 
      } 

      /** 
       * 注册HttpClient 
       * @param manager 
       * @param config 
       * @return 
       */ 
      @Bean 
      public HttpClient httpClient(HttpClientConnectionManager manager, RequestConfig config) { 
          return HttpClientBuilder.create().setConnectionManager(manager).setDefaultRequestConfig(config) 
              .build(); 
      } 
     /** 
       * 使用连接池管理连接 
       * @param httpClient 
       * @return 
       */ 
      @Bean 
      public ClientHttpRequestFactory requestFactory(HttpClient httpClient) { 
          return new HttpComponentsClientHttpRequestFactory(httpClient); 
      } 
      /** 
       * 使用HttpClient来初始化一个RestTemplate 
       * @param requestFactory 
       * @return 
       */ 
      @Bean 
      public RestTemplate restTemplate(ClientHttpRequestFactory requestFactory) { 
          RestTemplate template = new RestTemplate(requestFactory); 

          List<HttpMessageConverter<?>> list = template.getMessageConverters(); 
          for (HttpMessageConverter<?> mc : list) { 
              if (mc instanceof StringHttpMessageConverter) { 
                  ((StringHttpMessageConverter) mc).setDefaultCharset(Charset.forName("UTF-8")); 
              } 
          } 
          return template; 
      } 

      public Integer getMaxTotal() { 
          return maxTotal; 
      } 

      public void setMaxTotal(Integer maxTotal) { 
          this.maxTotal = maxTotal; 
      } 

      public Integer getDefaultMaxPerRoute() { 
          return defaultMaxPerRoute; 
      } 

      public void setDefaultMaxPerRoute(Integer defaultMaxPerRoute) { 
          this.defaultMaxPerRoute = defaultMaxPerRoute; 
      } 

      public Integer getConnectTimeout() { 
          return connectTimeout; 
      } 

      public void setConnectTimeout(Integer connectTimeout) { 
          this.connectTimeout = connectTimeout; 
      } 

      public Integer getConnectionRequestTimeout() { 
          return connectionRequestTimeout; 
      } 

      public void setConnectionRequestTimeout(Integer connectionRequestTimeout) { 
          this.connectionRequestTimeout = connectionRequestTimeout; 
      } 

      public Integer getSocketTimeout() { 
          return socketTimeout; 
      } 

      public void setSocketTimeout(Integer socketTimeout) { 
          this.socketTimeout = socketTimeout; 
      } 
  }
​

总结

  • 总结：HttpClient 使用起来 太过繁琐。 一般使用 RestTemplate，更多简洁方便调用。
  • HttpComponents 的作用是模拟浏览器获取网页内容。 就是 HttpClient

RestTemplate

  • 传统情况下在 java 代码里访问 restful 服务，一般使用 Apache 的 HttpClient。不过此种方法使用起来太过繁琐。spring 提供了一种简单便捷的模板类来进行操作，这就是 RestTemplate。

依赖

  • RestTemplate 就是 spring 其下的产品，就在封装在 spring 的依赖中

配置类

@Configuration
public class RestTempConfig {
    /**
     * @return 返回一个RestTemplate对象，注册到spring容器中。
     */
    @Bean
    public RestTemplate getRestTemplate(){
        // 使用HttpClient，支持GZIP
    	RestTemplate restTemplate = new RestTemplate(new HttpComponentsClientHttpRequestFactory());
        //解决RestTemplate的中文乱码问题
        // 设置中文乱码问题方式一
        restTemplate.getMessageConverters().add(1,new StringHttpMessageConverter(Charset.forName("UTF-8")));
        // 设置中文乱码问题方式二
        //restTemplate.getMessageConverters().set(1,
        //new StringHttpMessageConverter(StandardCharsets.UTF_8)); // 支持中文编码
        return restTemplate;
    }
}
​

调用方法：

  • 可以调用 RestTemplate 的 get ，post 等..各种请求

  • 代码：

    post(@RequestBody Goods goods){
    ResponseEntitystring response = restTemplate.postForEntity("http://localhost:8090/goods", goods , String.class);
    System.out.println("状态码："+response.getStatusCode());
    System.out.println("返回信息："+response.getBody());
    System.out.println("Headers："+response.getHeaders());
    return response;
    }

    @PutMapping
    public ResponseEntitystring put(@RequestBody Goods goods){
    restTemplate.put("http://localhost:8090/goods", goods , String.class);
    return null;
    }

    @DeleteMapping("/{id}")
    public ResponseEntitystring delete(@PathVariable Integer id){
    restTemplate.delete("http://localhost:8090/goods/"+id);
    return ResponseEntity.ok("删除成功");
    }
    ">

      @Autowired
  private RestTemplate restTemplate;

  @GetMapping
  public ResponseEntity<String> get(){
      ResponseEntity<String> response = restTemplate.getForEntity("http://localhost:8090/goods?pageNum=1&pageSize=2&name=&key=", String.class);
      System.out.println("状态码："+response.getStatusCode());
      System.out.println("返回信息："+response.getBody());
      System.out.println("Headers："+response.getHeaders());
      return response;
  }

  @PostMapping
  public ResponseEntity<String> post(@RequestBody Goods goods){
      ResponseEntity<String> response = restTemplate.postForEntity("http://localhost:8090/goods", goods , String.class);
      System.out.println("状态码："+response.getStatusCode());
      System.out.println("返回信息："+response.getBody());
      System.out.println("Headers："+response.getHeaders());
      return response;
  }

  @PutMapping
  public ResponseEntity<String> put(@RequestBody Goods goods){
      restTemplate.put("http://localhost:8090/goods", goods , String.class);
      return null;
  }

  @DeleteMapping("/{id}")
  public ResponseEntity<String> delete(@PathVariable Integer id){
      restTemplate.delete("http://localhost:8090/goods/"+id);
      return ResponseEntity.ok("删除成功");
  }
​

两者总结

  • 相同点：
    • 跨操作系统和编程语言的的访问技术
    • 访问另一个服务器请求的技术
  • 不同的：
    • httpClient 是 Apache 的，RestTemplate 是 spring 的
    • RestTemplate 更加简单

RestTemplate 获取天气预报

ResponseEntity<String> response = restTemplate.getForEntity("http://wthrcdn.etouch.cn/weather_mini?city=沭阳", String.class);
System.out.println("状态码："+response.getStatusCode());
System.out.println("返回信息："+response.getBody());
System.out.println("Headers："+response.getHeaders());
​
  • 微服务

    微服务架构是一种架构模式，它提倡将单一应用划分成一组小的服务。服务之间互相协调，互相配合，为用户提供最终价值。每个服务运行在独立的进程中。服务于服务之间才用轻量级的通信机制互相沟通。每个服务都围绕着具体业务构建，能够被独立的部署。

    96 引用 • 155 回帖
  • Java

    Java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言，是由 Sun Microsystems 公司于 1995 年 5 月推出的。Java 技术具有卓越的通用性、高效性、平台移植性和安全性。

    3195 引用 • 8215 回帖 • 2 关注
  • Spring

    Spring 是一个开源框架，是于 2003 年兴起的一个轻量级的 Java 开发框架，由 Rod Johnson 在其著作《Expert One-On-One J2EE Development and Design》中阐述的部分理念和原型衍生而来。它是为了解决企业应用开发的复杂性而创建的。框架的主要优势之一就是其分层架构，分层架构允许使用者选择使用哪一个组件，同时为 JavaEE 应用程序开发提供集成的框架。

    946 引用 • 1460 回帖
北京 位置
1 关注
5 回帖
1.3k 61 339 154 189 35 3 22 502

相关帖子

5 回帖
HttpClient&RestTemplate

欢迎来到这里！

我们正在构建一个小众社区，大家在这里相互信任，以平等 • 自由 • 奔放的价值观进行分享交流。最终，希望大家能够找到与自己志同道合的伙伴，共同成长。

注册 关于
请输入回帖内容 ...
Weixl
北京
回帖
2
 帖子
7
 积分
704