0
0

springCloud使用apache的http类和RestTemplate以及Eureka

  1. 使用apache的：
  1. package com.csgholding.pvgpsp.eqp.util;
  3. import com.esotericsoftware.minlog.Log;
  4. import org.apache.commons.collections4.MapUtils;
  5. import org.apache.http.HttpEntity;
  6. import org.apache.http.client.config.RequestConfig;
  7. import org.apache.http.client.methods.CloseableHttpResponse;
  8. import org.apache.http.client.methods.HttpGet;
  9. import org.apache.http.client.utils.URIBuilder;
  10. import org.apache.http.impl.client.CloseableHttpClient;
  11. import org.apache.http.impl.client.HttpClients;
  12. import org.apache.http.util.EntityUtils;
  13. import org.springframework.http.HttpHeaders;
  14. import org.springframework.http.HttpStatus;
  15. import org.springframework.http.MediaType;
  16. import org.springframework.http.ResponseEntity;
  17. import org.springframework.http.client.SimpleClientHttpRequestFactory;
  18. import org.springframework.web.client.RestTemplate;
  20. import java.io.IOException;
  21. import java.net.URI;
  22. import java.net.URISyntaxException;
  23. import java.util.Map;
  25. /**
  26.  * @Classname HttpClientUtil
  27.  * @Date 2021/5/11 8:45
  28.  * @Created by jj.Zhou
  29.  */
  30. public class HttpClientUtil {
  32.     //字符集
  33.     private static final String CHARSET = "UTF-8";
  35.     private static RequestConfig defaultRequestConfig = RequestConfig
  36.             .custom()
  37.             //设置等待数据超时时间
  38.             .setSocketTimeout(300000)
  39.             //设置连接超时时间
  40.             .setConnectTimeout(300000)
  41.             //设置从连接池获取连接的等待超时时间
  42.             .setConnectionRequestTimeout(300000)
  43.             //.setStaleConnectionCheckEnabled(true)
  44.             .build();
  46.     //释放资源，httpResponse为响应流，httpClient为请求客户端
  47.     private static void release(CloseableHttpResponse httpResponse, CloseableHttpClient httpClient) throws IOException {
  48.         if (httpResponse != null) {
  49.             httpResponse.close();
  50.         }
  51.         if (httpClient != null) {
  52.             httpClient.close();
  53.         }
  54.     }
  55.     //get请求带参数、带请求头
  56.     public static String getAndJson(String urlWithParams, Map<String, String> header, Map<String, String> param) throws URISyntaxException {
  57.         // 创建uri
  58.         URIBuilder builder = new URIBuilder(urlWithParams);
  59.         if (param != null) {
  60.             for (String key : param.keySet()) {
  61.                 builder.addParameter(key, param.get(key));
  62.             }
  63.         }
  64.         URI uri = builder.build();
  65.         // 创建http GET请求
  66.         HttpGet httpGet = new HttpGet(uri);
  67.         if (!MapUtils.isEmpty(header)) {
  68.             header.forEach(httpGet::addHeader);
  69.         }
  70.         CloseableHttpClient httpClient = null;
  71.         String result;
  72.         try {
  73.             httpClient = HttpClients.createDefault();
  74.             CloseableHttpResponse response = httpClient.execute(httpGet);
  75.             HttpEntity entity = response.getEntity();
  76.             result = EntityUtils.toString(entity, CHARSET);
  77.             httpGet.releaseConnection();
  78.             release(response, httpClient);
  79.         } catch (Exception e) {
  80.             throw new RuntimeException(e.getMessage());
  81.         } finally {
  82.             if (httpClient != null) {
  83.                 try {
  84.                     httpClient.close();
  85.                 } catch (Exception e) {
  86.                     Log.error(e.getMessage());
  87.                 }
  88.             }
  89.         }
  90.         return result;
  91.     }
  93.     //get请求带参数、带请求头
  94.     public static String get(String urlWithParams, Map<String, String> header) {
  95.         HttpGet httpget = new HttpGet(urlWithParams);
  96.         if (!MapUtils.isEmpty(header)) {
  97.             header.forEach(httpget::addHeader);
  98.         }
  99.         CloseableHttpClient httpClient = null;
  100.         String result;
  101.         try {
  102.             httpClient = HttpClients.createDefault();
  103.             CloseableHttpResponse response = httpClient.execute(httpget);
  104.             HttpEntity entity = response.getEntity();
  105.             result = EntityUtils.toString(entity, CHARSET);
  106.             httpget.releaseConnection();
  107.             release(response, httpClient);
  108.         } catch (Exception e) {
  109.             throw new RuntimeException(e.getMessage());
  110.         } finally {
  111.             if (httpClient != null) {
  112.                 try {
  113.                     httpClient.close();
  114.                 } catch (Exception e) {
  115.                     Log.error(e.getMessage());
  116.                 }
  117.             }
  118.         }
  119.         return result;
  120.     }
  122.     public static String get(String urlWithParams) throws IOException {
  123.         return get(urlWithParams, null);
  124.     }
  126.     //发送post请求，带json请求体和请求头
  127.     public static ResponseEntity<String> postJson(String url, String json, Map<String, String> headersMap, Integer retryNum) {
  128.         SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
  129.         factory.setConnectTimeout(120000);
  130.         factory.setReadTimeout(120000);
  132.         RestTemplate restTemplate = new RestTemplate(factory);
  133.         HttpHeaders headers = new HttpHeaders();
  134.         headers.setContentType(MediaType.APPLICATION_JSON);
  136.         for (Map.Entry<String, String> entry : headersMap.entrySet()) {
  137.             headers.add(entry.getKey(), entry.getValue());
  138.         }
  139.         org.springframework.http.HttpEntity<String> request = new org.springframework.http.HttpEntity<>(json, headers);
  140.         ResponseEntity<String> response = null;
  141.         try {
  142.             response = restTemplate.postForEntity(url, request, String.class);
  143.             if (retryNum > 0 && !HttpStatus.OK.equals(response.getStatusCode())) {
  144.                 retryNum--;
  145.                 postJson(url, json, headersMap, retryNum);
  146.             }
  147.         } catch (Exception e) {
  148.             if (retryNum > 0) {
  149.                 retryNum--;
  150.                 postJson(url, json, headersMap, retryNum);
  151.             } else {
  152.                 throw e;
  153.             }
  154.         }
  155.         return response;
  156.     }
  157. }

