问题标签 [spring-boot-rsocket]

我正在尝试将 WebFlux 与 RSocket 一起使用，示例应用程序具有服务器和客户端应用程序。都在 WebFlux 和 RSocket 上运行，我的 rsocket 通信类型是请求流。客户端-服务器应用程序对于几个并发请求运行得非常好，但是当我用 1000qps 和 8 个线程加载测试时，请求开始挂起。在调查下面的示例代码通过负载测试。

工作样品

RSocketClientConfig.java

客户端.java

不工作

RSocketClientConfig.java

客户端.java

如何正确地将请求流映射到通量？

我想直接使用官方 rsocket .net 库在 RSocket 服务器（使用 spring boot rsocket 用 java 编写）和 C# 客户端之间进行通信：https ://github.com/rsocket/rsocket-net

不幸的是，Java 服务器无法解码有效负载并将其映射到 Java 类。Obvisouly 它确实适用于字节数组，但我如何将它映射到对象。

这是服务器配置（超过 tcp:7000）

我的服务器基本上有一个控制器，我希望将数据映射到一个 java 对象（这里是 Person）：

Person java 类是这样的：

客户端基本上是官方github例子使用tcp Socket传输到spring boot rsocket服务器

C# Person 类如下：

选项是：

也许可以使用带有杰克逊对象映射器或其他东西的 Protobuf 编码器，我还没有找到任何相关的东西

这是堆栈：

我希望你能帮帮我 ！

AB

RSocketResumableTransport 似乎不起作用。我有以下代码，我正在使用 RSocketResumableTransport 但它从不连接到服务器（spring-boot 版本 2.4.0-M1）。我正在使用 rsocket-websocket-client": "0.0.19" 版本。下面是用于连接的类：

浏览器控制台中的连续错误如下。此错误不断重复，直到超时：

如果我做错了什么，请告诉我？

我有以下场景，我的程序使用阻塞队列异步处理消息。有多个 RSocket 客户端希望接收此消息。我的设计是这样一种方式，当消息到达阻塞队列时，绑定到 Flux 的流将发出。我已尝试按如下方式实现此要求，但客户端未收到任何响应。但是，我可以看到 Stream 供应商被正确触发。

有人可以帮忙吗？

我正在尝试测试 RSocket 的重新连接功能，但是当服务器在两者之​​间关闭并重新启动时它不起作用。

第 1 步：在服务器关闭时启动客户端

第 2 步：服务器已启动。重新连接成功

第三步：关闭服务器

在上述步骤之后，RSocket 没有重新连接。下面是我的程序。有人可以帮助审查和建议这有什么问题。

12 月 15 日更新

以下代码在步骤 2 之后发送请求。断开连接后，它无法恢复流。我确信我的代码中一定遗漏了一些东西。请帮助

我有以下程序，通过它我可以检测到连接失败，即doBeforeRetry。

有人可以告诉我如何检测成功连接或重新连接。我想集成一个监控此连接的健康检查程序，但我无法捕获通知连接成功的事件。

谢谢

我有以下程序连接到在 localhost:7999 上运行的 Spring boot rsocket 服务器。我已经配置了连接器Retry.fixedDelay(Integer.MAX_VALUE, Duration.ofSeconds(5)) 如您所见，RSocketRequester 是 Mono，因此它应该保持一个连接。当连接失败并且重试开始时，我看到每次重试都是从不同的线程进行的，即如下parallel-1--- parallel-8。我可以知道这背后的原因吗？

我的程序如下：

我的 Spring boot 充当 rsocket 服务器。
spring-boot-starter-rsocket v2.5.2 和 spring-boot-starter v 2.5.2

应用程序有一个像这样的控制器 -

和rocket-js（v0.0.23）像这样连接并订阅websocket

有关配置的详细信息.......................................... ......................