测试挂起功能-未发现测试(有时)
在尝试测试挂起的Spring Kotlin@控制器函数时，我无法理解一个奇怪的行为： @Controller class PersonRSocketController(val personRepository: PersonRepository) { private val sharedFlow = flow { for (i in 1..1000)
..
rsocket相关内容
如何使用RSocket处理从服务器发送到客户端的消息？
我尝试使用RSocketRequester从服务器向特定客户端发送消息，但我不知道如何在前端处理它。服务器是Spring Webflow，控制器如下： data class Message(val message: String) @Controller class RSocketController { private val log = LoggerFactory.getLo
..
如何序列化通过Java RSocket发送的POJO？
我正在尝试通过RSocket请求流发送POJO： import java.io.Serializable; class GreetingRequest implements Serializable { private String name; public GreetingRequest() {} public GreetingRequest(String n
..
Javascript Rsocket 自定义元数据 - RSocket 错误 0x201(APPLICATION_ERROR):目标没有处理程序
我尝试遵循 spring-flights 示例，但我不断收到 RSocket 错误 0x201 (APPLICATION_ERROR):没有目的地处理程序. 元数据.js import {JsonSerializer} from 'rsocket-core';导出类元数据扩展地图{构造函数(json){超级()；如果(json ！= null){for (let [key, value]
..
从 Kafka 获取消息，发送到 Rsocket 并从 React 客户端接收它
我正在尝试使用 Spring 云流将数据从 kafka 发送到 Rsocket，然后在 React 上表示数据 这是我的配置. @Configuration公共类 RsocketConsumerConfiguration {@豆公共接收器.许多发件人(){返回 Sinks.many().multicast().directBestEffort();}} @控制器公共类 ServerCon
..
使用 RSocket-Java for Spring Rsocket Server 的 rsocket 路由元数据
如何设置路由元数据(当服务器使用 Spring Boot Rsocket 时，仅在负载中使用 RSocket-Java. Fluxs = connection.flatMapMany(requester -> requester.requestStream(DefaultPayload.create(“Some Message"))) 服务器正在使用@MessageMapping("/
..
带有JWT的RSocket Java Spring @AuthenticationPrincipal
我们如何将@AuthenticationPrincipal与RSocket方法@AuthenticationPrincipal Mono令牌一起使用 public Mono大写(String s，@AuthenticationPrincipal Mono令牌){//令牌始终为空返回Mono.just(s.toUpperCase
..
如何通过另一种方法向反应堆热通量动态添加元素?
我有一个数据源服务，该服务将观察者作为参数. void subscription(Consumer onEventConsumer); 我想使用flux作为RSocket的响应流.我怎样才能做到这一点?我现在看到的应该是 FluxcontrollerMethod(RequestMessage mgs){var flux = Flux.empty();dataSource.sub
..
迁移现有的Spring Websocket处理程序以使用rsocket
假设我有一个用于聊天消息的简单Websocket处理程序: @Override public Mono handle(WebSocketSession webSocketSession) { webSocketSession .receive() .map(webSocketMessage -> webSocketMessa
..
通过RSocket协议的Spring 5 WebFlux服务器推送通知
情况如下: 当客户端A和B通过RSocket协议与服务器建立连接后，可以使用各自的事件(event A或event B)通知每个客户端以触发某些事件对客户端(event X -> action on client X)的操作. 谢谢 解决方案 您可以通过设置有效负载来实现. 服务器: @Controller public class ServerController
..
Spring Integraton RSocket和Spring RSocket交互问题
我创建了一个新示例，并将代码放入客户端和服务器端. 完整代码可在此处找到. > 服务器端有3个版本. 服务器:无Spring Boot应用程序，使用Spring Integration RSocket InboundGateway. 服务器启动，重新使用Spring RSocket自动配置，并通过ServerRSocketMessageHanlder创建ServerRSocket
..
如何使用Spring Security在Spring Boot应用程序中配置RSocket安全
对于微服务到微服务的通信，RSocket似乎是HTTP/S的不错替代品.幸运的是，Spring Boot已经具有平滑的集成，可以简化其配置. 但是，我缺少RSocket和Spring(引导，安全性)文档中与RSocket安全相关的所有信息. 我的问题是: 1)我们如何配置RSocket以使用TLS(在Spring Boot应用程序的上下文中)? 2)Spring Secur
..
仅将Websockets与Rsocket和Spring Webflux一起使用将消息发送给某些客户端
我正在我的一个POC项目中尝试将Rsocket与websocket一起使用.在我的情况下，不需要用户登录.当我从其他服务收到消息时，我只想向某些客户端发送消息.基本上，我的流程是这样的. Service A Service B |--------| we
..
Spring Boot RSocketRequester处理服务器重启
我对Springs RSocketRequester有疑问.我有一个rsocket服务器和客户端.客户端连接到该服务器并请求@MessageMapping端点.它按预期工作. 但是，如果我重新启动服务器该怎么办.如何从客户端自动重新连接到rsocket服务器?谢谢 服务器: @Controller class RSC { @MessageMapping("pong")
..
Rsocket服务器异常:没有针对目标''的处理程序(目标未从客户端传递到服务器)
我为RSocket消息编写了一个演示 问题是我无法访问Rsocket端点， 我从服务器收到以下异常: 客户端: 配置: @Bean RSocket rSocket() { return RSocketFactory.connect() .mimeType(MimeTypeUtils.APPLICATION_JSON_VALUE, MimeTypeU
..