对于微服务到微服务的通信，RSocket 似乎是 HTTP/S 的一个很好的替代品。幸运的是 Spring Boot 已经有一个平滑的集成，可以简化它的配置。

但是，我在 RSocket 和 Spring（引导、安全）文档中都缺少与 RSocket 安全性相关的所有信息。

我的问题是：

1) 我们如何配置 RSocket 以使用 TLS（在 Spring Boot 应用程序的上下文中）？

2) Spring Security 是否为 RSocket 安全性添加了任何附加功能？我想到的事情，假设我们想要将 JWT 令牌从一个应用程序传播到另一个应用程序，它如何通过 RSocket 传递和验证？

如何设置路由元数据（在服务器使用 Spring Boot Rsocket 时仅使用 RSocket-Java 的有效负载。

Flux<Payload> s = connection.flatMapMany(requester -> requester.requestStream(DefaultPayload.create("Some Message")))

服务器正在使用@MessageMapping("/route")

我试图了解LoadbalanceRSocketClient SpringBoot 应用程序 ( RSocketRequester)上下文中的正确配置和使用模式。

我有两个 RSocket 服务器后端（SpringBoot、RSocket 消息传递）RSocketRequester在客户端上运行和配置，如下所示：

List<LoadbalanceTarget> servers = new ArrayList<>();
for (String url: backendUrls) {
  HttpClient httpClient = HttpClient.create()
    .baseUrl(url)
    .secure(ssl -> 
       ssl.sslContext(SslContextBuilder.forClient().trustManager(InsecureTrustManagerFactory.INSTANCE)));
  servers.add(LoadbalanceTarget.from(url, WebsocketClientTransport.create(httpClient, url)));
}

// RSocketRequester.Builder is autowired by Spring boot
RSocketRequester requester = builder
  .setupRoute("/connect")
  .setupData("test")
  //.rsocketConnector(connector -> connector.reconnect(Retry.fixedDelay(60, Duration.ofSeconds(1))))
 .transports(Flux.just(servers), new RoundRobinLoadbalanceStrategy());   

配置完成后，请求者将在计时器循环中重复使用，如下所示：

@Scheduled(fixedDelay = 10000, initialDelay = 1000)
public void timer() {
  requester.route("/foo").data(Data).send().block();
}

它工作 - 客户端启动，连接到其中一台服务器并将消息推送到它。如果我终止客户端连接的服务器，客户端会在下一个计时器事件中重新连接到另一台服务器。如果我再次启动第一个服务器并杀死第二个服务器，客户端将不再连接，并且在客户端观察到以下异常：

java.util.concurrent.CancellationException: Pool is exhausted
    at io.rsocket.loadbalance.RSocketPool.select(RSocketPool.java:202) ~[rsocket-core-1.1.0.jar:na]
    at io.rsocket.loadbalance.LoadbalanceRSocketClient.lambda$fireAndForget$0(LoadbalanceRSocketClient.java:49) …

我按照 spring-rsocket-demo 项目来完成我的代码。我在服务器端代码中添加了一些身份验证逻辑，如下所示。您可以看到我在身份验证逻辑“CLIENT.add(requester)”之后抛出了一个异常。我在 spring-rsocket-demo 项目中执行名为“testRequestGetsResponse”的测试方法，发现无法收到异常。如何处理 @ConnectMapping 注释方法中的设置有效负载并在需要时返回 RejectedSetupException。

        requester.rsocket()
                .onClose()
                .doFirst(() -> {
                    // Add all new clients to a client list
                    log.info("Client: {} CONNECTED.", client);
                    //throw Exception during process setup payload
                    //my authentication code.
                    try {
//                        CLIENTS.add(requester);
                        throw new RuntimeException();
                    } catch (Exception exception) {
                        throw exception;
                    }
                })
                .doOnError(error -> {
                    // Warn when channels are closed by clients
                    log.warn("Channel to client {} CLOSED", client);
                })
                .doFinally(consumer -> {
                    // Remove disconnected clients from the client list …

我一直在浏览一些 RSocket 演示和示例来了解它们是如何工作的，但其中大多数往往都有过时的代码片段。

例如，我有这个演示，当碰巧被弃用时使用 RSocketFactory。

@Bean
RSocket rSocket () {
    return RSocketFactory
            .connect()
            .dataMimeType(MimeTypeUtils.APPLICATION_JSON_VALUE)
            .frameDecoder(PayloadDecoder.ZERO_COPY)
            .transport(TcpClientTransport.create(7000))
            .start()
            .block();
}

我通过搜索更多发现它已被替换，RSocketConnectorConfigurer但我无法找到新用法的示例代码。以前使用过 RSocket 的人是否有机会帮助使用新的配置方法？

谢谢！

我已经研究 rsocket 和响应式编程有一段时间了，经常提到 spring webflux，我想问 rsocket 和 spring webflux 之间有什么区别，或者它们是相同的东西。谢谢

我最近开始了一系列关于使用FHIR资源的服务到服务通信的性能调查，以确定在以下方面花费的处理时间：

1. 有效载荷通信/交换
2. 序列化和反序列化有效负载

在调查过程中遇到了两个我不明白的结果，因此我需要RSocket开发团队的帮助。我将详细说明结果和问题。

为了找出最快的通信方式，我分析了使用两种传输协议的三种传输方式——HTTP 和 RSocket。更准确地说 - 我已经分析和基准测试：

1. 使用HAPI REST 服务器和 HAPI FHIR 客户端交换 FHIR 资源
2. 通过@RestController使用RestTemplateWeb 客户端访问 Spring端点，使用 REST 通信交换字符串（序列化的 FHIR 资源）
3. 使用RSocket消息交换 FHIR 资源

对前两种通信方法的分析产生了使用 HAPI REST 服务器交换 FHIR 资源与交换（原始）字符串有效载荷之间的巨大差异，包括将这些有效载荷反序列化为 FHIR 资源。更准确地说 - 对于大型 FHIR 资源，HAPI REST 服务器增加的开销大约是（原始）字符串通信和反序列化所带来的开销的 3-4 倍。

关于两个服务之间的 RSocket 通信 - 我尝试使用两种模式来交换 FHIR 资源：

1. 作为原始字符串，从 FHIR 资源序列化
2. 作为原始 FHIR 资源，让 RSocket 处理序列化和反序列化

第一种方法（使用原始字符串）产生的负载交换开销几乎与 HTTP（使用 REST）通信所产生的开销相似。更准确地说 - 通信开销比 HTTP 通信高几个百分比 (5-10%)。这让我感到惊讶，因为我认为 RSocket 通信开销将远低于 HTTP …