get方法调用：

  1.     public String callMesEqp() {
  2.         Map<String, String> header = new HashMap<>();
  3.         ResponseEntity<String> response;
  4.         HttpStatus statusCode;
  5.         String responseBody = "";
  6.         try {
  7.             responseBody = HttpClientUtil.get("http://127.0.0.1/t1", der);
  8.         } catch (Throwable e) {
  9.         }
  10.         return responseBody;
  11.     }

post方法调用：

  1.     public String callMesStepEqp(String syncTime) {
  2.         Map<String, String> header = new HashMap<>();
  3.         ResponseEntity<String> response = null;
  4.         HttpStatus statusCode;
  5.         String responseBody = "";
  6.         MesStepEqpQuery query = new MesStepEqpQuery();
  7.         //query就是请求参数，全是字符串    
  8.         query.setTrxDate(syncTime);
  9.         String jsonString = JSON.toJSONString(query);
  10.         try {
  11.             response = HttpClientUtil.postJson("http://127.0.0.1:8080/t1, jsonString, header, 1);
  12.         } catch (Throwable e) {
  13.         }
  14.         return response.getBody();
  15.     }

使用ResTemplate:

  1.     @Autowired
  2.     RestTemplate restTemplate;
  4.     @ApiOperation(value = "通过id获取用户", notes = "通过id获取用户")
  5.     @GetMapping("getUserByIdApi")
  6.     public Result<UserVO> getUserByIdApi(@ApiParam("用户id") Integer id) {
  7. //        UserVO vo = restTemplate.getForObject("http://127.0.0.1:8081/v1/user/getUserById?id=" + id, UserVO.class);
  8.         restTemplate.getForObject("http://127.0.0.1:8081/v1/user/getUserById?id=" + id, Result.class);
  9. //        return Result.success(vo);
  10.         return (restTemplate.getForObject("http://127.0.0.1:8081/v1/user/getUserById?id=" + id, Result.class));
  11.     }

使用springCloud的Eureka:

注意我的jdk和cloud版本：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <modelVersion>4.0.0</modelVersion>
  7.     <groupId>org.cloud</groupId>
  8.     <artifactId>springCloudPuls</artifactId>
  9.     <version>1.0-SNAPSHOT</version>
  10.     <modules>
  11.         <module>cloud-common</module>
  12.         <module>cloud-user</module>
  13.         <module>cloud-auth</module>
  14.         <module>cloud-eureka</module>
  15.     </modules>
  17.     <packaging>pom</packaging>
  19.     <properties>
  21.     </properties>
  23.     <dependencyManagement>
  24.         <dependencies>
  25.             <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-dependencies -->
  26.             <dependency>
  27.                 <groupId>org.springframework.cloud</groupId>
  28.                 <artifactId>spring-cloud-dependencies</artifactId>
  29.                 <version>2022.0.3</version>
  30.                 <type>pom</type>
  31.                 <scope>import</scope>
  32.             </dependency>
  33.             <dependency>
  34.                 <groupId>org.springframework.boot</groupId>
  35.                 <artifactId>spring-boot-dependencies</artifactId>
  36.                 <version>3.1.5</version>
  37.                 <type>pom</type>
  38.                 <scope>import</scope>
  39.             </dependency>
  40.             <!--            mysql连接-->
  41.             <dependency>
  42.                 <groupId>mysql</groupId>
  43.                 <artifactId>mysql-connector-java</artifactId>
  44.                 <version>8.0.28</version>
  45.             </dependency>
  46.             <!--            连接池-->
  47.             <dependency>
  48.                 <groupId>com.alibaba</groupId>
  49.                 <artifactId>druid</artifactId>
  50.                 <version>1.2.16</version>
  51.             </dependency>
  52.             <dependency>
  53.                 <groupId>junit</groupId>
  54.                 <artifactId>junit</artifactId>
  55.                 <version>4.13.2</version>
  56.                 <scope>test</scope>
  57.             </dependency>
  58.             <dependency>
  59.                 <groupId>org.projectlombok</groupId>
  60.                 <artifactId>lombok</artifactId>
  61.                 <version>1.18.28</version>
  62.             </dependency>
  63.             <!--            log4j日志-->
  64.             <dependency>
  65.                 <groupId>log4j</groupId>
  66.                 <artifactId>log4j</artifactId>
  67.                 <version>1.2.17</version>
  68.             </dependency>
  69.             <!--            swagger-->
  70.             <dependency>
  71.                 <groupId>io.swagger</groupId>
  72.                 <artifactId>swagger-annotations</artifactId>
  73.                 <version>1.5.20</version>
  74.             </dependency>
  75.             <!--            mybatis-plus-->
  76.             <dependency>
  77.                 <groupId>com.baomidou</groupId>
  78.                 <artifactId>mybatis-plus-boot-starter</artifactId>
  79.                 <version>3.5.3.1</version>
  80.             </dependency>
  82.             <!-- https://mvnrepository.com/artifact/cn.dev33/sa-token-spring-boot3-starter -->
  83.             <dependency>
  84.                 <groupId>cn.dev33</groupId>
  85.                 <artifactId>sa-token-spring-boot3-starter</artifactId>
  86.                 <version>1.37.0</version>
  87.             </dependency>
  88.         </dependencies>
  90.     </dependencyManagement>
  91. </project>

编写Eureka服务器：

  1.         <dependency>
  2.             <groupId>org.springframework.cloud</groupId>
  3.             <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
  4.         </dependency>

yml：

  1. server:
  2.   port: 8084
  4. #eureka配置
  5. eureka:
  6.   instance:
  7.     hostname: locahost
  8.   client:
  9.     register-with-eureka: false
  10.     fetch-registry: false #is false,me is eurekaService，true is not
  11.     service-url:
  12.       defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka

springBoot启动类上加上：

@EnableEurekaServer

将服务注册进来：

  1.         <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-client -->
  2.         <dependency>
  3.             <groupId>org.springframework.cloud</groupId>
  4.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  5.             <version>4.1.0</version>
  6.         </dependency>

yml：

  1. server:
  2.   port: 8081
  3. spring:
  4.   application:
  5.     name: cloude-user-server
  6.   datasource:
  7.     driver-class-name: com.mysql.cj.jdbc.Driver
  8.     type: com.alibaba.druid.pool.DruidDataSource
  9.     url: jdbc:mysql://192.168.126.128:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
  10.     username: root
  11.     password: 123456
  12. mybatis-plus:
  13.   configuration:
  14.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
  16. #eureka配置
  17. # eureka
  18. eureka:
  19.   client:
  20.     register-with-eureka: true   #注册eureka
  21.     fetch-registry: true    # 获取注册信息
  22.     service-url:
  23.       defaultZone: http://127.0.0.1:8084/eureka  #访问地址,一定得是ip地址和端口号！！！
  24.   instance:
  25.     prefer-ip-address: true  #暴露ip
  26.     instance-id: xry   #名字
  27. management:
  28.   endpoints:
  29.     web:
  30.       exposure:
  31.         include: '*'
  32.     jmx:
  33.       exposure:
  34.         include: '*'
  35. info:
  36.   name: qx

启动类加上：

  1. @EnableDiscoveryClient

然后访问Eureka的页面，http://localhost:8084/

未完，待续

标签： spring cloud apache http
本文转载自: https://blog.csdn.net/qx020814/article/details/135586671
版权归原作者 菜汪在路上 所有， 如有侵权，请联系我们删除。
登录后发布评论

“springCloud使用apache的http类和RestTemplate以及Eureka”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？

文章导航
没有找到文章内容分段。。。