动力节点王鹤SpringBoot3笔记——远程访问@HttpExchange[SpringBoot 3]

news/2024/11/29 6:32:17/

目录

第六章  远程访问@HttpExchange[SpringBoot 3]

6.1.1.1  准备工作： 

6.1.1.2 声明式HTTP远程服务 

6.1.1.3 Http服务接口的方法定义

6.1.1.4 组合使用注解 

6.1.1.5 Java Record

6.1.1.6  定制HTTP请求服务 

第六章  远程访问@HttpExchange[SpringBoot 3]

远程访问是开发的常用技术，一个应用能够访问其他应用的功能。Spring Boot提供了多种远程访问的技术。 基于HTTP协议的远程访问是支付最广泛的。Spring Boot3提供了新的HTTP的访问能力，通过接口简化HTTP远程访问，类似Feign功能。Spring包装了底层HTTP客户的访问细节。 

SpringBoot中定义接口提供HTTP服务。生成的代理对象实现此接口，代理对象实现HTTP的远程访问。需要理解：

  • @HttpExchange
  • WebClient 

WebClient特性： 

我们想要调用其他系统提供的 HTTP 服务，通常可以使用 Spring 提供的 RestTemplate 来访问，RestTemplate 是 Spring 3 中引入的同步阻塞式 HTTP 客户端，因此存在一定性能瓶颈。Spring 官方在 Spring 5 中引入了 WebClient 作为非阻塞式HTTP 客户端。

  • 非阻塞，异步请求
  • 它的响应式编程的基于Reactor
  • 高并发，硬件资源少。
  • 支持Java 8 lambdas 函数式编程 

什么是异步非阻塞 

理解：异步和同步，非阻塞和阻塞
上面都是针对对象不一样
异步和同步针对调度者,调用者发送请求,如果等待对方回应之后才去做其他事情,就是同步,如果发送请求之后不等着对方回应就去做其他事情就是异步
阻塞和非阻塞针对被调度者,被调度者收到请求后,做完请求任务之后才给出反馈就是阻塞,收到请求之后马上给出反馈然后去做事情,就是非阻塞 

6.1.1.1  准备工作： 

1.安装GsonFormat插件，方便json和Bean的转换

2.介绍一个免费的、24h在线的Rest Http服务，每月提供近20亿的请求，关键还是免费的、可公开访问的。 

6.1.1.2 声明式HTTP远程服务 

需求： 访问 https://jsonplaceholder.typicode.com/  提供的todos服务。 基于RESTful风格，添加新的todo，修改todo，修改todo中的title，查询某个todo。声明接口提供对象https://jsonplaceholder.typicode.com/todos 服务的访问

创建新的Spring Boot项目Lession18-HttpService, Maven构建工具，JDK19。 Spring Web, Spring Reactive Web , Lombok依赖。

step1：Maven依赖pom.xml 

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>io.projectreactor</groupId><artifactId>reactor-test</artifactId><scope>test</scope></dependency>
</dependencies>

step2:声明Todo数据类

/*** 根据https://jsonplaceholder.typicode.com/todos/1 的结构创建的*/
public class Todo {private int userId;private int id;private String title;private boolean completed;//省略 set ， get方法public boolean getCompleted() {return completed;}public void setCompleted(boolean completed) {this.completed = completed;}@Overridepublic String toString() {return "Todo{" +"userId=" + userId +", id=" + id +", title='" + title + '\'' +", completed=" + completed +'}';}
}

step3:声明服务接口

import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
//...public interface TodoService {@GetExchange("/todos/{id}")Todo getTodoById(@PathVariable Integer id);@PostExchange(value = "/todos",accept = MediaType.APPLICATION_JSON_VALUE)Todo createTodo(@RequestBody  Todo newTodo);@PutExchange("/todos/{id}")ResponseEntity<Todo> modifyTodo(@PathVariable Integer id,@RequestBody Todo todo);@PatchExchange("/todos/{id}")HttpHeaders pathRequest(@PathVariable Integer id, @RequestParam String title);@DeleteExchange("/todos/{id}")void removeTodo(@PathVariable Integer id);}

