springboot整合httpClient代码实例

 更新时间:2019年12月17日 11:18:48   作者:专注菜鸟  
这篇文章主要介绍了springboot整合httpClient代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

这篇文章主要介绍了springboot整合httpClient代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

创建httpClientConfig配置类

@Configuration
@PropertySource(value="classpath:/properties/httpClient.properties")
public class HttpClientConfig {
  @Value("${http.maxTotal}")
  private Integer maxTotal;            //最大连接数

  @Value("${http.defaultMaxPerRoute}")
  private Integer defaultMaxPerRoute;        //最大并发链接数

  @Value("${http.connectTimeout}")
  private Integer connectTimeout;          //创建链接的最大时间

  @Value("${http.connectionRequestTimeout}") 
  private Integer connectionRequestTimeout;    //链接获取超时时间

  @Value("${http.socketTimeout}")
  private Integer socketTimeout;           //数据传输最长时间

  @Value("${http.staleConnectionCheckEnabled}")
  private boolean staleConnectionCheckEnabled;   //提交时检查链接是否可用

  //定义httpClient链接池
  @Bean(name="httpClientConnectionManager")
  public PoolingHttpClientConnectionManager getPoolingHttpClientConnectionManager() {
    PoolingHttpClientConnectionManager manager = new PoolingHttpClientConnectionManager();
    manager.setMaxTotal(maxTotal); //设定最大链接数
    manager.setDefaultMaxPerRoute(defaultMaxPerRoute); //设定并发链接数
    return manager;
  }

  //定义HttpClient
  /**
   * 实例化连接池,设置连接池管理器。
   * 这里需要以参数形式注入上面实例化的连接池管理器
   @Qualifier 指定bean标签进行注入
   */
  @Bean(name = "httpClientBuilder")
  public HttpClientBuilder getHttpClientBuilder(@Qualifier("httpClientConnectionManager")PoolingHttpClientConnectionManager httpClientConnectionManager){

    //HttpClientBuilder中的构造方法被protected修饰,所以这里不能直接使用new来实例化一个HttpClientBuilder,可以使用HttpClientBuilder提供的静态方法create()来获取HttpClientBuilder对象
    HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
    httpClientBuilder.setConnectionManager(httpClientConnectionManager);
    return httpClientBuilder;
  }

  /**
   *   注入连接池,用于获取httpClient
   * @param httpClientBuilder
   * @return
   */
  @Bean
  public CloseableHttpClient getCloseableHttpClient(@Qualifier("httpClientBuilder") HttpClientBuilder httpClientBuilder){

    return httpClientBuilder.build();
  }

  /**
   * Builder是RequestConfig的一个内部类
   * 通过RequestConfig的custom方法来获取到一个Builder对象
   * 设置builder的连接信息
   * @return
   */
  @Bean(name = "builder")
  public RequestConfig.Builder getBuilder(){
    RequestConfig.Builder builder = RequestConfig.custom();
    return builder.setConnectTimeout(connectTimeout)
        .setConnectionRequestTimeout(connectionRequestTimeout)
        .setSocketTimeout(socketTimeout)
        .setStaleConnectionCheckEnabled(staleConnectionCheckEnabled);
  }

  /**
   * 使用builder构建一个RequestConfig对象
   * @param builder
   * @return
   */
  @Bean
  public RequestConfig getRequestConfig(@Qualifier("builder") RequestConfig.Builder builder){
    return builder.build();
  }
}

创建HttpClientClose关闭配置类

@Component  //交给spring容器管理
public class HttpClientClose extends Thread{
  @Autowired
  private PoolingHttpClientConnectionManager manage;
  private volatile boolean shutdown;  //开关 volatitle表示多线程可变数据,一个线程修改,其他线程立即修改
  
  public HttpClientClose() {
    ///System.out.println("执行构造方法,实例化对象");
    //线程开启启动
    this.start();
  }
  
  
  @Override
  public void run() {
    try {
      //如果服务没有关闭,执行线程
      while(!shutdown) {
        synchronized (this) {
          wait(5000);      //等待5秒
          //System.out.println("线程开始执行,关闭超时链接");
          //关闭超时的链接
          PoolStats stats = manage.getTotalStats();
          int av = stats.getAvailable();  //获取可用的线程数量
          int pend = stats.getPending();  //获取阻塞的线程数量
          int lea = stats.getLeased();  //获取当前正在使用的链接数量
          int max = stats.getMax();
          //System.out.println("max/"+max+":  av/"+av+": pend/"+pend+":  lea/"+lea);
          manage.closeExpiredConnections();
        }
      }
    } catch (Exception e) {
      e.printStackTrace();
      throw new RuntimeException();
    }

    super.run();
  }
  //关闭清理无效连接的线程
  @PreDestroy  //容器关闭时执行该方法.
  public void shutdown() {
    shutdown = true;
    synchronized (this) {
      //System.out.println("关闭全部链接!!");
      notifyAll(); //全部从等待中唤醒.执行关闭操作;
    }
  }

编写工具类HttpClientService

@Service
public class HttpClientService {

