环境：Spring Boot3.2.5
本篇文章将介绍与RSocket在Spring Boot中应用的相关知识，如果你对RSocket还不了解的，可以查看下面这篇文章
SpringBoot整合RSocket实时数据通信
从Spring 6和Spring Boot 3开始，类似于其他声明式客户端（如OpenFeign和Retrofit），Spring框架支持将RSocket服务创建为一个Java接口，其中使用注解的方法用于RSocket交互。接下来我将使用@RSocketExchange来创建一个用于RSocket协议的声明式请求者客户端。
一个声明式HTTP接口是一个Java接口，它有助于减少样板代码，生成实现该接口的代理，并在框架级别执行交互。
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-rsocket</artifactId></dependency>
该starter中包含所有必要的类和接口。
@RSocketExchange注解用于在RSocket服务接口上声明一个方法作为RSocket端点。它接受一个value参数，该参数定义了端点路由。与用于HTTP传输的@RequestMapping类似，@RSocketExchange可以在接口级别使用，以表达一个公共路由，该路由将被所有服务方法继承。
publicinterface MessageService {@RSocketExchange("message")publicMono<String>sendMessage(Mono<String>requestObject);}
服务方法可以接受以下方法参数：
@DestinationVariable: 添加路由变量，将模板占位符扩展到路由中。
@Payload：可选注解，用于设置请求的输入有效载荷。
Object，然后是 MimeType：发送输入有效载荷中的附加元数据项及其 MIME 类型。
publicinterface MessageService {@RSocketExchange("message/{name}")publicMono<String>sendMessage(@DestinationVariable("name")String name,@PayloadMono<String>content);}
Spring底层会生成一个实现 MessageService 接口的代理，并使用底层的 RSocketRequester 进行交互。
众所周知，Spring Boot自动配置会为我们自动配置RSocketRequester.Builder。我们可以使用这个构建器来创建RSocketRequester。
@Componentpublicclass RSocketComponent {
private final RSocketRequester.Builder requesterBuilder;publicRSocketComponent(RSocketRequester.Builder requesterBuilder){
this.requesterBuilder=requesterBuilder;}@PostConstructpublicvoid initRSocket(){
RSocketRequester rsocketRequester=requesterBuilder.tcp("localhost",7000);}
}
接下来，我们可以使用 RSocketRequester 来初始化一个 RSocketServiceProxyFactory，最终用于为任何带有 @RSocketExchange 方法的 RSocket 服务接口创建客户端代理。
RSocketServiceProxyFactory factory=RSocketServiceProxyFactory.builder(rsocketRequester).build();MessageService messageService=factory.createClient(MessageService.class);
这里就得到了MessageService服务对象，接下来就可以进行服务调用的测试了。
针对RSocket服务端，我这里打算还是使用下面这篇文章中的服务端程序
SpringBoot整合RSocket实时数据通信
在RSocketComponent中添加如下方法，执行服务端接口调用
publicMono<String>message(Mono<String>requestObject){returnthis.service.sendMessage(requestObject);}
接下来，我们就可以进行测试
这里，通过Controller接口进行测试
@RestController@RequestMapping("/messages")publicclass MessageController {
private final RSocketComponent rc;publicMessageController(RSocketComponent rc){
this.rc=rc;}@GetMapping("msg")publicString msg(String msg){returnthis.rc.message(Mono.just(msg)).block();}
}
图片
图片
服务端控制台输出
接收到消息：Hello 接收到消息：Pack
测试通过；与Spring6之前版本相比较通过@RSocketExchange注解简化了我们客户端调用RSocket服务。其实，这种方式与Spring6中的@HttpExchange的使用及原理差不多。