问题标签 [rsocket-js]

Github 上提供的示例项目：https ://github.com/codependent/rsocket-rating-service

Spring Boot RSocket 服务器消息映射需要一个 requestResponse 请求，返回一个简单的 POJO：

在客户端，我有以下 JS 代码连接到 RSocket 服务器并请求一个值：

索引.html

访问http://localhost:8080/index.html后输入一些文本并推送发送。

请求到达记录正确生成 onNext 值的服务器：

但是在客户端

永远不会被调用，浏览器日志只显示：

为什么它没有从服务器获取生成的值？

我尝试使用 Angular、Spring RSocket、Spring Data Mongo Reactive 创建客户端/服务器示例。

完整的代码，请在此处查看。

后端代码：

在前端代码中。

我尝试使用requestStream方法连接消息路由，但失败了，在rscoket-jsAPI 中，似乎我必须在那里设置一个Subscription选项并设置请求号，否则它根本没有连接。

当我运行前端应用程序时，在浏览器控制台中出现以下错误。

更新：阅读相关文档后，我自己解决了这个上限集合。默认情况下，Spring Data Mongo 不会为您创建上限集合。

现在我在客户端遇到另一个错误，有一个意外关闭错误导致RSocketWebsocketClient。

更新 2：已解决。data应该是当null服务器端不接受有效负载时。

最终的工作版本被合并到master中。

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

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

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

我有一个从 Spring Boot 后端接收通知的屏幕，我将它们显示在一个铃铛中。删除通知时，它会很好地删除它，但是当另一个新通知到达时，它会加载我已经删除的通知。

我是 rsocket-js 的新手，并尝试使用相同的 chanel 接收消息并使用 rsocket-js（客户端）使用发射器发送消息。

我有一个带有网络安全授权的 spring 应用程序。有必要使用套接字协议，我选择了 rsocket。任务是将 SITE 上的授权用户连接到 rsocket 以进行进一步的信息交换。如何将网络安全授权绑定到 rsocket？我知道他们为此使用 jwt，但我在任何地方都找不到使用示例。

我打算将RSocket用于我的通知系统。我想将Spring Boot RSocket 用于我的后端（Java），而对于我的前端，我将使用 Angular 使用 rsocket-js。

我能够快速启动一个请求流交互模型，其中我可以在我的系统中提取所有通知。请参阅我的后端的代码片段：

现在在我的前端，我有以下代码片段：

我在 UI 中有一个按钮，如果单击该按钮，将调用方法retrieveNotifications ，该方法将订阅我的后端requestStream中的 rsocket 消息映射方法。

一切正常，我可以看到我的回复。现在我的问题是，如果在我的服务器上有一个新数据插入到数据库中，例如，我如何从我的后端服务器发送通知消息到前端说“嘿！新数据已推送到数据库中。” 我有点卡在服务器如何能够以某种方式使用火灾并忘记客户端。

据我了解，RSocket-JS 支持使用encodeCompositeMetadata和路由消息encodeRoute，但是，我无法让服务器接受fireAndForget消息。服务器不断记录以下消息：

o.s.m.r.a.support.RSocketMessageHandler : No handler for fireAndForget to ''

这是我试图触发的服务器映射：

这是尝试建立连接的 TypeScript 代码：

我也尝试过以其他方式添加路由（metadata: String.fromCharCode('route'.length)+'route'），我在互联网上找到了，但似乎都没有。

我需要做什么才能以 Spring Boot 服务器识别路由并正确路由消息的方式格式化路由？

结果是：

国家的文件connectionStatus()：

返回一个 Flowable，它立即发布当前连接 * 状态，然后随着它的变化而更新。[...]

我正在尝试创建 RSocket JS 客户端侦听 Spring Boot 服务器的情况。当服务器有一些数据给客户端时，它会发送它并且客户端 onNext() 触发并开始处理/显示该数据。很简单，对吧？

我看过很多例子，包括来自官方 RSocket-JS 存储库的一个例子，提出了这种设置：

这里sub.request(2147483647)请求maxn所在的数据实例。然而，并不是无限的。当服务器发送数据实例时会发生什么？客户端会停止接受新数据吗？如果是这样，当这种情况发生时你会怎么做？你怎么知道它何时发生？另外，如果需要，你如何停止这个无限请求循环？nint32n2147483647

我想出了这个：

然而，在测试这个时我遇到了另一个问题——出于某种原因，在几个请求之后，请求循环结束了。我不确定为什么会发生这种情况，但我猜这可能是因为someDataProcessing()它可能会阻塞（例如循环数据），这反过来会导致客户端“错过”新数据。我们可以通过增加1to 来解决这个问题，例如，5但这会导致请求堆积，所以我不确定这是否是最好的解决方案。