RSocket 系列

RSocket 是一种用于字节流传输的二进制协议。它通过单个连接上的异步消息传递来实现对称交互模型。spring-doc.cn

Spring Framework 的模块在客户端和服务器端为 RSocket 请求者和响应者提供支持。有关更多详细信息，包括 RSocket 协议的概述，请参见 Spring Framework 参考的 RSocket 部分。spring-messagingspring-doc.cn

RSocket 策略自动配置

Spring Boot 自动配置了一个RSocketStrategies bean，它为编码和解码 RSocket 有效负载提供了所有必需的基础设施。默认情况下，自动配置将尝试配置以下内容（按顺序）：spring-doc.cn

使用 Jackson 的 CBOR 编解码器spring-doc.cn
使用 Jackson 的 JSON 编解码器spring-doc.cn

Starter 提供了这两个依赖项。请参阅 Jackson 支持部分以了解有关自定义可能性的更多信息。spring-boot-starter-rsocketspring-doc.cn

开发人员可以通过创建实现 RSocketStrategiesCustomizer 接口的 bean 来自定义 RSocketStrategies 组件。请注意，它们@Order很重要，因为它决定了编解码器的顺序。spring-doc.cn

RSocket 服务器自动配置

Spring Boot 提供 RSocket 服务器自动配置。所需的依赖项由 .spring-boot-starter-rsocketspring-doc.cn

Spring Boot 允许从 WebFlux 服务器通过 WebSocket 公开 RSocket，或者建立独立的 RSocket 服务器。这取决于应用程序的类型及其配置。spring-doc.cn

对于 WebFlux 应用程序（类型为 WebApplicationType.REACTIVE），仅当以下属性匹配时，RSocket 服务器才会插入 Web 服务器：spring-doc.cn

Propertiesspring-doc.cn
YAMLspring-doc.cn

spring.rsocket.server.mapping-path=/rsocket
spring.rsocket.server.transport=websocket

spring:
  rsocket:
    server:
      mapping-path: "/rsocket"
      transport: "websocket"

只有 Reactor Netty 才支持将 RSocket 插入 Web 服务器，因为 RSocket 本身就是使用该库构建的。

或者，RSocket TCP 或 websocket 服务器作为独立的嵌入式服务器启动。除了依赖项要求之外，唯一需要的配置是为该服务器定义一个端口：spring-doc.cn

Propertiesspring-doc.cn
YAMLspring-doc.cn

spring.rsocket.server.port=9898

spring:
  rsocket:
    server:
      port: 9898

Spring Messaging RSocket 支持

Spring Boot 将为 RSocket 自动配置 Spring Messaging 基础设施。spring-doc.cn

这意味着 Spring Boot 将创建一个RSocketMessageHandler bean，该 bean 将处理对应用程序的 RSocket 请求。spring-doc.cn

使用 RSocketRequester 调用 RSocket 服务

一旦在服务器和客户端之间建立了 RSocket 通道，任何一方都可以向另一方发送或接收请求。spring-doc.cn

作为服务器，您可以在 RSocket @Controller的任何处理程序方法上注入 RSocketRequester 实例。作为客户端，您需要先配置并建立 RSocket 连接。 Spring Boot 使用预期的编解码器为此类情况自动配置RSocketRequester.Builder，并应用任何RSocketConnectorConfigurer bean。spring-doc.cn

RSocketRequester.Builder 实例是一个原型 bean，这意味着每个注入点都会为您提供一个新实例。这是有意为之的，因为此构建器是有状态的，您不应使用同一实例创建具有不同设置的请求者。spring-doc.cn

以下代码显示了一个典型的示例：spring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

import reactor.core.publisher.Mono;

import org.springframework.messaging.rsocket.RSocketRequester;
import org.springframework.stereotype.Service;

@Service
public class MyService {

	private final RSocketRequester rsocketRequester;

	public MyService(RSocketRequester.Builder rsocketRequesterBuilder) {
		this.rsocketRequester = rsocketRequesterBuilder.tcp("example.org", 9898);
	}

	public Mono<User> someRSocketCall(String name) {
		return this.rsocketRequester.route("user").data(name).retrieveMono(User.class);
	}

}

import org.springframework.messaging.rsocket.RSocketRequester
import org.springframework.stereotype.Service
import reactor.core.publisher.Mono

@Service
class MyService(rsocketRequesterBuilder: RSocketRequester.Builder) {

	private val rsocketRequester: RSocketRequester

	init {
		rsocketRequester = rsocketRequesterBuilder.tcp("example.org", 9898)
	}

	fun someRSocketCall(name: String): Mono<User> {
		return rsocketRequester.route("user").data(name).retrieveMono(
			User::class.java
		)
	}

}