step4:创建HTTP服务代理对象

@Configuration(proxyBeanMethods = false)
public class HttpConfiguration {@Beanpublic TodoService requestService(){WebClient webClient = WebClient.builder().baseUrl("https://jsonplaceholder.typicode.com/").build();HttpServiceProxyFactory proxyFactory = HttpServiceProxyFactory.builder(WebClientAdapter.forClient(webClient)).build();return proxyFactory.createClient(TodoService.class);}
}

step5:单元测试

@SpringBootTest
class HttpApplicationTests {@Resourceprivate TodoService requestService;@Testvoid testQuery() {Todo todo = requestService.getTodoById(1);System.out.println("todo = " + todo);}@Testvoid testCreateTodo() {Todo todo = new Todo();todo.setId(1001);todo.setCompleted(true);todo.setTitle("录制视频");todo.setUserId(5001);Todo save = requestService.createTodo(todo);System.out.println(save);}@Testvoid testModifyTitle() {//org.springframework.http.HttpHeadersHttpHeaders entries = requestService.pathRequest(5, "homework");entries.forEach( (name,vals)->{System.out.println(name);vals.forEach(System.out::println);System.out.println("=========================");});}@Testvoid testModifyTodo() {Todo todo = new Todo();todo.setCompleted(true);todo.setTitle("录制视频!!!");todo.setUserId(5002);ResponseEntity<Todo> result = requestService.modifyTodo(2,todo);HttpStatusCode statusCode = result.getStatusCode();HttpHeaders headers = result.getHeaders();Todo modifyTodo = result.getBody();System.out.println("statusCode = " + statusCode);System.out.println("headers = " + headers);System.out.println("modifyTodo = " + modifyTodo);}@Testvoid testRemove() {requestService.removeTodo(2);}
}

6.1.1.3 Http服务接口的方法定义

@HttpExchange注解用于声明接口作为HTTP远程服务。在方法、类级别使用。通过注解属性以及方法的参数设置HTTP请求的细节。

快捷注解简化不同的请求方式

  • GetExchange
  • PostExchange
  • PutExchange
  • PatchExchange
  • DeleteExchange

@GetExchange就是@HttpExchange表示的GET请求方式 

@HttpExchange(method = "GET")
public @interface GetExchange {@AliasFor(annotation = HttpExchange.class)String value() default "";@AliasFor(annotation = HttpExchange.class)String url() default "";@AliasFor(annotation = HttpExchange.class)String[] accept() default {};}

作为HTTP服务接口中的方法允许使用的参数列表

参数说明
URI设置请求的url，覆盖注解的url属性
HttpMethod请求方式，覆盖注解的method属性
@RequestHeader添加到请求中header。 参数类型可以为Map<String,?>, MultiValueMap<String,?>,单个值 或者 Collection<?>
@PathVariableurl中的占位符，参数可为单个值或Map<String,?>
@RequestBody请求体，参数是对象
@RequestParam请求参数，单个值或Map<String,?>, MultiValueMap<String,?>，Collection<?>
@RequestPart发送文件时使用
@CookieValue向请求中添加cookie

