问题标签 [rsocket]

这两个映射位于服务器端。

当 RSocket 客户端使用 'message/x.rsocket.authentication.v0' 元数据建立连接时，

然后向hello映射发送请求。

第一个主体为空。

第二个主体是预期的身份验证数据。

如何解析@ConnectMapping 中的主体？

我一直在从（https://dzone.com/articles/rsocket-with-spring-boot-amp-js-zero-to-hero）运行一个示例 RSocket 项目，我试图存储每个客户端 ID 的请求者对象。

Rsocket JS客户端：

Rsocket Java 服务器：

我一直在调试模式下运行应用程序，无法触发onConnect ConnectMapping 注释方法。请帮助了解我在这里缺少什么。

我正在尝试为短暂的 Spring Cloud Data Flow 任务建立监控。由于 SCDF 的更新版本，建议使用rsocket 代理 prometheus。

根据 helm 图表，我能够部署 rsocket 代理。连接正常，代理自己的指标在 prometheus 中可用。但我仍在努力在申请期间公开自己的仪表。

我包括了所需的依赖项：

在应用程序中，我在代码中添加了一个简单的计数器：

应用程序运行没有任何问题。但是无论是在 prometheus 本身上，还是在代理的 /metrics/connected 端点上，都看不到任何指标。少了什么东西？

编辑：好的，同时我发现我的任务和 RSocket 代理之间的通信正在工作。但与文档“......将保留它们[指标]直到普罗米修斯下一次刮擦”相反，一旦我的应用程序结束，我在'metrics/connected'端点的指标就消失了。

我的服务器可以拒绝客户端的设置。这可以在客户端使用 RSocket.onClose() 检测到。
但是有没有办法检测连接是否成功打开，即服务器接受了设置有效负载？
我想要诸如 onOpened() 之类的东西，它会在服务器和客户端接受器都成功时触发。

如果我运行下面的代码，即使服务器拒绝了客户端设置，也会调用客户端的接受器，所以我不能使用它。

客户端代码：

客户端流请求示例：

服务器响应示例：

似乎一切都很顺利。我看到客户端发布有效负载，但没有任何回复。没有错误。客户端卡住并等待答复。

在 1.0.1 这个例子有效。请指教。

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

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

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

谢谢！

我想在春季检查我的服务器的gatling中创建性能测试。我使用rsocket协议（通过websocket）。我不知道如何通过此协议建立连接并发送任何数据。加特林支持吗？如果无法使用 gatling 我如何模拟与我的服务器的特定连接数。（也许不同的图书馆）

服务器代码

属性文件：

我要发送消息的示例端点：

maven依赖：

我有一个问题要问 Spring Cloud 的人。

大约。一年前，有关于 Spring Cloud RSocket 的精彩演讲。其中一部分包括 Spring Cloud Gateway 中的 RSocket 支持。rsocket 代理。

现在我看到https://github.com/spring-cloud-incubator/spring-cloud-rsocket已经存档了。

我想知道：这是否意味着 Spring Cloud RSocket 已死？有替代品吗？Spring Cloud Gateway 中是否还有其他对 RSocket 的支持？还是 Spring Cloud RSocket 只是处于休眠状态，有复活的希望？

PS：我知道 Spring Boot 中的 RSocket 支持，这在此处进行了很好的描述。我感兴趣的是我没有找到 Spring Boot RSocket 支持的 Spring Cloud RSocket 特性。

我想直接使用官方 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

我正在尝试使用带有 Spring 的 RSocket 连接到 Binance websocket 端点，但出现以下异常。

java.lang.AssertionError: expectation "consumeNextWith" failed (expected: onNext(); actual: onError(java.nio.channels.ClosedChannelException))

这是我的测试代码：

我可以使用 RSocket 直接连接到 WebSocket 端点，还是必须创建一个处理 websocket 的 RSocket 服务器，然后从这个代理服务器连接到 websocket？