文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

Spring Boot3新特性@RSocketExchange轻松实现消息实时推送

2024-11-29 18:19

关注

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 依赖管理


  org.springframework.boot
  spring-boot-starter-rsocket

该starter中包含所有必要的类和接口。

2.2 使用@RSocketExchange

@RSocketExchange注解用于在RSocket服务接口上声明一个方法作为RSocket端点。它接受一个value参数,该参数定义了端点路由。与用于HTTP传输的@RequestMapping类似,@RSocketExchange可以在接口级别使用,以表达一个公共路由,该路由将被所有服务方法继承。

public interface MessageService {
  
  @RSocketExchange("message")
  public Mono sendMessage(Mono requestObject);
}

服务方法可以接受以下方法参数:

public interface MessageService {


  @RSocketExchange("message/{name}")
  public Mono sendMessage(
    @DestinationVariable("name") String name, 
    @Payload Mono 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 message(Mono 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全家桶实战案例源码内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