 接口中方法返回值

返回值类型说明
void执行请求，无需解析应答
HttpHeaders存储response应答的header信息
对象解析应答结果，转为声明的类型对象
ResponseEntity<Void>，ResponseEntity<T>解析应答内容，得到ResponseEntity,从ResponseEntity可以获取http应答码，header，body内容。

反应式的相关的返回值包含Mono<Void>,Mono<HttpHeaders>,Mono<T>,Flux<T> Mono<Respo nseEntity<Void>>,Mono<ResponseEntity<T>>,Mono<ResponseEntity<Flux<T>>。

6.1.1.4 组合使用注解 

@HttpExchange ， @GetExchange等可以组合使用。
这次使用Albums远程服务接口，查询Albums信息

step1:创建Albums数据类 

public class Albums {private int userId;private int id;private String title;//省略 set ,get@Overridepublic String toString() {return "Albums{" +"userId=" + userId +", id=" + id +", title='" + title + '\'' +'}';}
}

step2:创建AlbumsService接口

接口声明方法，提供HTTP远程服务。在类级别应用@HttpExchange接口，在方法级别使用@HttpExchange , @GetExchange等

@HttpExchange(url = "https://jsonplaceholder.typicode.com/")
public interface AlbumsService {@GetExchange("/albums/{aid}")Albums getById(@PathVariable Integer aid);@HttpExchange(url = "/albums/{aid}",method =  "GET",
contentType = MediaType.APPLICATION_JSON_VALUE)Albums getByIdV2(@PathVariable Integer aid);}

类级别的url和方法级别的url组合在一起为最后的请求url地址。

step3:声明代理 

@Configuration(proxyBeanMethods = true)
public class HttpServiceConfiguration {@Beanpublic AlbumsService albumsService(){WebClient webClient = WebClient.create();
HttpServiceProxyFactory proxyFactory = 
HttpServiceProxyFactory.builder(WebClientAdapter.forClient(webClient))
.build();return proxyFactory.createClient(AlbumsService.class);}
}

step4:单元测试

@SpringBootTest
public class TestHttpExchange {@ResourceAlbumsService albumsService;@Testvoid getQuery() {Albums albums = albumsService.getById(1);System.out.println("albums = " + albums);}@Testvoid getQueryV2() {Albums albums = albumsService.getByIdV2(2);System.out.println("albums = " + albums);}
}

6.1.1.5 Java Record

测试Java Record作为返回类型，由框架的HTTP代理转换应该内容为Record对象

step1:创建Albums的Java Record 

public record AlbumsRecord(int userId,int id,String title) {}

step2:AlbumsService接口增加新的远程访问方法，方法返回类型为Record

@GetExchange("/albums/{aid}")
AlbumsRecord getByIdRecord(@PathVariable Integer aid);

step3:单元测试，Record接收结果

@Test
void getQueryV3() {AlbumsRecord albums = albumsService.getByIdRecord(1);System.out.println("albums = " + albums);
}

JavaRecord能够正确接收应该结果，转为AlbumsRecord对象。

6.1.1.6  定制HTTP请求服务 

设置HTTP远程的超时时间， 异常处理
在创建接口代理对象前，先设置WebClient的有关配置。

step1:设置超时，异常处理 

 @Beanpublic AlbumsService albumsService(){HttpClient httpClient = HttpClient.create().option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 30000)  //连接超时.doOnConnected(conn -> {conn.addHandlerLast(new ReadTimeoutHandler(10)); //读超时conn.addHandlerLast(new WriteTimeoutHandler(10)); //写超时});WebClient webClient = WebClient.builder().clientConnector(new ReactorClientHttpConnector(httpClient))//定制4XX,5XX的回调函数.defaultStatusHandler(HttpStatusCode::isError,clientResponse -> {System.out.println("******WebClient请求异常********");return 
Mono.error(new RuntimeException(
"请求异常"+ clientResponse.statusCode().value()));}).build();HttpServiceProxyFactory proxyFactory= HttpServiceProxyFactory.builder(
WebClientAdapter.forClient(webClient)).build();return proxyFactory.createClient(AlbumsService.class);}

step2:单元测试超时和400异常

  @Testvoid testError() {Albums albums = albumsService.getById(111);System.out.println("albums = " + albums);}

测试方法执行会触发异常代码。


http://www.ppmy.cn/news/39202.html

相关文章

汽车网络管理的意义和分类

汽车网络管理的意义和分类

