问题标签 [rsocket-java]

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

工作样品

RSocketClientConfig.java

客户端.java

不工作

RSocketClientConfig.java

客户端.java

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

我试图通过 RSocket 实现中的 requestResponse 范式公开我所有的后端服务调用（所有返回对调用客户端的响应）。为此，我必须使用 RPC 或反射。我不想走 rsocket-RPC 的路线。反射大大降低了吞吐量。如果您对此要求有任何解决方案或建议，请告诉我。

我知道 RSocket 连接是双向的。在连接终止之前，客户端可以通过 RSocket 连接到服务器多长时间？

如果连接确实终止了，如果服务器想向客户端发送一些东西，它如何重新连接？

我有多个测试来测试不同的路由和单独的类，这些测试需要设置 RSocket 客户端然后处置客户端，下面是一个示例。

但是问题是，它们都使用相同的 RSocket 端口，并且一旦测试完成，它们都会处理 RSocket 客户端，这会影响其他测试。我怎样才能避免这种情况？

谢谢！

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

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

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

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

我怀疑我要么没有正确配置请求者，要么没有正确使用它。将不胜感激任何提示，因为该领域的文档和测试似乎很薄。

理想情况下，我希望客户端在服务器/连接失败时透明地切换到任何下一个可用服务器。现在重新连接尝试似乎只发生在下一次调用timer()方法时，这并不理想，因为客户端需要处理来自服务器的传入消息。我观察到的另一件事是，即使"/foo"是 FnF 路由也是如此，除非我block()在send()服务器从未收到呼叫之后这样做。

足够稳定的系统每天处理约 5000 个 WS 请求，并且 1%（约 50 个连接）的连接因错误而关闭，但出现下一个异常：在恢复过程中，我们在删除帧期间存在分歧。

有人遇到过这个问题吗？知道发生了什么吗？

我有简单的 Spring boot RSocket 服务

连接2个Spring服务很容易，但是我的客户端应用程序没有spring，我的客户端应该在RSocket java中

我很难理解如何向该特定通道发送（路由，如 Spring RsocketRequester）消息。

客户端代码应该是：

是否可以订阅 Spring 频道？

我们如何使用 @AuthenticationPrincipal 和 RSocket 方法 @AuthenticationPrincipal Mono 令牌

我创建了一个 RSocketSecurityConfiguration 类：

全大写控制器：

全连接控制器：

RSocket 客户端：

我为 Spring REST 做了一些非常相似的事情，它工作正常，但对于 RSocket，令牌始终为空。

类似于为 Spring Rsocket Server 使用 RSocket-Java 的 rsocket 路由元数据，但对于 RSocket Net Client，我们使用 spring boot @MessageMapping 用于端口 7000 上的 websocket 端点路由，这取决于路由返回 webfluxes。例如：

当 Spring Boot 服务器在本地运行时，要获得此通量，您可以使用rsc 客户端

java -jar rsc.jar --debug --request --route helloWorld ws://localhost:7000

或者对于流

java -jar rsc.jar --debug --stream --route myStream ws://localhost:7000

要在 C# Net 中以编程方式执行此操作，它在此处表示 RSocket Net 尚不支持请求路由，但可以使用元数据有效负载。有没有人有这样的网络？

谢谢

我们有一个基于 rsocket-rpc 的自定义 spring boot 启动器，我们使用了 FragmentationDuplexConnection。升级到 Rsocket 1.1.0 和 rsocket-rpc 0.3.0 后，代码中似乎不再存在 FragmentationDuplexConnection 了。取而代之的是什么？

我们之所以使用它是因为我们在通过负载均衡器/代理通过 websocket 使用 RSocket 时遇到问题，并且必须将 MTU 设置为 65K。