  @Autowired
  private CloseableHttpClient httpClient;
  @Autowired
  private RequestConfig requestConfig;

  /**
   * 通过给的url地址,获取服务器数据
   * @param url 服务器地址
   * @param params 封装用户参数
   * @param charset 设定字符编码
   * @return
   */
  public String doGet(String url, Map<String,String> params,String charset) {
    if (StringUtils.isEmpty(charset)) {
      charset = "utf-8";
    }
    //判断是否有参数
    if (params != null) {
      url +="?";
      for (Map.Entry<String,String> entry: params.entrySet()) {
        String key = entry.getKey();
        String value = entry.getValue();
        url += key +"="+value+"&";
      }
      url = url.substring(0,url.length() - 1);
    }
    HttpGet httpGet = new HttpGet(url);
    httpGet.setConfig(requestConfig);
    String result = "";
    try {
      CloseableHttpResponse response = httpClient.execute(httpGet);
      if (response.getStatusLine().getStatusCode() == 200) {
        result = EntityUtils.toString(response.getEntity(),charset);
      }
    } catch (IOException e) {
      e.printStackTrace();
      throw new RuntimeException(e);
    }
    return result;
  }

  public String doGet(String url, Map<String,String> params) {
      return doGet(url,params,null);
  }
  public String doGet(String url) {
    return doGet(url,null,null);
  }

  public <T> T doGet(String url,Class<T> tClass,Map<String,String> map, String charSet){
    String result = doGet(url,map,charSet);
    return ObjectMapperUtil.toObject(result, tClass);
  }

}

测试类:

@SpringBootTest
@RunWith(SpringRunner.class)
public class HttpClientTest {

@Autowired
private HttpClientService httpClientService;
 
@Test 
public void getTest1() {
    //次url是通过nginx加hosts文件映射的,需要修改url才可以使用
    String url = "http://manage.jt.com/web/item/findItemDescById";
    Map<String,String> map = new HashMap<>();
    map.put("itemId","562379");
    String s = httpClientService.doGet(url, map);
    System.out.println(s);

  }

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • 实践讲解SpringBoot自定义初始化Bean+HashMap优化策略模式

    实践讲解SpringBoot自定义初始化Bean+HashMap优化策略模式

    本篇讲解了SpringBoot自定义初始化Bean+HashMap优化策略模式,通过实践的方式更通俗易懂,对此不了解的同学跟着小编往下看吧
    2021-09-09
  • 如何将复杂SQL转换成Java对象的实例讲解

    如何将复杂SQL转换成Java对象的实例讲解

    转换复杂SQL到Java代码,我们需要确定数据库连接方式和工具,使用JDBC的API来连接数据库、执行SQL语句,复杂SQL语句可以被拆分为多个步骤,每个步骤执行一个特定的操作,通过将SQL语句拆分为多个步骤,我们可以更好地理解复杂SQL的逻辑,并且更容易将其转换为Java代码
    2024-05-05
  • Response如何实现重定向

    Response如何实现重定向

    这篇文章主要介绍了Response如何实现重定向方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-09-09
  • Java实现接口限流方案

    Java实现接口限流方案

    这篇文章主要为大家详细介绍了Java实现接口限流方案,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-11-11
  • Java遍历Map集合的方法(最新推荐)

    Java遍历Map集合的方法(最新推荐)

    这篇文章主要介绍了Java遍历Map集合的方法,遍历map的key集合然后通过key获取value,本文给大家讲解的非常详细,需要的朋友可以参考下
    2024-05-05
  • java中生产者消费者问题和代码案例

    java中生产者消费者问题和代码案例

    大家好,本篇文章主要讲的是java中生产者消费者问题和代码案例,感兴趣的同学赶快来看一看吧,对你有帮助的话记得收藏一下
    2022-02-02
  • java中生成任意之间数的随机数详解

    java中生成任意之间数的随机数详解

    这篇文章主要介绍了java中生成任意之间数的随机数详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-09-09
  • 新手学习Java对Redis简单操作

    新手学习Java对Redis简单操作

    这篇文章主要介绍了新手学习Java对Redis简单操作,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-04-04
  • spring通过导入jar包和配置xml文件启动的步骤详解

    spring通过导入jar包和配置xml文件启动的步骤详解

    这篇文章主要介绍了spring通过导入jar包和配置xml文件启动,本文分步骤通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-08-08
  • 关于Java HashMap自动排序的简单剖析

    关于Java HashMap自动排序的简单剖析

    这篇文章主要给大家介绍了关于Java HashMap自动排序的简单剖析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-09-09

最新评论