ToB企服应用市场:ToB评测及商务社交产业平台

标题: WebClient HTTP 哀求问题处理模板（泛型相应、忽略 SSL 证书等） [打印本页]

---

作者: 半亩花草    时间: 2024-9-13 02:21
标题: WebClient HTTP 哀求问题处理模板（泛型相应、忽略 SSL 证书等）
一、哀求大数据

1、问题案例

（1）Server

• 该接口返回一段大小为 1MB 的字符串
  

1. @GetMapping("/testBigData")
2. public String testBigData() {
3.     int targetSize = 1024 * 1024; // 1MB
4.     StringBuilder sb = new StringBuilder(targetSize);
5.     for (int i = 0; i < targetSize; i++)   sb.append('A');
6.     String largeString = sb.toString();
7.     return largeString;
8. }

复制代码

（2）Client

1. WebClient webClient = WebClient.create();
3. Mono<String> response = webClient.get()
4.         .uri("http://127.0.0.1:9999/test/testBigData")
5.         .retrieve()
6.         .bodyToMono(String.class);
8. response.subscribe(result -> {
9.     System.out.println("请求成功，结果长度为：" + result.length());
10. }, throwable -> {
11.     throwable.printStackTrace();
12. });

复制代码

• 输出效果，因为数据量超过了设定的最大限制而报错
  

1. org.springframework.web.reactive.function.client.WebClientResponseException: 200 OK from GET http://127.0.0.1:9999/test/testBigData
2. Caused by: org.springframework.core.io.buffer.DataBufferLimitException: Exceeded limit on max bytes to buffer : 262144

复制代码

2、处理计谋

• 调解数据量的最大限制
  

1. int size = 2 * 1024 * 1024;
2. ExchangeStrategies strategies = ExchangeStrategies.builder()
3.         .codecs(codecs -> codecs.defaultCodecs().maxInMemorySize(size))
4.         .build();
6. WebClient webClient = WebClient.builder()
7.         .exchangeStrategies(strategies)
8.         .build();
10. Mono<String> response = webClient.get()
11.         .uri("http://127.0.0.1:9999/test/testBigData")
12.         .retrieve()
13.         .bodyToMono(String.class);
15. response.subscribe(result -> {
16.     System.out.println("请求成功，结果长度为：" + result.length());
17. }, throwable -> {
18.     throwable.printStackTrace();
19. });

复制代码

---

二、不使用缓冲区哀求图片

1、问题案例

（1）Server

• application.yaml
  

