java - 如何让 Spring Webflux WebSocket 保持活跃

Question

我正在研究 spring web-flux 反应式 WebSocket ，所以我试图模拟一个双向文本通信通道，我可以通过它发送和接收消息，我成功地运行了一个 WebSocket 服务器

public Mono<Void> handle(WebSocketSession webSocketSession) {
     webSocketSession.receive().map(msg -> msg.getPayloadAsText())
        .doOnNext(ReactiveWebSocketHandler::processMessage).then();

    Flux<WebSocketMessage> hello = Flux.just(webSocketSession.textMessage("hello"));
    return webSocketSession.send(hello);
  }

当我启动应用程序并点击端点时，它会回复一条消息，但是当我尝试发送消息处理程序未接收时，如何建立一个保持活动状态的双向 WebSocket 连接

标签： javaspringspring-bootwebsocketspring-webflux