网络管理的意义&#xff1a; 1. 工作状态协同&#xff1a; 在任意多ECU节点网络工作时&#xff0c;对同一网络ECU的通信状态做统一的管理&#xff0c;保证各个ECU节点可以在条件满足的时候进入低功耗模式 2. 信息交互协同&#xff1a; 可以根据NM报文状态判定特定ECU的运行状态…
阅读更多...
多线程（七）线程池

多线程（七）线程池

线程池&#xff0c;又是一个池&#xff0c;我们已经见识过很多池了&#xff1a; 数据库连接池、字符串常量池.... 那我们这个线程池又是个啥呢&#xff1f; 我们提前将线程准备好&#xff0c;需要用的时候直接取&#xff0c;不需要用的时候&#xff0c;在直接还回去。 这样…
阅读更多...
重磅发布！百分点科技正式发布数据科学基础平台DeepMatrix

重磅发布！百分点科技正式发布数据科学基础平台DeepMatrix

‍数据智能产业创新服务媒体——聚焦数智 改变商业3月30日&#xff0c;由百分点科技主办的“2023数据科学峰会”在北京金隅智造工场科技秀场成功召开。此次大会以“数据进阶”为主题&#xff0c;邀请权威专家学者以科学视角和全球视野解读数据科学、数字政府建设及数字化业务&…
阅读更多...
RouterBootUI组件库（Vue3+TS+Scss/Sass+Vite+Lerna+Rollup）

RouterBootUI组件库（Vue3+TS+Scss/Sass+Vite+Lerna+Rollup）

RouterBootUI组件库&#xff08;Vue3TSScss/SassViteLernaRollup&#xff09;RouterBootUI组件库&#xff08;Vue3TSScss/SassViteLernaRollup&#xff09;前言技术选项参考官网项目地址项目构建1. 安装Lerna2.lerna初始化文件夹3.配置lerna文件lerna.jsonpackage.json4.安装依…
阅读更多...
从零开始实现一个C++高性能服务器框架----线程模块

从零开始实现一个C++高性能服务器框架----线程模块

此项目是根据sylar框架实现&#xff0c;是从零开始重写sylar&#xff0c;也是对sylar丰富与完善 项目地址&#xff1a;https://gitee.com/lzhiqiang1999/server-framework 简介 项目介绍&#xff1a;实现了一个基于协程的服务器框架&#xff0c;支持多线程、多协程协同调度&am…
阅读更多...
界面控件DevExtreme v23.1抢先体验，增强的UI/UX自定义功能！

界面控件DevExtreme v23.1抢先体验，增强的UI/UX自定义功能！

DevExtreme拥有高性能的HTML5 / JavaScript小部件集合&#xff0c;使您可以利用现代Web开发堆栈&#xff08;包括React&#xff0c;Angular&#xff0c;ASP.NET Core&#xff0c;jQuery&#xff0c;Knockout等&#xff09;构建交互式的Web应用程序&#xff0c;该套件附带功能齐…
阅读更多...
从Hive源码解读大数据开发为什么可以脱离SQL、Java、Scala

从Hive源码解读大数据开发为什么可以脱离SQL、Java、Scala

从Hive源码解读大数据开发为什么可以脱离SQL、Java、Scala 前言 【本文适合有一定计算机基础/半年工作经验的读者食用。立个Flg&#xff0c;愿天下不再有肤浅的SQL Boy】 谈到大数据开发&#xff0c;占据绝大多数人口的就是SQL Boy&#xff0c;不接受反驳&#xff0c;毕竟大…
阅读更多...
【go 定时调度框架】你知道几种go语言定时调度框架？

【go 定时调度框架】你知道几种go语言定时调度框架？

Go语言中有很多类似Python apscheduler 的定时调度框架&#xff0c;其中比较流行的有以下几个&#xff1a; cron: 一个基于Cron表达式的定时任务库&#xff0c;可以精确到秒级。它提供了简单易用的API来定义和管理定时任务&#xff0c;支持任务暂停、恢复、删除等操作&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023