1. server:
2.   port: 9999
3. spring:
4.   mvc:
5.     static-path-pattern: /file/download/**
6.   web:
7.     resources:
8.       static-locations: file:D:/fileUpload/

复制代码

（2）Client

1. WebClient webClient = WebClient.create();
3. Mono<byte[]> response = webClient.get()
4.         .uri("http://127.0.0.1:9999/file/download/1.png")
5.         .accept(MediaType.IMAGE_JPEG, MediaType.IMAGE_PNG)
6.         .retrieve()
7.         .bodyToMono(byte[].class);
9. response.subscribe(result -> {
10.     System.out.println("请求成功");
11.     if (result != null) System.out.println("result length is " + result.length);
12. }, throwable -> {
13.     throwable.printStackTrace();
14. });

复制代码

• 输出效果，不使用 DataBuffer，会因为数据量超过了设定的最大限制而报错
  

1. org.springframework.web.reactive.function.client.WebClientResponseException: 200 OK from GET http://127.0.0.1:9999/file/download/1.png
2. Caused by: org.springframework.core.io.buffer.DataBufferLimitException: Exceeded limit on max bytes to buffer : 262144

复制代码

2、处理计谋

• 调解数据量的最大限制
  

1. int size = 10 * 1024 * 1024;
2. ExchangeStrategies strategies = ExchangeStrategies.builder()
3.         .codecs(codecs -> codecs.defaultCodecs().maxInMemorySize(size))
4.         .build();
6. WebClient webClient = WebClient.builder()
7.         .exchangeStrategies(strategies)
8.         .build();
10. Mono<byte[]> response = webClient.get()
11.         .uri("http://127.0.0.1:9999/file/download/1.png")
12.         .accept(MediaType.IMAGE_JPEG, MediaType.IMAGE_PNG)
13.         .retrieve()
14.         .bodyToMono(byte[].class);
16. response.subscribe(result -> {
17.     System.out.println("请求成功");
18.     if (result != null) System.out.println("result length is " + result.length);
19. }, throwable -> {
20.     throwable.printStackTrace();
21. });

复制代码

---

三、泛型相应

1、问题案例

（1）Entity

• Person.java
  

1. @Data
2. @NoArgsConstructor
3. @AllArgsConstructor
4. public class Person<T> {
5.     private String name;
6.     private int age;
7.     private T thing;
8. }

复制代码

• Computer.java
  

1. @Data
2. @NoArgsConstructor
3. @AllArgsConstructor
4. public class Computer {
5.     private String name;
6.     private Double price;
7. }

复制代码

（2）Server

1. @GetMapping("/testGeneric")
2. public Person<Computer> testGeneric() {
3.     Computer computer = new Computer("联想电脑", 8999.0);
4.     Person<Computer> person = new Person<Computer>("张三", 20, computer);
5.     return person;
6. }

复制代码

（3）Client

1. WebClient webClient = WebClient.create();
3. Mono<Person> response = webClient.get()
4.         .uri("http://127.0.0.1:9999/test/testGeneric")
5.         .retrieve()
6.         .bodyToMono(Person.class);
8. response.subscribe(person -> {
9.     System.out.println("请求成功");
10.     System.out.println(person);
11.     Computer computer = (Computer) person.getThing();
12.     System.out.println(computer);
13. }, throwable -> {
14.     System.out.println("请求失败，结果为：" + throwable.getMessage());
15. });

复制代码

• 输出效果，对于嵌套的泛型强转失败
  

1. 请求成功
2. Person(name=张三, age=20, thing={name=联想电脑, price=8999.0})
3. 请求失败，结果为：class java.util.LinkedHashMap cannot be cast to class com.zy.api.Computer (java.util.LinkedHashMap is in module java.base of loader 'bootstrap'; com.zy.api.Computer is in unnamed module of loader 'app')

复制代码

2、处理计谋

• 精确指示 bodyToMono 方法
  

1. WebClient webClient = WebClient.create();
3. Mono<Person<Computer>> response = webClient.get()
4.         .uri("http://127.0.0.1:9999/test/testGeneric")
5.         .retrieve()
6.         .bodyToMono(new ParameterizedTypeReference<Person<Computer>>() {
7.         });
9. response.subscribe(person -> {
10.     System.out.println("请求成功");
11.     System.out.println(person);
12.     Computer computer = person.getThing();
13.     System.out.println(computer);
14. }, throwable -> {
15.     System.out.println("请求失败，结果为：" + throwable.getMessage());
16. });

复制代码

---

四、跟随重定向相应

1、问题案例

（1）Server

1. server:
2.   port: 9999
3. spring:
4.   mvc:
5.     static-path-pattern: /file/download/**
6.   web:
7.     resources:
8.       static-locations: file:D:/fileUpload/

复制代码

1. @GetMapping("/testRedirect2Image")
2. public ResponseEntity testRedirect2Image() {
3.     return ResponseEntity.status(HttpStatus.SEE_OTHER)
4.             .header("Location", "http://127.0.0.1:9999/file/download/1.png")
5.             .build();
6. }

复制代码

（2）Client

1. WebClient webClient = WebClient.create();
3. webClient.get()
4.         .uri("http://127.0.0.1:9999/test/testRedirect2Image")
5.         .accept(MediaType.IMAGE_JPEG, MediaType.IMAGE_PNG) // 指定了客户端期望接受的响应内容类型
6.         .retrieve() // 获取响应
7.         .bodyToFlux(DataBuffer.class) // 将响应体转换为 Flux<DataBuffer>
8.         .reduce(new org.apache.tomcat.util.http.fileupload.ByteArrayOutputStream(), (baos, dataBuffer) -> {
9.             try {
10.                 byte[] bytes = new byte[dataBuffer.readableByteCount()];
11.                 dataBuffer.read(bytes);
12.                 baos.write(bytes);
13.                 DataBufferUtils.release(dataBuffer);
14.             } catch (IOException e) {
15.                 e.printStackTrace();
16.                 DataBufferUtils.release(dataBuffer);
17.                 return null;
18.             }
19.             return baos;
20.         })
21.         .map(byteArrayOutputStream -> {
22.             if (byteArrayOutputStream == null) return null;
23.             return byteArrayOutputStream.toByteArray();
24.         })
25.         .subscribe(result -> {
26.             if (result == null) {
27.                 System.out.println("result is null");
28.                 return;
29.             }
30.             System.out.println("result length: " + result.length);
31.         }, throwable -> {
32.             throwable.printStackTrace();
33.         });

复制代码

• 输出效果，默认不会跟随重定向相应
  

1. result length: 0

复制代码

2、处理计谋

• 收到开启跟随重定向相应
  

1. HttpClient httpClient = HttpClient.create()
2.         .followRedirect(true); // 允许跟随重定向
4. WebClient webClient = WebClient.builder()
5.         .clientConnector(new ReactorClientHttpConnector(httpClient))
6.         .build();
8. webClient.get()
9.         .uri("http://127.0.0.1:9999/test/testRedirect2Image")
10.         .accept(MediaType.IMAGE_JPEG, MediaType.IMAGE_PNG) // 指定了客户端期望接受的响应内容类型
11.         .retrieve() // 获取响应
12.         .bodyToFlux(DataBuffer.class) // 将响应体转换为 Flux<DataBuffer>
13.         .reduce(new org.apache.tomcat.util.http.fileupload.ByteArrayOutputStream(), (baos, dataBuffer) -> {
14.             try {
15.                 byte[] bytes = new byte[dataBuffer.readableByteCount()];
16.                 dataBuffer.read(bytes);
17.                 baos.write(bytes);
18.                 DataBufferUtils.release(dataBuffer);
19.             } catch (IOException e) {
20.                 e.printStackTrace();
21.                 DataBufferUtils.release(dataBuffer);
22.                 return null;
23.             }
24.             return baos;
25.         })
26.         .map(byteArrayOutputStream -> {
27.             if (byteArrayOutputStream == null) return null;
28.             return byteArrayOutputStream.toByteArray();
29.         })
30.         .subscribe(result -> {
31.             if (result == null) {
32.                 System.out.println("result is null");
33.                 return;
34.             }
35.             System.out.println("result length: " + result.length);
36.         }, throwable -> {
37.             throwable.printStackTrace();
38.         });

复制代码

---

五、SSL 证书

1、问题案例

1. WebClient webClient = WebClient.create();
3. Mono<byte[]> response = webClient.get()
4.         .uri(url)
5.         .accept(MediaType.IMAGE_JPEG, MediaType.IMAGE_PNG)
6.         .retrieve()
7.         .bodyToFlux(DataBuffer.class)
8.         .reduce(new ByteArrayOutputStream(), (baos, dataBuffer) -> {
9.             try {
10.                 byte[] bytes = new byte[dataBuffer.readableByteCount()];
11.                 dataBuffer.read(bytes);
12.                 baos.write(bytes);
13.                 DataBufferUtils.release(dataBuffer);
14.             } catch (IOException e) {
15.                 e.printStackTrace();
16.                 DataBufferUtils.release(dataBuffer);
17.                 return null;
18.             }
19.             return baos;
20.         })
21.         .map(byteArrayOutputStream -> {
22.             if (byteArrayOutputStream == null) return null;
23.             return byteArrayOutputStream.toByteArray();
24.         });
26. response.subscribe(result -> {
27.     System.out.println("请求成功");
28.     if (result != null) System.out.println("result length is " + result.length);
29. }, throwable -> {
30.     throwable.printStackTrace();
31. });

复制代码

• 输出效果
  

1. org.springframework.web.reactive.function.client.WebClientRequestException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target

复制代码

2、忽略 SSL 证书

1. SslContext context = SslContextBuilder.forClient().trustManager(InsecureTrustManagerFactory.INSTANCE).build();
3. HttpClient httpClient = HttpClient.create().secure(t -> t.sslContext(context));
5. WebClient webClient = WebClient.builder()
6.         .clientConnector(new ReactorClientHttpConnector(httpClient))
7.         .build();
9. Mono<byte[]> response = webClient.get()
10.         .uri(url)
11.         .accept(MediaType.IMAGE_JPEG, MediaType.IMAGE_PNG)
12.         .retrieve()
13.         .bodyToFlux(DataBuffer.class)
14.         .reduce(new ByteArrayOutputStream(), (baos, dataBuffer) -> {
15.             try {
16.                 byte[] bytes = new byte[dataBuffer.readableByteCount()];
17.                 dataBuffer.read(bytes);
18.                 baos.write(bytes);
19.                 DataBufferUtils.release(dataBuffer);
20.             } catch (IOException e) {
21.                 e.printStackTrace();
22.                 DataBufferUtils.release(dataBuffer);
23.                 return null;
24.             }
25.             return baos;
26.         })
27.         .map(byteArrayOutputStream -> {
28.             if (byteArrayOutputStream == null) return null;
29.             return byteArrayOutputStream.toByteArray();
30.         });
32. response.subscribe(result -> {
33.     System.out.println("请求成功");
34.     if (result != null) System.out.println("result length is " + result.length);
35. }, throwable -> {
36.     throwable.printStackTrace();
37. });

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

---

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)

Powered by Discuz! X3.4