SpringBoot3新特性@RSocketExchange轻松实现消息实时推送
1. 简介
本篇文章将介绍与RSocket在Spring Boot中应用的相关知识，如果你对RSocket还不了解的，可以查看下面这篇文章
SpringBoot整合RSocket实时数据通信
从Spring 6和Spring Boot 3开始，类似于其他声明式客户端（如OpenFeign和Retrofit），Spring框架支持将RSocket服务创建为一个Java接口，其中使用注解的方法用于RSocket交互。接下来我将使用@RSocketExchange来创建一个用于RSocket协议的声明式请求者客户端。
一个声明式HTTP接口是一个Java接口，它有助于减少样板代码，生成实现该接口的代理，并在框架级别执行交互。
2. 实战案例
2.1 依赖管理
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-rsocket</artifactId>
</dependency>该starter中包含所有必要的类和接口。
2.2 使用@RSocketExchange
@RSocketExchange注解用于在RSocket服务接口上声明一个方法作为RSocket端点。它接受一个value参数，该参数定义了端点路由。与用于HTTP传输的@RequestMapping类似，@RSocketExchange可以在接口级别使用，以表达一个公共路由，该路由将被所有服务方法继承。
public interface MessageService {
@RSocketExchange("message")
public Mono<String> sendMessage(Mono<String> requestObject);
}服务方法可以接受以下方法参数：
- @DestinationVariable: 添加路由变量，将模板占位符扩展到路由中。
- @Payload：可选注解，用于设置请求的输入有效载荷。
- Object，然后是 MimeType：发送输入有效载荷中的附加元数据项及其 MIME 类型。
public interface MessageService {
@RSocketExchange("message/{name}")
public Mono<String> sendMessage(@DestinationVariable("name") String name,@Payload Mono<String> content);
}Spring底层会生成一个实现 MessageService 接口的代理，并使用底层的 RSocketRequester 进行交互。
2.3 生成服务代理
众所周知，Spring Boot自动配置会为我们自动配置RSocketRequester.Builder。我们可以使用这个构建器来创建RSocketRequester。
@Component
public class RSocketComponent {
private final RSocketRequester.Builder requesterBuilder;
public RSocketComponent(RSocketRequester.Builder requesterBuilder) {
this.requesterBuilder = requesterBuilder ;
}
@PostConstruct public void 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中添加如下方法，执行服务端接口调用
public Mono<String> message(Mono<String> requestObject) {
return this.service.sendMessage(requestObject) ;
}接下来，我们就可以进行测试
2.4 测试
这里，通过Controller接口进行测试
@RestController
@RequestMapping("/messages")
public class MessageController {
private final RSocketComponent rc ;
public MessageController(RSocketComponent rc) {
this.rc = rc ;
}
@GetMapping("msg")
public String msg(String msg) {
return this.rc.message(Mono.just(msg)).block() ;
}
}服务端控制台输出
接收到消息：Hello
接收到消息：Pack测试通过；与Spring6之前版本相比较通过@RSocketExchange注解简化了我们客户端调用RSocket服务。其实，这种方式与Spring6中的@HttpExchange的使用及原理差不多。
微信公众号：Spring全家桶实战案例源码