问题标签 [rsocket]

我尝试按照 spring-flights 示例进行操作，但我不断收到 RSocket 错误 0x201 (APPLICATION_ERROR): No handler for destination。

元数据.js

但是如果没有自定义元数据，它可以很好地工作。

我需要有关自定义元数据的帮助，以便我可以使用不记名身份验证

我的目标是为客户端订阅服务器事件 SSE。客户端将使用 WebSocket 协议，因此我使用：spring.rsocket.server.transport: websocket

阻塞 IO 栈的模拟：

用法：

客户端代码：

simpMessagingTemplate将事件推送到连接的客户端。

我想用反应器实现同样的效果，spring-boot-starter-rsocket 它也可以在客户端-服务器级别与 WebSocket 一起使用。

Rsocketrequest-stream适合，但在这种情况下，我需要服务器上的永恒通量流，因为我不知道事件何时会到来。我不知道该怎么做

假设我有这个用于聊天消息的简单 Websocket 处理程序：

一般来说，这里需要做什么，因为它将使用rsocket协议？

我正在查看文档https://github.com/rsocket/rsocket-js/blob/master/docs/01-client-configuration.md

但是我发现缺少一些东西，你实际上在哪里得到rsocket-core并且rsocket-websocket-client没有启动节点 js？我的意思是rsocket-websocket-client在纯浏览器中使用？

通过环顾四周（例如SpringBoot 如何在应用程序服务器上工作），很容易在应用程序服务器上移动 springboot rest 应用程序（因此使用 spring-boot-starter-web），因为我认为最终它们都有一个 tomcat引擎盖下的服务器。

但是我能做些什么来部署一个使用 netty 容器的 spring-boot-starter-webflux 或者更好的 spring-boot-starter-rsocket 呢？是不是不可能，或者有什么方法可以让它发挥作用？

我们知道响应式编程（以及 spring-webflux）的优势在于只有一个线程用于处理多个客户端请求。

我想通过 websockets 而不是 sse 事件来使用响应式编程，所以我发现 spring-boot-rsocket 可能是我正在寻找的。

它可以工作，但现在我想知道幕后发生了什么：如果更多客户端连接到我的 websocket 服务器只是一个处理订阅的线程？还是我回退到多个线程？

我的用例是新闻提要，客户端保持连接打开并耐心等待他们订阅的新闻。因此，每个客户端拥有一个线程是一种资源浪费和降低我的应用程序的风险。

事实上，假设在我的生产系统上，我知道我可以承受最大数量的 x 线程，为了解释起见，假设为 200。如果每个订阅请求都在一个线程中，并且我同时连接了 200 个客户端，这意味着将达到线程饱和！

我希望能够拦截客户端向我的端点发出的第一个请求，以便能够以 101（已建立 websocket）回答或拒绝它。

有没有我可以使用的拦截器？我尝试注册一个过滤器 bean，但它似乎只是被跳过了，我想是因为我在一个 webflux 应用程序中......

和

我想利用 servlet 和过滤器，所以我想使用 tomcat，一般来说，使用 servlet 3.1 来处理通信。

我尝试执行以下操作：

它可以启动一个tomcat，但我失去了端点！这是我注册它的方法：

和：

我正在尝试获取连接到 RSocket+SpringBoot 网络服务器的浏览器的远程 IP。连接是基于 WebSocket 的 RSocket。

网络服务器是 Java-8，SpringBoot-2，使用 RSocket over WebSocket 并将 RequestStreams 发送到浏览器。我将 SpringBoot 自动配置用于 RSocket 设置，因此服务器端的代码非常少 - 见下文。

@Headers and MessageHeader在下面的代码中只是为了看看他们是否有任何可能导致远程 IP 的东西，没有其他原因他们在那里。

我在网上搜索了一个答案 - http 很多，websockets 有一些， RSocket为零。这 - https://github.com/rsocket/rsocket-java/issues/735 - 看起来很有希望，但无法处理 DuplexConnection，所以那里没有雪茄。

有任何想法吗 ？谢谢 ！

应用程序.yml：

测试控制器.java

我有一个数据源服务，它以观察者为参数。

我想使用通量作为 RSocket 的响应流。我怎样才能做到这一点？正如我现在所看到的，它应该类似于

但是我很怀疑这是一个合适的解决方案，而且我是反应式方法的新手，我不知道我应该在这里使用什么方法？